| /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...] |
