Home
last modified time | relevance | path

Searched refs:peer_closed (Results 1 – 16 of 16) sorted by relevance

/external/libchrome/mojo/public/cpp/system/tests/
Dwait_unittest.cc97 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 …]
Dhandle_signal_tracker_unittest.cc84 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()
Dhandle_signals_state_unittest.cc23 EXPECT_FALSE(empty_signals.peer_closed()); in TEST_F()
37 EXPECT_TRUE(all_signals.peer_closed()); in TEST_F()
Dwait_set_unittest.cc75 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()
/external/libchrome/mojo/core/ports/
Dnode.cc88 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 …]
Dport.cc18 peer_closed(false) {} in Port()
Dport.h149 bool peer_closed; variable
Dnode.h42 bool peer_closed; member
Devent.h72 bool peer_closed; in COMPONENT_EXPORT() member
Dports_unittest.cc628 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()
/external/libchrome/mojo/public/cpp/system/
Dscope_to_message_pipe.cc17 DCHECK(state.peer_closed()); in OnWatcherSignaled()
Dhandle_signals_state.h60 bool peer_closed() const { in peer_closed() function
/external/libchrome/ipc/
Dipc_mojo_bootstrap.cc302 if (endpoint->peer_closed()) in AttachEndpointClient()
414 bool peer_closed() const { in peer_closed() function in IPC::__anonf422a6c80111::ChannelAssociatedGroupController::Endpoint
640 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()
/external/libchrome/mojo/core/
Dhandle_signals_state.h64 bool peer_closed() const { in peer_closed() function
Dmessage_pipe_dispatcher.cc371 if (!port_status.peer_closed) { in GetHandleSignalsStateNoLock()
415 if (port_status.peer_closed) { in OnPortStatusChanged()
/external/libchrome/mojo/public/cpp/bindings/lib/
Dmultiplex_router.cc57 bool peer_closed() const { return peer_closed_; } in peer_closed() function in mojo::internal::MultiplexRouter::InterfaceEndpoint
469 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()