Fix nullpointer in Metadata
This commit is contained in:
parent
d125ab3431
commit
fe0d11add6
|
@ -293,18 +293,20 @@ func (serve *Serve) worker() {
|
|||
//panic(err)
|
||||
continue
|
||||
}
|
||||
if f, ok := serve.callbackFuncs[payload.Metadata.CallID]; ok {
|
||||
serve.callbackFuncsMutex.Lock()
|
||||
delete(serve.callbackFuncs, payload.Metadata.CallID)
|
||||
serve.callbackFuncsMutex.Unlock()
|
||||
if payload.ErrNo != 0 {
|
||||
err = fmt.Errorf(payload.Error)
|
||||
if payload.Metadata != nil {
|
||||
if f, ok := serve.callbackFuncs[payload.Metadata.CallID]; ok {
|
||||
serve.callbackFuncsMutex.Lock()
|
||||
delete(serve.callbackFuncs, payload.Metadata.CallID)
|
||||
serve.callbackFuncsMutex.Unlock()
|
||||
if payload.ErrNo != 0 {
|
||||
err = fmt.Errorf(payload.Error)
|
||||
}
|
||||
if f != nil {
|
||||
//go f.F(err, payload.Header, payload.Payload)
|
||||
f.F(err, payload.Header, payload.Payload)
|
||||
}
|
||||
//f(err, payload.Header, payload.Payload)
|
||||
}
|
||||
if f != nil {
|
||||
//go f.F(err, payload.Header, payload.Payload)
|
||||
f.F(err, payload.Header, payload.Payload)
|
||||
}
|
||||
//f(err, payload.Header, payload.Payload)
|
||||
}
|
||||
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue
Block a user