summaryrefslogtreecommitdiff
path: root/chromium/mojo/public/cpp/bindings/lib/interface_endpoint_client.cc
diff options
context:
space:
mode:
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.cc20
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;