Home
last modified time | relevance | path

Searched refs:send_bytes (Results 1 – 10 of 10) sorted by relevance

/third_party/grpc/src/core/ext/transport/chttp2/transport/
Dwriting.cc136 int64_t send_bytes, grpc_chttp2_write_cb** list, in update_list() argument
141 *ctr += send_bytes; in update_list()
341 uint32_t send_bytes = static_cast<uint32_t> GPR_MIN( in FlushUncompressedBytes() local
343 is_last_frame_ = send_bytes == s_->flow_controlled_buffer.length && in FlushUncompressedBytes()
347 grpc_chttp2_encode_data(s_->id, &s_->flow_controlled_buffer, send_bytes, in FlushUncompressedBytes()
349 s_->flow_control->SentData(send_bytes); in FlushUncompressedBytes()
350 s_->sending_bytes += send_bytes; in FlushUncompressedBytes()
357 uint32_t send_bytes = static_cast<uint32_t> GPR_MIN( in FlushCompressedBytes() local
360 (send_bytes == s_->compressed_data_buffer.length && in FlushCompressedBytes()
382 grpc_chttp2_encode_data(s_->id, &s_->compressed_data_buffer, send_bytes, in FlushCompressedBytes()
[all …]
/third_party/libuv/test/
Dtest-poll.c308 int send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer); local
309 ASSERT(send_bytes > 0);
312 r = send(context->sock, buffer, send_bytes, 0);
332 int send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer); local
333 ASSERT(send_bytes > 0);
336 r = send(context->sock, buffer, send_bytes, 0);
350 send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer);
351 ASSERT(send_bytes > 0);
354 r = send(context->sock, buffer, send_bytes, 0);
/third_party/python/Lib/multiprocessing/
Dqueues.py82 self._send_bytes = self._writer.send_bytes
214 def _feed(buffer, notempty, send_bytes, writelock, close, ignore_epipe, argument
247 send_bytes(obj)
251 send_bytes(obj)
375 self._writer.send_bytes(obj)
378 self._writer.send_bytes(obj)
Dconnection.py186 def send_bytes(self, buf, offset=0, size=None): member in _ConnectionBase
743 connection.send_bytes(CHALLENGE + message)
747 connection.send_bytes(WELCOME)
749 connection.send_bytes(FAILURE)
761 connection.send_bytes(digest)
780 self._conn.send_bytes(s)
Dresource_sharer.py33 conn.send_bytes(share)
/third_party/libwebsockets/lib/tls/mbedtls/wrapper/library/
Dssl_lib.c493 int send_bytes, bytes; in SSL_write() local
502 send_bytes = len; in SSL_write()
506 if (send_bytes > SSL_SEND_DATA_MAX_LENGTH) in SSL_write()
509 bytes = send_bytes; in SSL_write()
521 send_bytes -= ret; in SSL_write()
524 } while (ret > 0 && send_bytes && ret == bytes); in SSL_write()
527 ret = len - send_bytes; in SSL_write()
531 if (send_bytes == len) in SSL_write()
534 ret = len - send_bytes; in SSL_write()
/third_party/python/Lib/multiprocessing/dummy/
Dconnection.py56 self.send = self.send_bytes = _out.put
/third_party/python/Lib/test/
D_test_multiprocessing.py3036 conn.send_bytes(msg)
3057 self.assertEqual(conn.send_bytes(msg), None)
3063 self.assertEqual(conn.send_bytes(arr), None)
3070 self.assertEqual(conn.send_bytes(arr), None)
3076 self.assertEqual(conn.send_bytes(longmsg), None)
3104 conn.send_bytes(really_big_msg)
3107 conn.send_bytes(SENTINEL) # tell child to quit
3145 conn.send_bytes(msg)
3148 conn.send_bytes(SENTINEL)
3159 a.send_bytes(msg)
[all …]
/third_party/python/Lib/concurrent/futures/
Dprocess.py79 self._writer.send_bytes(b"")
/third_party/python/Doc/library/
Dmultiprocessing.rst1125 .. method:: send_bytes(buffer[, offset[, size]])
1185 >>> b.send_bytes(b'thank you')
1191 >>> a.send_bytes(arr1)
2512 conn.send_bytes(b'hello')
2514 conn.send_bytes(array('i', [42, 1729]))