ymnuk/yt-function-sdk-go
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 23 Wiki Activity

Fix mutex

Browse Source
This commit is contained in:
Александр Федорюк 2022-10-28 14:59:43 +03:00
parent a43583865d
commit 901b373e3c
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
ytfunction.go
View File

@ -249,9 +249,9 @@ func (serve *Serve) worker() {
panic(err)
}
if f, ok := serve.callbackFuncs[payload.Metadata.CallID]; ok {
//serve.callbackFuncsMutex.Lock()
serve.callbackFuncsMutex.Lock()
delete(serve.callbackFuncs, payload.Metadata.CallID)
//serve.callbackFuncsMutex.Unlock()
serve.callbackFuncsMutex.Unlock()
if payload.ErrNo != 0 {
err = fmt.Errorf(payload.Error)
}
@ -378,9 +378,9 @@ func (serve *Serve) CallAsync(name string, header *network.Header, payload []byt
if err != nil {
panic(err)
}
//serve.callbackFuncsMutex.Lock()
serve.callbackFuncsMutex.Lock()
defer serve.callbackFuncsMutex.Unlock()
serve.callbackFuncs[metadata.CallID] = f
//defer serve.callbackFuncsMutex.Unlock()
serve.nc.Publish(name, buf)
}