Commitcda8053

committed

add_lock_to_protect mReqeustToSession

Signed-off-by: Chuang Zhu <111838961+chuangz0@users.noreply.github.com>

1 parent20e6cd3 commitcda8053Copy full SHA for cda8053

File tree

-1

lines changed

-1

lines changed

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -291,8 +291,9 @@ class CacheSender::Impl`
`291`	`291`	`mSelfState.setCommState(std::move(commState));`
`292`	`292`	`}`
`293`	`293`
`294`		`- [[nodiscard]]size_tgetCounterpartsCount(LlmRequest::RequestIdType requestId)const`
	`294`	`+ [[nodiscard]]size_tgetCounterpartsCount(LlmRequest::RequestIdType requestId)`
`295`	`295`	`{`
	`296`	`+ std::unique_lock<std::mutex>lock(mMtxForMap);`
`296`	`297`	`auto it =mRequestToSession.find(requestId);`
`297`	`298`	`TLLM_CHECK(it !=mRequestToSession.end());`
`298`	`299`	`return it->second.getConnections().size();`

Comments

(0)