File tree Expand file tree Collapse file tree 1 file changed +11
-10
lines changed Expand file tree Collapse file tree 1 file changed +11
-10
lines changed Original file line number Diff line number Diff line change @@ -732,19 +732,20 @@ Stub::ProcessRequests(RequestBatch* request_batch_shm_ptr)
732732 InferRequest* request = py_request.cast <InferRequest*>();
733733 request->GetResponseSender ()->Close ();
734734 }
735- }
736-
737- if (!response_batch) {
738- response_batch = shm_pool_->Construct <char >(
739- sizeof (ResponseBatch) + sizeof (IPCMessageShm));
735+ } else {
736+ if (!response_batch) {
737+ response_batch = shm_pool_->Construct <char >(
738+ sizeof (ResponseBatch) + sizeof (IPCMessageShm));
739+ ResponseBatch* response_batch_shm_ptr = reinterpret_cast <ResponseBatch*>(
740+ response_batch.value ().data_ .get () + sizeof (IPCMessageShm));
741+ response_batch_shm_ptr->batch_size = 0 ;
742+ }
740743 ResponseBatch* response_batch_shm_ptr = reinterpret_cast <ResponseBatch*>(
741744 response_batch.value ().data_ .get () + sizeof (IPCMessageShm));
742- response_batch_shm_ptr->batch_size = 0 ;
745+ response_batch_shm_ptr->has_error = false ;
746+ response_batch_shm_ptr->is_error_set = false ;
743747 }
744- ResponseBatch* response_batch_shm_ptr = reinterpret_cast <ResponseBatch*>(
745- response_batch.value ().data_ .get () + sizeof (IPCMessageShm));
746- response_batch_shm_ptr->has_error = false ;
747- response_batch_shm_ptr->is_error_set = false ;
748+
748749 execute_response = IPCMessage::Create (
749750 reinterpret_cast <IPCMessageShm*>(response_batch.value ().data_ .get ()),
750751 response_batch.value ().handle_ );
You can’t perform that action at this time.
0 commit comments