mirror of
https://github.com/kata-containers/kata-containers.git
synced 2025-08-02 00:02:01 +00:00
Merge pull request #3441 from liangxianlong/main
runtime: Provide protection for shared data
This commit is contained in:
commit
6387a3d323
@ -2044,10 +2044,20 @@ func (k *kataAgent) sendReq(spanCtx context.Context, request interface{}) (inter
|
||||
}
|
||||
|
||||
msgName := proto.MessageName(request.(proto.Message))
|
||||
|
||||
k.Lock()
|
||||
|
||||
if k.reqHandlers == nil {
|
||||
return nil, errors.New("Client has already disconnected")
|
||||
}
|
||||
|
||||
handler := k.reqHandlers[msgName]
|
||||
if msgName == "" || handler == nil {
|
||||
return nil, errors.New("Invalid request type")
|
||||
}
|
||||
|
||||
k.Unlock()
|
||||
|
||||
message := request.(proto.Message)
|
||||
ctx, cancel := k.getReqContext(spanCtx, msgName)
|
||||
if cancel != nil {
|
||||
|
Loading…
Reference in New Issue
Block a user