Home
last modified time | relevance | path

Searched refs:receive (Results 1 – 25 of 625) sorted by relevance

12345678910>>...25

/external/grpc-grpc/src/ruby/spec/generic/
Drpc_desc_spec.rb41 expect(@call).to receive(:read_unary_request).once.and_return(Object.new)
42 expect(@call).to receive(:send_status).once.with(@bs_code, 'NOK', false,
48 expect(@call).to receive(:read_unary_request).once.and_return(Object.new)
49 expect(@call).to receive(:send_status).once.with(UNKNOWN,
56 expect(@call).to receive(:read_unary_request).once.and_return(Object.new)
57 expect(@call).to receive(:send_status).once.with(
63 expect(@call).to receive(:read_unary_request).once.and_raise(CallError)
77 allow(@call).to receive(:single_req_view).and_return(@call)
78 allow(@call).to receive(:output_metadata).and_return(@call)
85 expect(@call).to receive(:read_unary_request).once.and_return(req)
[all …]
Dclient_interceptors_spec.rb29 expect(interceptor).to receive(:request_response)
34 expect_any_instance_of(GRPC::ActiveCall).to receive(:request_response)
41 expect(interceptor).to receive(:request_response)
46 expect_any_instance_of(GRPC::ActiveCall).to receive(:request_response)
56 expect(interceptor).to receive(:client_streamer)
61 expect_any_instance_of(GRPC::ActiveCall).to receive(:client_streamer)
69 expect(interceptor).to receive(:client_streamer)
75 expect_any_instance_of(GRPC::ActiveCall).to receive(:client_streamer)
85 expect(interceptor).to receive(:server_streamer)
91 expect_any_instance_of(GRPC::ActiveCall).to receive(:server_streamer)
[all …]
Dserver_interceptors_spec.rb36 expect(interceptor).to receive(:request_response)
46 expect(interceptor).to receive(:request_response)
52 receive(:request_response).with(request, metadata: client_metadata)
71 expect(interceptor).to receive(:client_streamer)
81 expect(interceptor).to receive(:client_streamer)
87 receive(:client_streamer).with(requests)
106 expect(interceptor).to receive(:server_streamer)
119 expect(interceptor).to receive(:server_streamer)
125 receive(:server_streamer).with(request)
146 expect(interceptor).to receive(:bidi_streamer)
[all …]
/external/scapy/scapy/contrib/
Deigrp.uts120 * The receive-only flag is always set, when a router anounces itself as stub router.
123 p = IP()/EIGRP(tlvlist=[EIGRPStub(flags="receive-only")])
127 p = IP()/EIGRP(tlvlist=[EIGRPStub(flags="connected+receive-only")])
131 p = IP()/EIGRP(tlvlist=[EIGRPStub(flags="static+receive-only")])
135 p = IP()/EIGRP(tlvlist=[EIGRPStub(flags="summary+receive-only")])
139 p = IP()/EIGRP(tlvlist=[EIGRPStub(flags="connected+summary+receive-only")])
143 p = IP()/EIGRP(tlvlist=[EIGRPStub(flags="static+summary+receive-only")])
147 p = IP()/EIGRP(tlvlist=[EIGRPStub(flags="redistributed+connected+receive-only")])
151 p = IP()/EIGRP(tlvlist=[EIGRPStub(flags="redistributed+static+receive-only")])
155 p = IP()/EIGRP(tlvlist=[EIGRPStub(flags="redistributed+static+connected+receive-only")])
[all …]
/external/google-breakpad/src/client/mac/handler/
Dexception_handler.cc481 ExceptionMessage receive; in WaitForMessage() local
485 receive.header.msgh_local_port = self->handler_port_; in WaitForMessage()
486 receive.header.msgh_size = static_cast<mach_msg_size_t>(sizeof(receive)); in WaitForMessage()
487 kern_return_t result = mach_msg(&(receive.header), in WaitForMessage()
489 receive.header.msgh_size, in WaitForMessage()
506 if (!receive.exception) { in WaitForMessage()
509 if (receive.header.msgh_id == kShutdownMessage) in WaitForMessage()
522 if (receive.header.msgh_id == kWriteDumpWithExceptionMessage) { in WaitForMessage()
523 thread = receive.thread.name; in WaitForMessage()
560 if (receive.task.name == mach_task_self()) { in WaitForMessage()
[all …]
/external/tcpdump/tests/
Dsflow_multiple_counter_30_pdus.out14 carrier error 0, frames too long 0, mac receive errors 0, symbol errors 0
26 carrier error 0, frames too long 0, mac receive errors 0, symbol errors 0
38 carrier error 0, frames too long 0, mac receive errors 0, symbol errors 0
50 carrier error 0, frames too long 0, mac receive errors 0, symbol errors 0
62 carrier error 0, frames too long 0, mac receive errors 0, symbol errors 0
74 carrier error 0, frames too long 0, mac receive errors 0, symbol errors 0
86 carrier error 0, frames too long 0, mac receive errors 0, symbol errors 0
100 carrier error 0, frames too long 0, mac receive errors 0, symbol errors 0
112 carrier error 0, frames too long 0, mac receive errors 0, symbol errors 0
124 carrier error 0, frames too long 0, mac receive errors 0, symbol errors 0
[all …]
/external/parameter-framework/asio-1.10.6/include/asio/
Dbasic_stream_socket.hpp439 std::size_t receive(const MutableBufferSequence& buffers) in receive() function in asio::basic_stream_socket
442 std::size_t s = this->get_service().receive( in receive()
479 std::size_t receive(const MutableBufferSequence& buffers, in receive() function in asio::basic_stream_socket
483 std::size_t s = this->get_service().receive( in receive()
508 std::size_t receive(const MutableBufferSequence& buffers, in receive() function in asio::basic_stream_socket
511 return this->get_service().receive( in receive()
761 std::size_t s = this->get_service().receive( in read_some()
788 return this->get_service().receive( in read_some()
/external/compiler-rt/lib/sanitizer_common/
Dsanitizer_symbolizer_win.cc160 HANDLE *receive() { return &h_; } in receive() function
178 if (!::CreatePipe(stdin_read.receive(), stdin_write.receive(), &attrs, 0) || in StartSymbolizerSubprocess()
179 !::CreatePipe(stdout_read.receive(), stdout_write.receive(), &attrs, 0)) { in StartSymbolizerSubprocess()
/external/okhttp/okio/benchmarks/src/main/java/com/squareup/okio/benchmarks/
DBufferPerformanceBench.java138 buffers.receive(requestBytes).readAll(NullSink); in thinkReadHot()
149 buffers.receive(requestBytes).readAll(NullSink); in readWriteRecycle()
242 public BufferedSource receive(byte[] bytes) throws IOException { in receive() method in BufferPerformanceBench.BufferSetup
243 return super.receive(bytes, bench.maxReadBytes); in receive()
277 protected Buffer receive(byte[] bytes, int maxChunkSize) throws IOException { in receive() method in BufferPerformanceBench.BufferState
/external/selinux/libsepol/tests/policies/test-deps/
Dmodreq-perm-global.conf4 class msg { send receive };
10 allow a_t b_t: msg { send receive };
Dmodreq-perm-opt.conf11 class msg { send receive };
17 allow a_mod_t b_mod_t: msg { send receive };
/external/skia/include/private/
DSkMessageBus.h49 void receive(const Message& m); // SkMessageBus is a friend only to call this.
96 void SkMessageBus<Message>::Inbox::receive(const Message& m) { in receive() function
120 bus->fInboxes[i]->receive(m); in Post()
/external/skqp/include/private/
DSkMessageBus.h49 void receive(const Message& m); // SkMessageBus is a friend only to call this.
96 void SkMessageBus<Message>::Inbox::receive(const Message& m) { in receive() function
120 bus->fInboxes[i]->receive(m); in Post()
/external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/
DNettyHttpClient.java158 receive((HttpResponse) message); in channelRead0()
161 receive((HttpContent) message); in channelRead0()
172 void receive(HttpResponse response) { in receive() method in NettyHttpClient.HttpChannel
176 void receive(HttpContent content) { in receive() method in NettyHttpClient.HttpChannel
/external/robolectric-shadows/resources/src/main/java/org/robolectric/res/
DResBunch.java30 void receive(ResourceTable.Visitor visitor) { in receive() method in ResBunch
32 resBundle.receive(visitor); in receive()
/external/python/cpython2/Lib/test/
Dtest_socketserver.py43 def receive(sock, n, timeout=20): function
184 buf = data = receive(s, 100)
186 data = receive(s, 100)
196 buf = data = receive(s, 100)
198 data = receive(s, 100)
/external/perfetto/ui/src/base/
Dremote.ts36 this.receive(event.data);
61 private receive(response: RemoteResponse): void { method in Remote
/external/clang/docs/
DLTOVisibility.rst31 visibility receive public LTO visibility. When targeting Windows, classes
32 with dllimport or dllexport attributes receive public LTO visibility. All
33 other classes receive hidden LTO visibility. Classes with internal linkage
34 (e.g. classes declared in unnamed namespaces) also receive hidden LTO
58 COM case, classes with the ``__declspec(uuid())`` attribute receive public
/external/autotest/server/site_tests/bluetooth_AdapterHIDReports/
Dcontrol.le.mouse11 CRITERIA = 'Adapter should receive HID events correctly.'
20 Verify that the bluetooth adapter of the DUT could receive HID reports
Dcontrol.ble_mouse11 CRITERIA = 'Adapter should receive BLE HID events correctly.'
20 Verify that the bluetooth adapter of the DUT could receive HID reports
Dcontrol.mouse.suspend_resume11 CRITERIA = 'Adapter should receive HID events correctly after a suspend resume.'
20 Verify that the bluetooth adapter of the DUT could receive HID reports
Dcontrol.mouse11 CRITERIA = 'Adapter should receive HID events correctly.'
20 Verify that the bluetooth adapter of the DUT could receive HID reports
Dcontrol.mouse.reboot11 CRITERIA = 'Adapter should receive HID events correctly.'
20 Verify that the bluetooth adapter of the DUT could receive HID reports
/external/ltp/testcases/open_posix_testsuite/stress/mqueues/
Dmulti_send_rev_2.c56 int *receive(void *ID) in receive() function
111 pthread_create(&rev[i], NULL, (void *)receive, in main()
/external/webrtc/talk/media/base/
Drtpdataengine.h108 virtual bool SetReceive(bool receive) { in SetReceive() argument
109 receiving_ = receive; in SetReceive()

12345678910>>...25