GaoreGo/gearman-go
7
0
Fork 0
forked from yuxh/gearman-go
Code Issues Pull Requests Releases 1 Wiki Activity

Merge pull request #75 from No-ops/patch-1

Browse Source 
Add sync lock to create job functions
This commit is contained in:
Christoffer Fjellström 2017-03-02 13:40:41 +01:00 committed by GitHub
commit 9735b2e54f
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
client/client.go
View File

@ -221,6 +221,8 @@ func (client *Client) do(funcname string, data []byte,
return "", ErrLostConn return "", ErrLostConn
} }
var result = make(chan handleOrError, 1) var result = make(chan handleOrError, 1)
client.Lock()
defer client.Unlock()
client.lastcall = "c" client.lastcall = "c"
client.innerHandler.put("c", func(resp *Response) { client.innerHandler.put("c", func(resp *Response) {
if resp.DataType == dtError { if resp.DataType == dtError {