|
@@ -270,12 +270,10 @@ void alts_handshaker_client_handle_response(alts_handshaker_client* c,
|
|
handle_response_done(client, status, nullptr, 0, nullptr);
|
|
handle_response_done(client, status, nullptr, 0, nullptr);
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
-
|
|
|
|
alts_tsi_handshaker_result_set_unused_bytes(
|
|
alts_tsi_handshaker_result_set_unused_bytes(
|
|
result, &client->recv_bytes,
|
|
result, &client->recv_bytes,
|
|
grpc_gcp_HandshakerResp_bytes_consumed(resp));
|
|
grpc_gcp_HandshakerResp_bytes_consumed(resp));
|
|
}
|
|
}
|
|
-
|
|
|
|
grpc_status_code code = static_cast<grpc_status_code>(
|
|
grpc_status_code code = static_cast<grpc_status_code>(
|
|
grpc_gcp_HandshakerStatus_code(resp_status));
|
|
grpc_gcp_HandshakerStatus_code(resp_status));
|
|
if (code != GRPC_STATUS_OK) {
|
|
if (code != GRPC_STATUS_OK) {
|
|
@@ -551,10 +549,8 @@ static grpc_byte_buffer* get_serialized_start_server(
|
|
GPR_ASSERT(bytes_received != nullptr);
|
|
GPR_ASSERT(bytes_received != nullptr);
|
|
alts_grpc_handshaker_client* client =
|
|
alts_grpc_handshaker_client* client =
|
|
reinterpret_cast<alts_grpc_handshaker_client*>(c);
|
|
reinterpret_cast<alts_grpc_handshaker_client*>(c);
|
|
-
|
|
|
|
upb::Arena arena;
|
|
upb::Arena arena;
|
|
grpc_gcp_HandshakerReq* req = grpc_gcp_HandshakerReq_new(arena.ptr());
|
|
grpc_gcp_HandshakerReq* req = grpc_gcp_HandshakerReq_new(arena.ptr());
|
|
-
|
|
|
|
grpc_gcp_StartServerHandshakeReq* start_server =
|
|
grpc_gcp_StartServerHandshakeReq* start_server =
|
|
grpc_gcp_HandshakerReq_mutable_server_start(req, arena.ptr());
|
|
grpc_gcp_HandshakerReq_mutable_server_start(req, arena.ptr());
|
|
grpc_gcp_StartServerHandshakeReq_add_application_protocols(
|
|
grpc_gcp_StartServerHandshakeReq_add_application_protocols(
|