Searched refs:bytes_received_size (Results 1 – 2 of 2) sorted by relevance
| /third_party/grpc/test/core/tsi/alts/handshaker/ |
| D | alts_concurrent_connectivity_test.cc | 394 int bytes_received_size, int read_error, int s) { in CloseSocketUponReceivingBytesFromPeer() argument
395 if (bytes_received_size < 0 && read_error != EAGAIN && in CloseSocketUponReceivingBytesFromPeer()
401 if (bytes_received_size >= 0) { in CloseSocketUponReceivingBytesFromPeer()
406 bytes_received_size, s); in CloseSocketUponReceivingBytesFromPeer()
412 static ProcessReadResult CloseSocketUponCloseFromPeer(int bytes_received_size, in CloseSocketUponCloseFromPeer() argument
414 if (bytes_received_size < 0 && read_error != EAGAIN && in CloseSocketUponCloseFromPeer()
420 if (bytes_received_size == 0) { in CloseSocketUponCloseFromPeer()
458 int bytes_received_size = recv(p, buf, 100, 0); in RunServerLoop() local
460 self->process_read_cb_(bytes_received_size, errno, p); in RunServerLoop()
|
| /third_party/grpc/src/core/lib/security/transport/ |
| D | security_handshaker.cc | 61 size_t bytes_received_size);
357 const unsigned char* bytes_received, size_t bytes_received_size) { in DoHandshakerNextLocked() argument
363 handshaker_, bytes_received, bytes_received_size, &bytes_to_send, in DoHandshakerNextLocked()
399 size_t bytes_received_size = h->MoveReadBufferIntoHandshakeBuffer(); in OnHandshakeDataReceivedFromPeerFn() local
401 error = h->DoHandshakerNextLocked(h->handshake_buffer_, bytes_received_size); in OnHandshakeDataReceivedFromPeerFn()
473 size_t bytes_received_size = MoveReadBufferIntoHandshakeBuffer(); in DoHandshake() local
475 DoHandshakerNextLocked(handshake_buffer_, bytes_received_size); in DoHandshake()
|