Skip to content

Commit

Permalink
Rename functions
Browse files Browse the repository at this point in the history
  • Loading branch information
kthui committed Jun 4, 2024
1 parent 3381b04 commit 4b162f5
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
2 changes: 1 addition & 1 deletion src/pb_stub.cc
Original file line number Diff line number Diff line change
Expand Up @@ -747,7 +747,7 @@ Stub::ProcessRequests(RequestBatch* request_batch_shm_ptr)
// responses after the factories are closed.
for (py::handle py_request : py_request_list) {
InferRequest* request = py_request.cast<InferRequest*>();
request->GetResponseSender()->ForceClose();
request->GetResponseSender()->Close();
}
}
}
Expand Down
6 changes: 3 additions & 3 deletions src/response_sender.cc
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@
namespace triton { namespace backend { namespace python {

void
AssertResponseSenderArgumentsWellFormed(
CheckResponseSenderArguments(
const std::shared_ptr<InferResponse>& response, const uint32_t flags)
{
// Check the correctness of the provided flags.
Expand Down Expand Up @@ -121,7 +121,7 @@ ResponseSender::Send(
// the next available thread to pick up the job during resource contention.
py::gil_scoped_release release;

AssertResponseSenderArgumentsWellFormed(infer_response, flags);
CheckResponseSenderArguments(infer_response, flags);
UpdateStateAndCounters(infer_response, flags);

std::unique_ptr<Stub>& stub = Stub::GetOrCreateInstance();
Expand Down Expand Up @@ -246,7 +246,7 @@ ResponseSender::IsCancelled()
}

void
ResponseSender::ForceClose()
ResponseSender::Close()
{
std::lock_guard<std::mutex> lk(mu_);
closed_ = true;
Expand Down
2 changes: 1 addition & 1 deletion src/response_sender.h
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ class ResponseSender {
bool IsCancelled();

// Can be useful at stopping the model from sending any more responses.
void ForceClose();
void Close();

private:
void UpdateStateAndCounters(
Expand Down

0 comments on commit 4b162f5

Please sign in to comment.