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)
732
732
InferRequest* request = py_request.cast <InferRequest*>();
733
733
request->GetResponseSender ()->Close ();
734
734
}
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
+ }
740
743
ResponseBatch* response_batch_shm_ptr = reinterpret_cast <ResponseBatch*>(
741
744
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 ;
743
747
}
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
+
748
749
execute_response = IPCMessage::Create (
749
750
reinterpret_cast <IPCMessageShm*>(response_batch.value ().data_ .get ()),
750
751
response_batch.value ().handle_ );
You can’t perform that action at this time.
0 commit comments