Searched refs:send_bytes (Results 1 - 8 of 8) sorted by relevance
/third_party/libuv/test/ |
H A D | test-poll.c | 309 int send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer); local 310 ASSERT_GT(send_bytes, 0); 313 r = send(context->sock, buffer, send_bytes, 0); 333 int send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer); local 334 ASSERT_GT(send_bytes, 0); 337 r = send(context->sock, buffer, send_bytes, 0); 351 send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer); 352 ASSERT_GT(send_bytes, 0); 355 r = send(context->sock, buffer, send_bytes, 0);
|
/third_party/libwebsockets/lib/tls/mbedtls/wrapper/library/ |
H A D | ssl_lib.c | 493 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() 517 //printf("%s: ssl_pm said %d for %d requested (cum %d)\n", __func__, ret, bytes, len -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() [all...] |
/third_party/python/Lib/multiprocessing/ |
H A D | queues.py | 82 self._send_bytes = self._writer.send_bytes 212 def _feed(buffer, notempty, send_bytes, writelock, reader_close, 246 send_bytes(obj) 250 send_bytes(obj) 374 self._writer.send_bytes(obj) 377 self._writer.send_bytes(obj)
|
H A D | connection.py | 181 def send_bytes(self, buf, offset=0, size=None): member in _ConnectionBase 737 connection.send_bytes(CHALLENGE + message) 741 connection.send_bytes(WELCOME) 743 connection.send_bytes(FAILURE) 755 connection.send_bytes(digest) 769 for attr in ('fileno', 'close', 'poll', 'recv_bytes', 'send_bytes'): 774 self._conn.send_bytes(s)
|
H A D | resource_sharer.py | 33 conn.send_bytes(share)
|
/third_party/python/Lib/multiprocessing/dummy/ |
H A D | connection.py | 56 self.send = self.send_bytes = _out.put
|
/third_party/python/Lib/test/ |
H A D | _test_multiprocessing.py | 3109 conn.send_bytes(msg) 3130 self.assertEqual(conn.send_bytes(msg), None) 3136 self.assertEqual(conn.send_bytes(arr), None) 3143 self.assertEqual(conn.send_bytes(arr), None) 3149 self.assertEqual(conn.send_bytes(longmsg), None) 3177 conn.send_bytes(really_big_msg) 3180 conn.send_bytes(SENTINEL) # tell child to quit 3218 conn.send_bytes(msg) 3221 conn.send_bytes(SENTINEL) 3232 a.send_bytes(ms 4649 def send_bytes(self, data): global() member in OtherTest.test_deliver_challenge_auth_failure._FakeConnection 4666 def send_bytes(self, data): global() member in OtherTest.test_answer_challenge_auth_failure._FakeConnection [all...] |
/third_party/python/Lib/concurrent/futures/ |
H A D | process.py | 79 self._writer.send_bytes(b"")
|
Completed in 11 milliseconds