/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
H A D | IncomingStreamHandler.java | 24 @Override public void receive(FramedStream stream) throws IOException { 35 void receive(FramedStream stream) throws IOException; method in interface:IncomingStreamHandler
|
H A D | Ping.java | 37 void receive() { method in class:Ping
|
H A D | FramedStream.java | 286 this.source.receive(in, length); 311 * class uses synchronization to safely receive incoming data frames, it is 315 /** Buffer to receive data from the network into. Only accessed by the reader thread. */ 329 * receive no more bytes beyond those already in the buffer. 384 void receive(BufferedSource in, long byteCount) throws IOException { method in class:FramedStream.FramedDataSource 408 // Fill the receive buffer without holding any locks. 505 waitForIo(); // Wait until we receive a WINDOW_UPDATE for this stream.
|
/external/skia/src/core/ |
H A D | SkMessageBus.h | 36 void receive(const Message& m); // SkMessageBus is a friend only to call this. 81 void SkMessageBus<Message>::Inbox::receive(const Message& m) { function in class:SkMessageBus::Inbox 104 bus->fInboxes[i]->receive(m);
|
/external/libchrome/crypto/ |
H A D | scoped_capi_types.h | 68 CAPIHandle* receive() { function in class:crypto::ScopedCAPIHandle
|
/external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/internal/framed/ |
H A D | FramedServer.java | 92 @Override public void receive(final FramedStream stream) throws IOException { method in class:FramedServer
|
/external/parameter-framework/asio/include/asio/ |
H A D | basic_stream_socket.hpp | 412 * This function is used to receive data on the stream socket. The function 424 * @note The receive operation may not receive all of the requested number of 429 * To receive into a single data buffer use the @ref buffer function as 432 * socket.receive(asio::buffer(data, size)); 439 std::size_t receive(const MutableBufferSequence& buffers) function in class:asio::basic_stream_socket 442 std::size_t s = this->get_service().receive( 444 asio::detail::throw_error(ec, "receive"); 450 * This function is used to receive data on the stream socket. The function 456 * @param flags Flags specifying how the receive cal 479 std::size_t receive(const MutableBufferSequence& buffers, function in class:asio::basic_stream_socket 508 std::size_t receive(const MutableBufferSequence& buffers, function in class:asio::basic_stream_socket [all...] |
H A D | stream_socket_service.hpp | 299 std::size_t receive(implementation_type& impl, function in class:asio::stream_socket_service 303 return service_impl_.receive(impl, buffers, flags, ec); 306 /// Start an asynchronous receive.
|
/external/parameter-framework/asio-1.10.6/include/asio/ |
H A D | basic_stream_socket.hpp | 412 * This function is used to receive data on the stream socket. The function 424 * @note The receive operation may not receive all of the requested number of 429 * To receive into a single data buffer use the @ref buffer function as 432 * socket.receive(asio::buffer(data, size)); 439 std::size_t receive(const MutableBufferSequence& buffers) function in class:asio::basic_stream_socket 442 std::size_t s = this->get_service().receive( 444 asio::detail::throw_error(ec, "receive"); 450 * This function is used to receive data on the stream socket. The function 456 * @param flags Flags specifying how the receive cal 479 std::size_t receive(const MutableBufferSequence& buffers, function in class:asio::basic_stream_socket 508 std::size_t receive(const MutableBufferSequence& buffers, function in class:asio::basic_stream_socket [all...] |
H A D | stream_socket_service.hpp | 299 std::size_t receive(implementation_type& impl, function in class:asio::stream_socket_service 303 return service_impl_.receive(impl, buffers, flags, ec); 306 /// Start an asynchronous receive.
|
/external/dbus/bus/ |
H A D | policy.h | 83 } receive; member in union:BusPolicyRule::__anon3604
|
/external/deqp/framework/delibs/decpp/ |
H A D | deSocket.hpp | 99 deSocketResult receive (void* buf, size_t bufSize, size_t* numRecv) { return deSocket_receive(m_socket, buf, bufSize, numRecv); } function in class:de::Socket
|
/external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/ |
H A D | NettyHttpClient.java | 158 receive((HttpResponse) message); 161 receive((HttpContent) message); 172 void receive(HttpResponse response) { method in class:NettyHttpClient.HttpChannel 176 void receive(HttpContent content) { method in class:NettyHttpClient.HttpChannel
|
/external/webrtc/talk/media/base/ |
H A D | rtpdataengine.h | 108 virtual bool SetReceive(bool receive) { argument 109 receiving_ = receive;
|
/external/compiler-rt/lib/sanitizer_common/ |
H A D | sanitizer_symbolizer_win.cc | 160 HANDLE *receive() { return &h_; } function in struct:__sanitizer::__anon3344::ScopedHandle 178 if (!::CreatePipe(stdin_read.receive(), stdin_write.receive(), &attrs, 0) || 179 !::CreatePipe(stdout_read.receive(), stdout_write.receive(), &attrs, 0)) {
|
/external/deqp/execserver/ |
H A D | xsExecutionServer.cpp | 220 anyIO = receive() || anyIO; 342 bool ExecutionRequestHandler::receive (void) function in class:xs::ExecutionRequestHandler 349 deSocketResult result = m_socket->receive(&m_sendRecvTmpBuf[0], maxLen, &numRecv); 367 throw ConnectionError("receive() failed");
|
/external/kernel-headers/original/uapi/linux/ |
H A D | atmlec.h | 89 unsigned char receive; /* 1= receive vcc, 0 = send vcc */ member in struct:atmlec_ioc
|
/external/libnfc-nxp/src/ |
H A D | phFriNfc_LlcpMac.h | 158 pphFriNfcLlpcMac_Receive_t receive; member in struct:phFriNfc_LlcpMac_Interface
|
/external/okhttp/okio/benchmarks/src/main/java/com/squareup/okio/benchmarks/ |
H A D | BufferPerformanceBench.java | 64 * Each benchmark thread maintains three buffers; a receive buffer, a process buffer 67 * - We fill up the receive buffer using the origin, write the request to the process 138 buffers.receive(requestBytes).readAll(NullSink); 149 buffers.receive(requestBytes).readAll(NullSink); 242 public BufferedSource receive(byte[] bytes) throws IOException { method in class:BufferPerformanceBench.BufferSetup 243 return super.receive(bytes, bench.maxReadBytes); 273 * Fills up the receive buffer, hands off to process buffer and returns it for consuming. 274 * Expects receive and process buffers to be empty. Leaves the receive buffer empty and 277 protected Buffer receive(byt method in class:BufferPerformanceBench.BufferState [all...] |
/external/parameter-framework/asio/include/asio/detail/ |
H A D | reactive_socket_service_base.hpp | 241 size_t receive(base_implementation_type& impl, function in class:asio::detail::reactive_socket_service_base 253 size_t receive(base_implementation_type& impl, const null_buffers&, function in class:asio::detail::reactive_socket_service_base 262 // Start an asynchronous receive. The buffer for the data being received 347 // Start an asynchronous receive. The buffer for the data being received
|
/external/parameter-framework/asio-1.10.6/include/asio/detail/ |
H A D | reactive_socket_service_base.hpp | 241 size_t receive(base_implementation_type& impl, function in class:asio::detail::reactive_socket_service_base 253 size_t receive(base_implementation_type& impl, const null_buffers&, function in class:asio::detail::reactive_socket_service_base 262 // Start an asynchronous receive. The buffer for the data being received 347 // Start an asynchronous receive. The buffer for the data being received
|
/external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/ |
H A D | MockWebServer.java | 860 @Override public void receive(FramedStream stream) throws IOException { method in class:MockWebServer.FramedSocketHandler
|
/external/webrtc/webrtc/voice_engine/test/cmd_test/ |
H A D | voe_cmd_test.cc | 387 const bool receive = !(call_selection == 2); local 389 if (receive) { 436 printf("%i. Toggle receive-side AGC \n", option_index++); 437 printf("%i. Toggle receive-side NS \n", option_index++); 822 if (receive) {
|
/external/google-breakpad/src/client/mac/handler/ |
H A D | exception_handler.cc | 481 ExceptionMessage receive; local 485 receive.header.msgh_local_port = self->handler_port_; 486 receive.header.msgh_size = static_cast<mach_msg_size_t>(sizeof(receive)); 487 kern_return_t result = mach_msg(&(receive.header), 489 receive.header.msgh_size, 506 if (!receive.exception) { 509 if (receive.header.msgh_id == kShutdownMessage) 522 if (receive.header.msgh_id == kWriteDumpWithExceptionMessage) { 523 thread = receive [all...] |
/external/libnfc-nxp/inc/ |
H A D | phNfcInterface.h | 265 * This callback signals the completion of the asynchronous send or receive 337 pphNfcIF_Transact_t receive; member in struct:phNfc_sLowerIF
|