Update name of ipc message type (triton-inference-server#329)

krishung5 · web-flow · commit 950c47f0f989 · 2023-12-18T16:16:18.000-08:00
diff --git a/src/ipc_message.h b/src/ipc_message.h
@@ -55,7 +55,7 @@ typedef enum PYTHONSTUB_commandtype_enum {
   PYTHONSTUB_AutoCompleteResponse,
   PYTHONSTUB_LogRequest,
   PYTHONSTUB_BLSDecoupledInferPayloadCleanup,
-  PYTHONSTUB_BLSDecoupledResponseFactoryCleanup,
+  PYTHONSTUB_DecoupledResponseFactoryCleanup,
   PYTHONSTUB_MetricFamilyRequestNew,
   PYTHONSTUB_MetricFamilyRequestDelete,
   PYTHONSTUB_MetricRequestNew,
diff --git a/src/pb_stub.cc b/src/pb_stub.cc
@@ -997,7 +997,7 @@ Stub::ServiceStubToParentRequests()
           (utils_msg_payload->command_type ==
            PYTHONSTUB_BLSDecoupledInferPayloadCleanup) ||
           (utils_msg_payload->command_type ==
-           PYTHONSTUB_BLSDecoupledResponseFactoryCleanup)) {
+           PYTHONSTUB_DecoupledResponseFactoryCleanup)) {
         SendCleanupId(utils_msg_payload, utils_msg_payload->command_type);
       } else if (
           utils_msg_payload->command_type == PYTHONSTUB_IsRequestCancelled) {
diff --git a/src/python_be.cc b/src/python_be.cc
@@ -830,8 +830,8 @@ ModelInstanceState::StubToParentMQMonitor()
         break;
       }
       case PYTHONSTUB_BLSDecoupledInferPayloadCleanup:
-      case PYTHONSTUB_BLSDecoupledResponseFactoryCleanup: {
-        ProcessBLSCleanupRequest(message);
+      case PYTHONSTUB_DecoupledResponseFactoryCleanup: {
+        ProcessCleanupRequest(message);
         break;
       }
       case PYTHONSTUB_IsRequestCancelled: {
@@ -921,7 +921,7 @@ ModelInstanceState::ProcessLogRequest(
 }
 
 void
-ModelInstanceState::ProcessBLSCleanupRequest(
+ModelInstanceState::ProcessCleanupRequest(
     const std::unique_ptr<IPCMessage>& message)
 {
   AllocatedSharedMemory<char> cleanup_request_message =
@@ -932,8 +932,7 @@ ModelInstanceState::ProcessBLSCleanupRequest(
   if (message->Command() == PYTHONSTUB_BLSDecoupledInferPayloadCleanup) {
     // Remove the InferPayload object from the map.
     infer_payload_.erase(id);
-  } else if (
-      message->Command() == PYTHONSTUB_BLSDecoupledResponseFactoryCleanup) {
+  } else if (message->Command() == PYTHONSTUB_DecoupledResponseFactoryCleanup) {
     // Delete response factory
     std::unique_ptr<
         TRITONBACKEND_ResponseFactory, backend::ResponseFactoryDeleter>
diff --git a/src/python_be.h b/src/python_be.h
@@ -400,9 +400,8 @@ class ModelInstanceState : public BackendModelInstance {
       std::unique_ptr<InferResponse>* infer_response,
       bi::managed_external_buffer::handle_t* response_handle);
 
-  // Process the bls decoupled cleanup request for InferPayload and
-  // ResponseFactory
-  void ProcessBLSCleanupRequest(const std::unique_ptr<IPCMessage>& message);
+  // Process the decoupled cleanup request for InferPayload and ResponseFactory
+  void ProcessCleanupRequest(const std::unique_ptr<IPCMessage>& message);
 
   // Process request cancellation query
   void ProcessIsRequestCancelled(const std::unique_ptr<IPCMessage>& message);
diff --git a/src/response_sender.cc b/src/response_sender.cc
@@ -50,7 +50,7 @@ ResponseSender::~ResponseSender()
   std::unique_ptr<Stub>& stub = Stub::GetOrCreateInstance();
   stub->EnqueueCleanupId(
       reinterpret_cast<void*>(response_factory_address_),
-      PYTHONSTUB_BLSDecoupledResponseFactoryCleanup);
+      PYTHONSTUB_DecoupledResponseFactoryCleanup);
 }
 
 void

Original file line number	Diff line number	Diff line change
`@@ -50,7 +50,7 @@ ResponseSender::~ResponseSender()`
`50`	`50`	`std::unique_ptr<Stub>& stub = Stub::GetOrCreateInstance();`
`51`	`51`	`stub->EnqueueCleanupId(`
`52`	`52`	`reinterpret_cast<void*>(response_factory_address_),`
`53`		`- PYTHONSTUB_BLSDecoupledResponseFactoryCleanup);`
	`53`	`+ PYTHONSTUB_DecoupledResponseFactoryCleanup);`
`54`	`54`	`}`
`55`	`55`
`56`	`56`	`void`