Searched refs:peer_closed (Results 1 – 16 of 16) sorted by relevance
97 EXPECT_TRUE(hss.readable() && hss.writable() && !hss.peer_closed()); in TEST_F()109 EXPECT_TRUE(hss.readable() && hss.peer_closed() && !hss.writable()); in TEST_F()120 EXPECT_TRUE(hss.peer_closed() && !hss.readable() && !hss.writable()); in TEST_F()140 EXPECT_TRUE(hss.readable() && hss.writable() && !hss.peer_closed()); in TEST_F()160 EXPECT_TRUE(!hss.readable() && !hss.writable() && hss.peer_closed()); in TEST_F()204 EXPECT_TRUE(!hss[0].readable() && hss[0].writable() && !hss[0].peer_closed()); in TEST_F()207 EXPECT_TRUE(hss[1].readable() && hss[1].writable() && !hss[1].peer_closed()); in TEST_F()224 EXPECT_TRUE(!hss[0].readable() && !hss[0].writable() && hss[0].peer_closed()); in TEST_F()270 EXPECT_TRUE(!hss[0].readable() && hss[0].writable() && !hss[0].peer_closed()); in TEST_F()273 EXPECT_TRUE(hss[1].readable() && hss[1].writable() && !hss[1].peer_closed()); in TEST_F()[all …]
84 EXPECT_FALSE(peer_closed_tracker.last_known_state().peer_closed()); in TEST_F()90 EXPECT_FALSE(readable_tracker.last_known_state().peer_closed()); in TEST_F()98 EXPECT_TRUE(pipe.handle0->QuerySignalsState().peer_closed()); in TEST_F()99 EXPECT_TRUE(peer_closed_tracker.last_known_state().peer_closed()); in TEST_F()100 EXPECT_FALSE(readable_tracker.last_known_state().peer_closed()); in TEST_F()
23 EXPECT_FALSE(empty_signals.peer_closed()); in TEST_F()37 EXPECT_TRUE(all_signals.peer_closed()); in TEST_F()
75 EXPECT_TRUE(hss[0].readable() && hss[0].writable() && !hss[0].peer_closed()); in TEST_F()92 EXPECT_TRUE(hss[0].readable() && hss[0].writable() && !hss[0].peer_closed()); in TEST_F()108 EXPECT_TRUE(hss[0].readable() && hss[0].writable() && !hss[0].peer_closed()); in TEST_F()109 EXPECT_TRUE(hss[1].readable() && hss[1].writable() && !hss[1].peer_closed()); in TEST_F()
88 if (port->peer_closed || port->remove_proxy_on_last_message) { in CanAcceptMoreMessages()306 port_status->peer_closed = port->peer_closed; in GetStatus()698 port->peer_closed = true; in OnObserveClosure()900 if (port0->peer_closed) in MergePortsInternal()902 if (port1->peer_closed) in MergePortsInternal()919 if (try_remove_proxy_immediately || port->peer_closed) { in MergePortsInternal()979 if (port->peer_closed) in ConvertToProxy()993 port_descriptor->peer_closed = port->peer_closed; in ConvertToProxy()1011 port->peer_closed = port_descriptor.peer_closed; in AcceptPort()1014 << " [peer_closed=" << port->peer_closed in AcceptPort()[all …]
18 peer_closed(false) {} in Port()
149 bool peer_closed; variable
42 bool peer_closed; member
72 bool peer_closed; in COMPONENT_EXPORT() member
628 EXPECT_TRUE(status.peer_closed); in TEST_F()679 EXPECT_TRUE(status.peer_closed); in TEST_F()1087 EXPECT_TRUE(status.peer_closed); in TEST_F()1157 EXPECT_TRUE(status.peer_closed); in TEST_F()
17 DCHECK(state.peer_closed()); in OnWatcherSignaled()
60 bool peer_closed() const { in peer_closed() function
302 if (endpoint->peer_closed()) in AttachEndpointClient()414 bool peer_closed() const { in peer_closed() function in IPC::__anonf422a6c80111::ChannelAssociatedGroupController::Endpoint640 DCHECK(endpoint->peer_closed()); in ~ChannelAssociatedGroupController()749 if (endpoint->closed() && endpoint->peer_closed()) in MarkClosedAndMaybeRemove()757 if (endpoint->closed() && endpoint->peer_closed()) in MarkPeerClosedAndMaybeRemove()914 if (!endpoint->peer_closed()) { in OnPeerAssociatedEndpointClosed()
64 bool peer_closed() const { in peer_closed() function
371 if (!port_status.peer_closed) { in GetHandleSignalsStateNoLock()415 if (port_status.peer_closed) { in OnPortStatusChanged()
57 bool peer_closed() const { return peer_closed_; } in peer_closed() function in mojo::internal::MultiplexRouter::InterfaceEndpoint469 if (endpoint->peer_closed()) in AttachEndpointClient()532 if (iter->second->peer_closed() || in ResumeIncomingMethodCallProcessing()633 if (!endpoint->peer_closed()) { in OnPeerAssociatedEndpointClosed()906 if (endpoint->closed() && endpoint->peer_closed()) in UpdateEndpointStateMayRemove()