Home
last modified time | relevance | path

Searched refs:received_bytes (Results 1 – 21 of 21) sorted by relevance

/external/rust/crates/grpcio-sys/grpc/src/core/tsi/alts/handshaker/
Dalts_tsi_handshaker.cc405 alts_tsi_handshaker* handshaker, const unsigned char* received_bytes, in alts_tsi_handshaker_continue_handshaker_next() argument
449 grpc_slice slice = (received_bytes == nullptr || received_bytes_size == 0) in alts_tsi_handshaker_continue_handshaker_next()
452 reinterpret_cast<const char*>(received_bytes), in alts_tsi_handshaker_continue_handshaker_next()
476 std::unique_ptr<unsigned char> received_bytes; member
493 handshaker, next_args->received_bytes.get(), in alts_tsi_handshaker_create_channel()
503 tsi_handshaker* self, const unsigned char* received_bytes, in handshaker_next() argument
524 args->received_bytes = nullptr; in handshaker_next()
527 args->received_bytes = std::unique_ptr<unsigned char>( in handshaker_next()
529 memcpy(args->received_bytes.get(), received_bytes, received_bytes_size); in handshaker_next()
543 handshaker, received_bytes, received_bytes_size, cb, user_data); in handshaker_next()
[all …]
/external/perfetto/src/profiling/perf/
Dproc_descriptors.cc130 size_t received_bytes = in OnDataAvailable() local
133 PERFETTO_DLOG("remote fds: received %zu bytes", received_bytes); in OnDataAvailable()
134 if (!received_bytes) in OnDataAvailable()
/external/grpc-grpc/src/core/ext/transport/cronet/transport/
Dcronet_transport.cc117 int received_bytes; member
556 s->state.rs.received_bytes = 0; in on_response_headers_received()
603 s->state.rs.received_bytes += count; in on_read_completed()
609 s->cbs, s->state.rs.read_buffer + s->state.rs.received_bytes, in on_read_completed()
1174 if (stream_state->rs.received_bytes == GRPC_HEADER_SIZE_IN_BYTES && in execute_stream_op()
1188 stream_state->rs.received_bytes = 0; in execute_stream_op()
1219 stream_state->rs.received_bytes = 0; in execute_stream_op()
1234 stream_state->rs.received_bytes = 0; in execute_stream_op()
1274 stream_state->rs.received_bytes = 0; in execute_stream_op()
/external/grpc-grpc/src/core/tsi/alts/handshaker/
Dalts_tsi_handshaker.cc238 tsi_handshaker* self, const unsigned char* received_bytes, in handshaker_next() argument
260 grpc_slice slice = (received_bytes == nullptr || received_bytes_size == 0) in handshaker_next()
263 reinterpret_cast<const char*>(received_bytes), in handshaker_next()
/external/grpc-grpc/src/core/tsi/
Dfake_transport_security.cc669 tsi_handshaker* self, const unsigned char* received_bytes, in fake_handshaker_next() argument
674 if ((received_bytes_size > 0 && received_bytes == nullptr) || in fake_handshaker_next()
686 result = fake_handshaker_process_bytes_from_peer(self, received_bytes, in fake_handshaker_next()
718 unused_bytes = received_bytes + consumed_bytes_size; in fake_handshaker_next()
Dtransport_security.h70 tsi_result (*next)(tsi_handshaker* self, const unsigned char* received_bytes,
Dtransport_security_interface.h441 tsi_handshaker* self, const unsigned char* received_bytes,
Dtransport_security.cc201 tsi_handshaker* self, const unsigned char* received_bytes, in tsi_handshaker_next() argument
209 return self->vtable->next(self, received_bytes, received_bytes_size, in tsi_handshaker_next()
Dlocal_transport_security.cc160 tsi_handshaker* self, const unsigned char* received_bytes, in handshaker_next() argument
Dssl_transport_security.cc1248 tsi_handshaker* self, const unsigned char* received_bytes, in ssl_handshaker_next() argument
1253 if ((received_bytes_size > 0 && received_bytes == nullptr) || in ssl_handshaker_next()
1263 status = ssl_handshaker_process_bytes_from_peer(impl, received_bytes, in ssl_handshaker_next()
1289 unused_bytes_size == 0 ? nullptr : received_bytes + bytes_consumed; in ssl_handshaker_next()
/external/rust/crates/grpcio-sys/grpc/src/core/tsi/
Dfake_transport_security.cc673 tsi_handshaker* self, const unsigned char* received_bytes, in fake_handshaker_next() argument
678 if ((received_bytes_size > 0 && received_bytes == nullptr) || in fake_handshaker_next()
690 result = fake_handshaker_process_bytes_from_peer(self, received_bytes, in fake_handshaker_next()
722 unused_bytes = received_bytes + consumed_bytes_size; in fake_handshaker_next()
Dtransport_security.h69 tsi_result (*next)(tsi_handshaker* self, const unsigned char* received_bytes,
Dtransport_security_interface.h458 tsi_handshaker* self, const unsigned char* received_bytes,
Dtransport_security.cc216 tsi_handshaker* self, const unsigned char* received_bytes, in tsi_handshaker_next() argument
224 return self->vtable->next(self, received_bytes, received_bytes_size, in tsi_handshaker_next()
Dssl_transport_security.cc1507 tsi_handshaker* self, const unsigned char* received_bytes, in ssl_handshaker_next() argument
1512 if ((received_bytes_size > 0 && received_bytes == nullptr) || in ssl_handshaker_next()
1522 status = ssl_handshaker_process_bytes_from_peer(impl, received_bytes, in ssl_handshaker_next()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/cronet/transport/
Dcronet_transport.cc128 int received_bytes = 0; member
302 s->state.rs.received_bytes = 0; in read_grpc_header()
611 s->state.rs.received_bytes += count; in on_read_completed()
617 s->cbs, s->state.rs.read_buffer + s->state.rs.received_bytes, in on_read_completed()
1221 if (stream_state->rs.received_bytes == GRPC_HEADER_SIZE_IN_BYTES && in execute_stream_op()
1235 stream_state->rs.received_bytes = 0; in execute_stream_op()
1274 stream_state->rs.received_bytes = 0; in execute_stream_op()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dinternal.h576 int64_t received_bytes; member
Dparsing.cc361 s->received_bytes += t->incoming_frame_size; in init_data_frame_parser()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/
Dinternal.h621 int64_t received_bytes = 0; member
Dparsing.cc366 s->received_bytes += t->incoming_frame_size; in init_data_frame_parser()
/external/libabigail/tests/data/test-read-dwarf/
Dtest16-pr18904.so.abi3895 …<var-decl name='received_bytes' type-id='type-id-56' visibility='default' filepath='../../../gcc/l…