/external/grpc-grpc/src/core/tsi/alts/handshaker/ |
alts_tsi_handshaker.h | 68 * - recv_buffer: buffer holding data received from the handshaker service. 77 grpc_byte_buffer* recv_buffer,
|
alts_tsi_event.h | 41 * recv_buffer, but not on handshaker. 46 grpc_byte_buffer* recv_buffer; member in struct:alts_tsi_event
|
alts_tsi_event.cc | 58 alts_tsi_handshaker_handle_response(event->handshaker, event->recv_buffer, 68 grpc_byte_buffer_destroy(event->recv_buffer);
|
alts_tsi_handshaker.cc | 405 grpc_byte_buffer* recv_buffer, 416 if (handshaker == nullptr || recv_buffer == nullptr) { 439 alts_tsi_utils_deserialize_response(recv_buffer);
|
alts_handshaker_client.cc | 71 op->data.recv_message.recv_message = &event->recv_buffer;
|
/external/grpc-grpc/test/cpp/end2end/ |
filter_end2end_test.cc | 195 ByteBuffer recv_buffer; local 196 stream.Read(&recv_buffer, tag(5)); 198 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); 210 recv_buffer.Clear(); 211 call->Read(&recv_buffer, tag(8)); 213 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_response)); 288 ByteBuffer recv_buffer; local 289 srv_stream.Read(&recv_buffer, tag(4)); 291 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); 300 cli_stream->Read(&recv_buffer, tag(6)) [all...] |
generic_end2end_test.cc | 151 ByteBuffer recv_buffer; local 152 stream.Read(&recv_buffer, tag(5)); 154 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); 166 recv_buffer.Clear(); 167 call->Read(&recv_buffer, tag(8)); 169 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_response)); 291 ByteBuffer recv_buffer; local 292 srv_stream.Read(&recv_buffer, tag(4)); 294 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); 303 cli_stream->Read(&recv_buffer, tag(6)) [all...] |
hybrid_end2end_test.cc | 85 ByteBuffer recv_buffer; local 86 service->RequestEcho(&srv_ctx, &recv_buffer, &response_writer, cq, cq, 90 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); 119 ByteBuffer recv_buffer; local 128 srv_stream.Read(&recv_buffer, tag(i)); 132 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); 164 ByteBuffer recv_buffer; local 165 stream->Read(&recv_buffer, tag(2)); 168 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); 180 ByteBuffer recv_buffer; local [all...] |
/external/grpc-grpc/test/core/tsi/alts/handshaker/ |
alts_tsi_handshaker_test.cc | 327 event->recv_buffer = generate_handshaker_response(CLIENT_START); 351 event->recv_buffer = generate_handshaker_response(SERVER_START); 387 event->recv_buffer = generate_handshaker_response(CLIENT_NEXT); 389 event->recv_buffer = generate_handshaker_response(SERVER_NEXT); 589 grpc_byte_buffer recv_buffer; local 591 alts_tsi_handshaker_handle_response(nullptr, &recv_buffer, GRPC_STATUS_OK, 599 alts_tsi_handshaker_handle_response(alts_handshaker, &recv_buffer, 603 alts_tsi_handshaker_handle_response(alts_handshaker, &recv_buffer, 632 grpc_byte_buffer* recv_buffer = generate_handshaker_response(INVALID); local 633 alts_tsi_handshaker_handle_response(alts_handshaker, recv_buffer, 681 grpc_byte_buffer* recv_buffer = generate_handshaker_response(FAILED); local 708 grpc_byte_buffer* recv_buffer = generate_handshaker_response(CLIENT_START); local [all...] |
alts_handshaker_client_test.cc | 129 ok &= (op->data.recv_message.recv_message == &event->recv_buffer);
|
/external/grpc-grpc/examples/cpp/helloworld/cocoapods/HelloWorldCpp/ |
ViewController.mm | 67 grpc::ByteBuffer recv_buffer; 68 call->Read(&recv_buffer, tag(3)); 87 recv_buffer.Dump(&slices);
|
/external/grpc-grpc/test/cpp/util/ |
cli_call.cc | 94 grpc::ByteBuffer recv_buffer; local 95 call_->Read(&recv_buffer, tag(3)); 101 GPR_ASSERT(recv_buffer.Dump(&slices).ok()); 151 grpc::ByteBuffer recv_buffer; local 153 call_->Read(&recv_buffer, tag(3)); 185 GPR_ASSERT(recv_buffer.Dump(&slices).ok());
|
/external/grpc-grpc/test/cpp/cocoapods/generic/ |
generic.mm | 206 ByteBuffer recv_buffer; 207 stream.Read(&recv_buffer, tag(5)); 209 XCTAssertTrue(byte_buffer_eq_string(&recv_buffer, "hello world")); 211 send_buffer = std::unique_ptr<ByteBuffer>(new ByteBuffer(recv_buffer)); 219 recv_buffer.Clear(); 220 call->Read(&recv_buffer, tag(8)); 222 XCTAssertTrue(byte_buffer_eq_string(&recv_buffer, "hello world"));
|
/device/google/marlin/camera/QCamera2/stack/mm-camera-test/src/ |
mm_qcamera_socket.c | 216 * @recv_buffer: received message from the client 224 static int32_t tuneserver_process_client_message(void *recv_buffer, 232 p->current_cmd = *(uint16_t *)recv_buffer; 239 p->next_recv_len = *(uint32_t *)recv_buffer; 256 memcpy(p->recv_buf, recv_buffer, p->next_recv_len); 265 p->send_len = *(uint32_t *)recv_buffer; 499 * @recv_buffer: received message from the client 507 static int32_t prevserver_process_client_message(void *recv_buffer, 517 p->current_cmd = *(uint16_t *)recv_buffer; 528 p->new_cnk_size = *(uint32_t *)recv_buffer; [all...] |
/external/autotest/server/cros/network/rf_switch/ |
rf_mocks.py | 25 self.recv_buffer = ''
|
/external/grpc-grpc/test/http2_test/ |
http2_base_server.py | 190 recv_buffer = self._recv_buffer[stream_id] 191 grpc_msg_size = struct.unpack('i',recv_buffer[1:5][::-1])[0] 192 if len(recv_buffer) != _GRPC_HEADER_SIZE + grpc_msg_size: 194 req_proto_str = recv_buffer[5:5+grpc_msg_size]
|
/external/ppp/pppd/plugins/radius/ |
sendserver.c | 211 char recv_buffer[BUFFER_LEN]; local 329 length = recvfrom (sockfd, (char *) recv_buffer, 330 (int) sizeof (recv_buffer), 342 recv_auth = (AUTH_HDR *)recv_buffer;
|
/external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
nccl_all_reduce_thunk.cc | 291 void* recv_buffer = participant.destination_data.opaque(); local 292 ncclResult_t result = ncclAllReduce(send_buffer, recv_buffer,
|
/external/webrtc/webrtc/base/ |
virtualsocket_unittest.cc | 503 char send_buffer[kDataSize], recv_buffer[kDataSize]; local 506 memset(recv_buffer, 0, sizeof(recv_buffer)); 533 result = b->Recv(recv_buffer + recv_pos, 500); 548 result = b->Recv(recv_buffer + recv_pos, kDataSize - recv_pos); 562 result = b->Recv(recv_buffer + recv_pos, kDataSize - recv_pos); 581 result = b->Recv(recv_buffer + recv_pos, kDataSize - recv_pos); 596 EXPECT_EQ(0, memcmp(recv_buffer, send_buffer, kDataSize)); [all...] |
socket_unittest.cc | 681 scoped_ptr<char[]> recv_buffer(new char[kDataSize]); 685 recv_buffer[i] = 0; 752 int rcvd = client->Recv(recv_buffer.get() + recv_pos, 785 EXPECT_EQ(0, memcmp(recv_buffer.get(), send_buffer.get(), kDataSize)); [all...] |