Skip to content

Commit 6d9d585

Browse files
committed
Review comment
Signed-off-by: Iman Tabrizian <[email protected]>
1 parent d570d9e commit 6d9d585

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

cpp/tensorrt_llm/batch_manager/dataTransceiver.cpp

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -160,9 +160,8 @@ class DataResponder::Impl
160160
}
161161
}
162162

163-
void sendResponse(std::vector<size_t> const& blockHashes)
163+
void sendResponse(std::vector<size_t> const& blockHashes, std::map<RequestIdType, Response>::iterator it)
164164
{
165-
auto it = getCurrentResponse();
166165
auto reqId = mCurrentRequest.value();
167166
auto count = --mRemainSendCount[reqId];
168167
TLLM_CHECK(count >= 0);
@@ -222,7 +221,7 @@ class DataResponder::Impl
222221
auto it = getCurrentResponse();
223222
if (it != mReadyResponses.end())
224223
{
225-
sendResponse(blockHashes);
224+
sendResponse(blockHashes, it);
226225
}
227226
else
228227
{
@@ -233,7 +232,7 @@ class DataResponder::Impl
233232
mResponderCv.wait(lk, [this]() { return (mAnyReady || mTerminate); });
234233
it = getCurrentResponse();
235234
}
236-
sendResponse(blockHashes);
235+
sendResponse(blockHashes, it);
237236
}
238237
}
239238
}

0 commit comments

Comments
 (0)