From a631b779e91741fa7351e04b8113b45ea523b212 Mon Sep 17 00:00:00 2001 From: tanmayv25 Date: Tue, 12 Sep 2023 15:32:00 -0700 Subject: [PATCH] Fix logs --- src/grpc/infer_handler.cc | 5 ++--- src/grpc/stream_infer_handler.cc | 6 +++--- 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/src/grpc/infer_handler.cc b/src/grpc/infer_handler.cc index f98b32cb9c..75462ac310 100644 --- a/src/grpc/infer_handler.cc +++ b/src/grpc/infer_handler.cc @@ -943,12 +943,11 @@ ModelInferHandler::Execute(InferHandler::State* state) // If not error then state->step_ == ISSUED and inference request // has initiated... completion callback will transition to // COMPLETE or CANCELLED. Recording the state and the irequest - // to handle gRPC stream cancellation. If error go immediately to - // COMPLETE. + // to handle gRPC stream cancellation. if (err == nullptr) { state->context_->InsertInflightState(state, irequest); } else { - // Handling error... + // If error go immediately to COMPLETE. LOG_VERBOSE(1) << "[request id: " << request_id << "] " << "Infer failed: " << TRITONSERVER_ErrorMessage(err); diff --git a/src/grpc/stream_infer_handler.cc b/src/grpc/stream_infer_handler.cc index b1915ea744..af34362c73 100644 --- a/src/grpc/stream_infer_handler.cc +++ b/src/grpc/stream_infer_handler.cc @@ -310,12 +310,12 @@ ModelStreamInferHandler::Process(InferHandler::State* state, bool rpc_ok) // state->step_ == ISSUED and inference request has // initiated... the completion callback will transition to // WRITEREADY or WRITTEN or CANCELLED. Recording the state and the - // irequest to handle gRPC stream cancellation. If there was an - // error then enqueue the error response and show it to be ready - // for writing. + // irequest to handle gRPC stream cancellation. if (err == nullptr) { state->context_->InsertInflightState(state, irequest); } else { + // If there was an error then enqueue the error response and show + // it to be ready for writing. inference::ModelStreamInferResponse* response; if (state->is_decoupled_) { state->response_queue_->AllocateResponse();