diff options
Diffstat (limited to 'chromium/mojo/public/cpp/bindings/lib/interface_endpoint_client.cc')
-rw-r--r-- | chromium/mojo/public/cpp/bindings/lib/interface_endpoint_client.cc | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/chromium/mojo/public/cpp/bindings/lib/interface_endpoint_client.cc b/chromium/mojo/public/cpp/bindings/lib/interface_endpoint_client.cc index c1e7efe6954..c7aade50db3 100644 --- a/chromium/mojo/public/cpp/bindings/lib/interface_endpoint_client.cc +++ b/chromium/mojo/public/cpp/bindings/lib/interface_endpoint_client.cc @@ -455,7 +455,7 @@ InterfaceEndpointClient::InterfaceEndpointClient( ipc_hash_callback_(ipc_hash_callback), method_name_callback_(method_name_callback) { DCHECK(handle_.is_valid()); - DETACH_FROM_SEQUENCE(sequence_checker_); + sequence_checker_.DetachFromSequence(); // TODO(yzshen): the way to use validator (or message filter in general) // directly is a little awkward. @@ -479,7 +479,7 @@ InterfaceEndpointClient::InterfaceEndpointClient( } InterfaceEndpointClient::~InterfaceEndpointClient() { - DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); + CHECK(sequence_checker_.CalledOnValidSequence()); if (controller_) handle_.group_controller()->DetachEndpointClient(handle_); } @@ -498,7 +498,7 @@ scoped_refptr<ThreadSafeProxy> InterfaceEndpointClient::CreateThreadSafeProxy( } ScopedInterfaceEndpointHandle InterfaceEndpointClient::PassHandle() { - DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); + CHECK(sequence_checker_.CalledOnValidSequence()); DCHECK(!has_pending_responders()); if (!handle_.is_valid()) @@ -520,7 +520,7 @@ void InterfaceEndpointClient::SetFilter(std::unique_ptr<MessageFilter> filter) { } void InterfaceEndpointClient::RaiseError() { - DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); + CHECK(sequence_checker_.CalledOnValidSequence()); if (!handle_.pending_association()) handle_.group_controller()->RaiseError(); @@ -528,7 +528,7 @@ void InterfaceEndpointClient::RaiseError() { void InterfaceEndpointClient::CloseWithReason(uint32_t custom_reason, base::StringPiece description) { - DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); + CHECK(sequence_checker_.CalledOnValidSequence()); auto handle = PassHandle(); handle.ResetWithReason(custom_reason, description); @@ -564,7 +564,7 @@ bool InterfaceEndpointClient::AcceptWithResponder( bool InterfaceEndpointClient::SendMessage(Message* message, bool is_control_message) { - DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); + CHECK(sequence_checker_.CalledOnValidSequence()); DCHECK(!message->has_flag(Message::kFlagExpectsResponse)); DCHECK(!handle_.pending_association()); @@ -600,7 +600,7 @@ bool InterfaceEndpointClient::SendMessageWithResponder( bool is_control_message, SyncSendMode sync_send_mode, std::unique_ptr<MessageReceiver> responder) { - DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); + CHECK(sequence_checker_.CalledOnValidSequence()); DCHECK(message->has_flag(Message::kFlagExpectsResponse)); DCHECK(!handle_.pending_association()); @@ -681,7 +681,7 @@ bool InterfaceEndpointClient::SendMessageWithResponder( } bool InterfaceEndpointClient::HandleIncomingMessage(Message* message) { - DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); + CHECK(sequence_checker_.CalledOnValidSequence()); // Accept() may invalidate `this` and `message` so we need to copy the // members we need for logging in case of an error. @@ -698,7 +698,7 @@ bool InterfaceEndpointClient::HandleIncomingMessage(Message* message) { void InterfaceEndpointClient::NotifyError( const absl::optional<DisconnectReason>& reason) { - DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); + CHECK(sequence_checker_.CalledOnValidSequence()); if (encountered_error_) return; @@ -821,7 +821,7 @@ void InterfaceEndpointClient::MaybeSendNotifyIdle() { } void InterfaceEndpointClient::ResetFromAnotherSequenceUnsafe() { - DETACH_FROM_SEQUENCE(sequence_checker_); + sequence_checker_.DetachFromSequence(); if (controller_) { controller_ = nullptr; |