| Index: remoting/host/native_messaging/pipe_messaging_channel.cc
|
| diff --git a/remoting/host/native_messaging/pipe_messaging_channel.cc b/remoting/host/native_messaging/pipe_messaging_channel.cc
|
| index 014e67de4c486dfeb12d5b5e6ac7ef1ceb097e6e..0b288a17065e2c657cbdddbb351208ec6dbc89c3 100644
|
| --- a/remoting/host/native_messaging/pipe_messaging_channel.cc
|
| +++ b/remoting/host/native_messaging/pipe_messaging_channel.cc
|
| @@ -54,10 +54,12 @@ PipeMessagingChannel::PipeMessagingChannel(base::File input, base::File output)
|
| weak_ptr_ = weak_factory_.GetWeakPtr();
|
| }
|
|
|
| -PipeMessagingChannel::~PipeMessagingChannel() {}
|
| +PipeMessagingChannel::~PipeMessagingChannel() {
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
| +}
|
|
|
| void PipeMessagingChannel::Start(EventHandler* event_handler) {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
| DCHECK(!event_handler_);
|
|
|
| event_handler_ = event_handler;
|
| @@ -70,14 +72,14 @@ void PipeMessagingChannel::Start(EventHandler* event_handler) {
|
|
|
| void PipeMessagingChannel::ProcessMessage(
|
| std::unique_ptr<base::Value> message) {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| if (event_handler_)
|
| event_handler_->OnMessage(std::move(message));
|
| }
|
|
|
| void PipeMessagingChannel::SendMessage(std::unique_ptr<base::Value> message) {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| bool success = message && native_messaging_writer_;
|
| if (success)
|
| @@ -91,7 +93,7 @@ void PipeMessagingChannel::SendMessage(std::unique_ptr<base::Value> message) {
|
| }
|
|
|
| void PipeMessagingChannel::Shutdown() {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| if (event_handler_) {
|
| // Set |event_handler_| to nullptr to indicate the object is in a shutdown
|
|
|