Home
last modified time | relevance | path

Searched refs:handle0 (Results 1 – 25 of 48) sorted by relevance

12

/external/libchrome/mojo/public/cpp/system/tests/
Dhandle_signal_tracker_unittest.cc43 HandleSignalTracker tracker(pipe.handle0.get(), in TEST_F()
50 Wait(pipe.handle0.get(), MOJO_HANDLE_SIGNAL_READABLE, in TEST_F()
54 HandleSignalTracker tracker(pipe.handle0.get(), in TEST_F()
62 HandleSignalTracker tracker(pipe.handle0.get(), MOJO_HANDLE_SIGNAL_READABLE); in TEST_F()
71 ReadMessageRaw(pipe.handle0.get(), &bytes, nullptr, in TEST_F()
79 HandleSignalTracker readable_tracker(pipe.handle0.get(), in TEST_F()
81 HandleSignalTracker peer_closed_tracker(pipe.handle0.get(), in TEST_F()
98 EXPECT_TRUE(pipe.handle0->QuerySignalsState().peer_closed()); in TEST_F()
105 ReadMessageRaw(pipe.handle0.get(), &bytes, nullptr, in TEST_F()
Dwait_set_unittest.cc64 WriteMessage(p.handle0, kTestMessage1); in TEST_F()
81 wait_set.AddHandle(p.handle0.get(), MOJO_HANDLE_SIGNAL_READABLE); in TEST_F()
90 EXPECT_EQ(p.handle0.get(), ready_handles[0]); in TEST_F()
102 EXPECT_TRUE((ready_handles[0] == p.handle0.get() && in TEST_F()
105 ready_handles[1] == p.handle0.get())); in TEST_F()
116 EXPECT_TRUE(ready_handles[0] == p.handle0.get() || in TEST_F()
127 EXPECT_TRUE(ready_handles[0] == p.handle0.get() || in TEST_F()
143 wait_set.AddHandle(q.handle0.get(), MOJO_HANDLE_SIGNAL_READABLE); in TEST_F()
145 wait_set.AddHandle(p.handle0.get(), MOJO_HANDLE_SIGNAL_READABLE); in TEST_F()
154 EXPECT_EQ(p.handle0.get(), ready_handles[0]); in TEST_F()
[all …]
Dwait_unittest.cc64 Handle valid_handles[2] = {p.handle0.get(), p.handle1.get()}; in TEST_F()
82 WriteMessage(p.handle0, kTestMessage1); in TEST_F()
103 p.handle0.reset(); in TEST_F()
134 &p.handle0)); in TEST_F()
154 &p.handle0)); in TEST_F()
172 &p.handle0)); in TEST_F()
175 Wait(p.handle0.get(), MOJO_HANDLE_SIGNAL_READABLE)); in TEST_F()
182 WriteMessage(p.handle0, kTestMessage1); in TEST_F()
188 Handle handles[2] = {p.handle0.get(), p.handle1.get()}; in TEST_F()
215 p.handle0.reset(); in TEST_F()
[all …]
Dscope_to_message_pipe_unittest.cc46 std::move(pipe.handle0)); in TEST_F()
63 ScopeToMessagePipe(42, std::move(pipe.handle0)); in TEST_F()
/external/libchrome/mojo/public/c/system/tests/
Dcore_unittest_pure_c.c44 MojoHandle handle0, handle1; in MinimalCTest() local
49 handle0 = MOJO_HANDLE_INVALID; in MinimalCTest()
50 EXPECT_NE(MOJO_RESULT_OK, MojoClose(handle0)); in MinimalCTest()
53 MojoQueryHandleSignalsState(handle0, NULL)); in MinimalCTest()
56 EXPECT_EQ(MOJO_RESULT_OK, MojoCreateMessagePipe(NULL, &handle0, &handle1)); in MinimalCTest()
62 EXPECT_EQ(MOJO_RESULT_OK, MojoWriteMessage(handle0, message, NULL)); in MinimalCTest()
72 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(handle0)); in MinimalCTest()
Dcore_api_unittest.cc107 Handle handle0(h0); in TEST() local
109 mojo::WaitMany(&handle0, &sig, 1, &result_index, states)); in TEST()
/external/libchrome/mojo/public/cpp/system/
Dmessage_pipe.h52 MessagePipeHandle handle0; in CreateMessagePipe() local
55 options, handle0.mutable_value(), handle1.mutable_value()); in CreateMessagePipe()
58 message_pipe0->reset(handle0); in CreateMessagePipe()
134 ScopedMessagePipeHandle handle0; variable
139 MojoResult result = CreateMessagePipe(nullptr, &handle0, &handle1); in MessagePipe()
141 DCHECK(handle0.is_valid()); in MessagePipe()
146 MojoResult result = CreateMessagePipe(&options, &handle0, &handle1); in MessagePipe()
148 DCHECK(handle0.is_valid()); in MessagePipe()
DREADME.md48 // difference between |handle0| or |handle1| here. They're just two ends of a
51 mojo::ScopedMessagePipeHandle client = std::move(pipe.handle0);
184 mojo::HandleSignalsState a = message_pipe.handle0->QuerySignalsState();
194 MojoQueryHandleSignalsState(handle0, &state);
203 if (message_pipe.handle0->QuerySignalsState().readable()) {
269 PipeReader reader(std::move(pipe.handle0));
298 mojo::WriteMessageRaw(pipe.handle0.get(), "hey", 3, nullptr, nullptr,
322 mojo::MessagePipeHandle handles[2] = {a.handle0.get(), b.handle0.get()};
328 // a.handle0 was ready.
330 // b.handle0 was ready.
[all …]
/external/libchrome/mojo/public/cpp/bindings/tests/
Dtest_helpers_unittest.cc112 ScopedMessagePipeHandle handle0, handle1; in TEST_F() local
113 WriteMessageRaw(pipe.handle0.get(), kTestString.data(), kTestString.size(), in TEST_F()
115 wait_for_trampoline.BounceOne(std::move(pipe.handle0), &handle0); in TEST_F()
116 wait_for_trampoline.BounceTwo(std::move(handle0), std::move(pipe.handle1), in TEST_F()
117 &handle0, &handle1); in TEST_F()
Dbindings_perftest.cc196 new internal::MultiplexRouter(std::move(pipe.handle0), in TEST_F()
253 std::move(pipe.handle0), internal::MultiplexRouter::SINGLE_INTERFACE, in TEST_F()
Dnative_struct_unittest.cc70 std::move(pipe.handle0)); in TEST_P()
Dhandle_passing_unittest.cc213 1, std::move(pipe1.handle0), base::nullopt, std::move(imported))); in TEST_P()
217 factory->DoStuff(std::move(request), std::move(pipe0.handle0), in TEST_P()
/external/libchrome/mojo/public/js/lib/
Dinterface_endpoint_handle.js133 var handle0 = new InterfaceEndpointHandle();
135 handle0.state_.initPendingState(handle1.state_);
136 handle1.state_.initPendingState(handle0.state_);
137 return {handle0: handle0, handle1: handle1};
Dconnector.js153 this.handle_ = dummyPipe.handle0;
/external/openscreen/platform/impl/
Dsocket_handle_waiter_posix_unittest.cc51 SocketHandle handle0{0}; in TEST() local
54 const SocketHandle& handle0_ref = handle0; in TEST()
72 SocketHandle handle0{0}; in TEST() local
76 const SocketHandle& handle0_ref = handle0; in TEST()
/external/libchrome/ipc/
Dipc_sync_channel_unittest.cc331 new SimpleServer(pump_during_send, std::move(pipe.handle0))); in Simple()
410 new TwoStepServer(create_server_pipe_now, std::move(pipe.handle0))); in TwoStep()
445 new SimpleServer(pump_during_send, std::move(pipe.handle0))); in DelayReply()
509 std::move(pipe.handle0))); in NoHang()
581 std::move(pipe.handle0))); in Unblock()
676 true, server_pump_first, server_pump_second, std::move(pipe.handle0))); in Recursive()
701 false, server_pump_first, server_pump_second, std::move(pipe.handle0))); in RecursiveNoHang()
811 worker = new MultipleServer2(std::move(pipe2.handle0)); in Multiple()
819 worker = new MultipleServer1(server_pump, std::move(pipe1.handle0)); in Multiple()
915 std::move(pipe1.handle0), "Got first message"); in QueuedReply()
[all …]
/external/libchrome/mojo/core/
Dmessage_unittest.cc281 message->AddMessagePipe(std::move(pipe.handle0)); in TEST_F()
304 message->AddMessagePipe(std::move(pipes[0].handle0)); in TEST_F()
305 message->AddMessagePipe(std::move(pipes[1].handle0)); in TEST_F()
306 message->AddMessagePipe(std::move(pipes[2].handle0)); in TEST_F()
307 message->AddMessagePipe(std::move(pipes[3].handle0)); in TEST_F()
328 pipes[0].handle0.get().value(), pipes[1].handle0.get().value(), in TEST_F()
329 pipes[2].handle0.get().value(), pipes[3].handle0.get().value(), in TEST_F()
331 message->AddMessagePipe(std::move(pipes[0].handle0)); in TEST_F()
332 message->AddMessagePipe(std::move(pipes[1].handle0)); in TEST_F()
333 message->AddMessagePipe(std::move(pipes[2].handle0)); in TEST_F()
[all …]
/external/libchrome/mojo/public/cpp/bindings/
Dassociated_interface_ptr.h207 ScopedInterfaceEndpointHandle handle0; in MakeRequest() local
209 ScopedInterfaceEndpointHandle::CreatePairPendingAssociation(&handle0, in MakeRequest()
212 ptr_info->set_handle(std::move(handle0)); in MakeRequest()
235 std::move(pipe.handle0), internal::MultiplexRouter::MULTI_INTERFACE, in MakeRequestAssociatedWithDedicatedPipe()
Dinterface_request.h139 ptr->Bind(InterfacePtrInfo<Interface>(std::move(pipe.handle0), 0u),
149 ptr_info->set_handle(std::move(pipe.handle0)); in MakeRequest()
Dscoped_interface_endpoint_handle.h33 ScopedInterfaceEndpointHandle* handle0, in COMPONENT_EXPORT()
/external/libchrome/mojo/public/js/
Dbindings.js14 var {handle0, handle1} = internal.createPairPendingAssociation();
15 output.interfaceEndpointHandle = handle0;
23 output.handle = pipe.handle0;
30 output.ptr.bind(new mojo.InterfacePtrInfo(pipe.handle0, 0));
/external/tensorflow/tensorflow/python/kernel_tests/
Dsparse_tensors_map_ops_test.py85 handle0 = add_sparse_to_tensors_map(sp_input0, shared_name="a")
87 self.assertEqual(handle0.get_shape(), ())
88 handles_concat = array_ops.stack([handle0, handle1])
91 sparse_map_op=handle0.op, sparse_handles=handles_concat)
/external/libchrome/mojo/public/cpp/bindings/lib/
Dassociated_interface_ptr.cc13 std::move(pipe.handle0), internal::MultiplexRouter::MULTI_INTERFACE, in AssociateWithDisconnectedPipe()
Dscoped_interface_endpoint_handle.cc287 ScopedInterfaceEndpointHandle* handle0, in CreatePairPendingAssociation() argument
294 *handle0 = std::move(result0); in CreatePairPendingAssociation()
/external/tensorflow/tensorflow/core/distributed_runtime/eager/
Deager_service_impl_test.cc1171 TensorHandle* handle0 = nullptr; in TEST_F() local
1172 TF_ASSERT_OK(packed_handle->ExtractPackedHandle(0, &handle0)); in TEST_F()
1173 EXPECT_EQ(handle0->Type(), TensorHandle::LOCAL); in TEST_F()
1174 EXPECT_EQ(handle0->op_device()->name(), device0); in TEST_F()
1176 TF_ASSERT_OK(handle0->Tensor(&t0)); in TEST_F()
1189 TF_ASSERT_OK(handle0->Tensor(&t1)); in TEST_F()

12