diff options
Diffstat (limited to 'grpc/src/core/ext/transport/inproc/inproc_transport.cc')
-rw-r--r-- | grpc/src/core/ext/transport/inproc/inproc_transport.cc | 59 |
1 files changed, 30 insertions, 29 deletions
diff --git a/grpc/src/core/ext/transport/inproc/inproc_transport.cc b/grpc/src/core/ext/transport/inproc/inproc_transport.cc index 213c142b..0c21db7f 100644 --- a/grpc/src/core/ext/transport/inproc/inproc_transport.cc +++ b/grpc/src/core/ext/transport/inproc/inproc_transport.cc @@ -50,15 +50,15 @@ grpc_slice g_fake_auth_key; grpc_slice g_fake_auth_value; struct inproc_stream; -bool cancel_stream_locked(inproc_stream* s, grpc_error* error); -void maybe_process_ops_locked(inproc_stream* s, grpc_error* error); -void op_state_machine_locked(inproc_stream* s, grpc_error* error); +bool cancel_stream_locked(inproc_stream* s, grpc_error_handle error); +void maybe_process_ops_locked(inproc_stream* s, grpc_error_handle error); +void op_state_machine_locked(inproc_stream* s, grpc_error_handle error); void log_metadata(const grpc_metadata_batch* md_batch, bool is_client, bool is_initial); -grpc_error* fill_in_metadata(inproc_stream* s, - const grpc_metadata_batch* metadata, - uint32_t flags, grpc_metadata_batch* out_md, - uint32_t* outflags, bool* markfilled); +grpc_error_handle fill_in_metadata(inproc_stream* s, + const grpc_metadata_batch* metadata, + uint32_t flags, grpc_metadata_batch* out_md, + uint32_t* outflags, bool* markfilled); struct shared_mu { shared_mu() { @@ -239,7 +239,7 @@ struct inproc_stream { grpc_millis write_buffer_deadline = GRPC_MILLIS_INF_FUTURE; grpc_metadata_batch write_buffer_trailing_md; bool write_buffer_trailing_md_filled = false; - grpc_error* write_buffer_cancel_error = GRPC_ERROR_NONE; + grpc_error_handle write_buffer_cancel_error = GRPC_ERROR_NONE; struct inproc_stream* other_side; bool other_side_closed = false; // won't talk anymore @@ -270,8 +270,8 @@ struct inproc_stream { bool closed = false; - grpc_error* cancel_self_error = GRPC_ERROR_NONE; - grpc_error* cancel_other_error = GRPC_ERROR_NONE; + grpc_error_handle cancel_self_error = GRPC_ERROR_NONE; + grpc_error_handle cancel_other_error = GRPC_ERROR_NONE; grpc_millis deadline = GRPC_MILLIS_INF_FUTURE; @@ -293,10 +293,10 @@ void log_metadata(const grpc_metadata_batch* md_batch, bool is_client, } } -grpc_error* fill_in_metadata(inproc_stream* s, - const grpc_metadata_batch* metadata, - uint32_t flags, grpc_metadata_batch* out_md, - uint32_t* outflags, bool* markfilled) { +grpc_error_handle fill_in_metadata(inproc_stream* s, + const grpc_metadata_batch* metadata, + uint32_t flags, grpc_metadata_batch* out_md, + uint32_t* outflags, bool* markfilled) { if (GRPC_TRACE_FLAG_ENABLED(grpc_inproc_trace)) { log_metadata(metadata, s->t->is_client, outflags != nullptr); } @@ -307,7 +307,7 @@ grpc_error* fill_in_metadata(inproc_stream* s, if (markfilled != nullptr) { *markfilled = true; } - grpc_error* error = GRPC_ERROR_NONE; + grpc_error_handle error = GRPC_ERROR_NONE; for (grpc_linked_mdelem* elem = metadata->list.head; (elem != nullptr) && (error == GRPC_ERROR_NONE); elem = elem->next) { grpc_linked_mdelem* nelem = @@ -374,7 +374,7 @@ void close_other_side_locked(inproc_stream* s, const char* reason) { // this stream_op_batch is only one of the pending operations for this // stream. This is called when one of the pending operations for the stream // is done and about to be NULLed out -void complete_if_batch_end_locked(inproc_stream* s, grpc_error* error, +void complete_if_batch_end_locked(inproc_stream* s, grpc_error_handle error, grpc_transport_stream_op_batch* op, const char* msg) { int is_sm = static_cast<int>(op == s->send_message_op); @@ -394,14 +394,14 @@ void complete_if_batch_end_locked(inproc_stream* s, grpc_error* error, } } -void maybe_process_ops_locked(inproc_stream* s, grpc_error* error) { +void maybe_process_ops_locked(inproc_stream* s, grpc_error_handle error) { if (s && (error != GRPC_ERROR_NONE || s->ops_needed)) { s->ops_needed = false; op_state_machine_locked(s, error); } } -void fail_helper_locked(inproc_stream* s, grpc_error* error) { +void fail_helper_locked(inproc_stream* s, grpc_error_handle error) { INPROC_LOG(GPR_INFO, "op_state_machine %p fail_helper", s); // If we're failing this side, we need to make sure that // we also send or have already sent trailing metadata @@ -431,7 +431,7 @@ void fail_helper_locked(inproc_stream* s, grpc_error* error) { } } if (s->recv_initial_md_op) { - grpc_error* err; + grpc_error_handle err; if (!s->t->is_client) { // If this is a server, provide initial metadata with a path and authority // since it expects that as well as no error yet @@ -550,7 +550,7 @@ void message_transfer_locked(inproc_stream* sender, inproc_stream* receiver) { GPR_ASSERT( sender->send_message_op->payload->send_message.send_message->Next( SIZE_MAX, &unused)); - grpc_error* error = + grpc_error_handle error = sender->send_message_op->payload->send_message.send_message->Pull( &message_slice); if (error != GRPC_ERROR_NONE) { @@ -583,13 +583,13 @@ void message_transfer_locked(inproc_stream* sender, inproc_stream* receiver) { sender->send_message_op = nullptr; } -void op_state_machine_locked(inproc_stream* s, grpc_error* error) { +void op_state_machine_locked(inproc_stream* s, grpc_error_handle error) { // This function gets called when we have contents in the unprocessed reads // Get what we want based on our ops wanted // Schedule our appropriate closures // and then return to ops_needed state if still needed - grpc_error* new_err = GRPC_ERROR_NONE; + grpc_error_handle new_err = GRPC_ERROR_NONE; bool needs_close = false; @@ -887,9 +887,10 @@ done: GRPC_ERROR_UNREF(new_err); } -bool cancel_stream_locked(inproc_stream* s, grpc_error* error) { +bool cancel_stream_locked(inproc_stream* s, grpc_error_handle error) { bool ret = false; // was the cancel accepted - INPROC_LOG(GPR_INFO, "cancel_stream %p with %s", s, grpc_error_string(error)); + INPROC_LOG(GPR_INFO, "cancel_stream %p with %s", s, + grpc_error_std_string(error).c_str()); if (s->cancel_self_error == GRPC_ERROR_NONE) { ret = true; s->cancel_self_error = GRPC_ERROR_REF(error); @@ -943,7 +944,7 @@ bool cancel_stream_locked(inproc_stream* s, grpc_error* error) { return ret; } -void do_nothing(void* /*arg*/, grpc_error* /*error*/) {} +void do_nothing(void* /*arg*/, grpc_error_handle /*error*/) {} void perform_stream_op(grpc_transport* gt, grpc_stream* gs, grpc_transport_stream_op_batch* op) { @@ -962,7 +963,7 @@ void perform_stream_op(grpc_transport* gt, grpc_stream* gs, s->t->is_client, false); } } - grpc_error* error = GRPC_ERROR_NONE; + grpc_error_handle error = GRPC_ERROR_NONE; grpc_closure* on_complete = op->on_complete; // TODO(roth): This is a hack needed because we use data inside of the // closure itself to do the barrier calculation (i.e., to ensure that @@ -1293,7 +1294,7 @@ grpc_channel* grpc_inproc_channel_create(grpc_server* server, client_args); // TODO(ncteisen): design and support channelz GetSocket for inproc. - grpc_error* error = server->core_server->SetupTransport( + grpc_error_handle error = server->core_server->SetupTransport( server_transport, nullptr, server_args, nullptr); grpc_channel* channel = nullptr; if (error == GRPC_ERROR_NONE) { @@ -1303,7 +1304,7 @@ grpc_channel* grpc_inproc_channel_create(grpc_server* server, if (error != GRPC_ERROR_NONE) { GPR_ASSERT(!channel); gpr_log(GPR_ERROR, "Failed to create client channel: %s", - grpc_error_string(error)); + grpc_error_std_string(error).c_str()); intptr_t integer; grpc_status_code status = GRPC_STATUS_INTERNAL; if (grpc_error_get_int(error, GRPC_ERROR_INT_GRPC_STATUS, &integer)) { @@ -1318,7 +1319,7 @@ grpc_channel* grpc_inproc_channel_create(grpc_server* server, } else { GPR_ASSERT(!channel); gpr_log(GPR_ERROR, "Failed to create server channel: %s", - grpc_error_string(error)); + grpc_error_std_string(error).c_str()); intptr_t integer; grpc_status_code status = GRPC_STATUS_INTERNAL; if (grpc_error_get_int(error, GRPC_ERROR_INT_GRPC_STATUS, &integer)) { |