ISM rewrite part 5
This commit is contained in:
parent
a77529f4f7
commit
b005f7f10a
1
main.go
1
main.go
|
@ -194,6 +194,7 @@ func (s *ServiceInitializationInformation) AcceptMessage() InterServiceMessage {
|
||||||
mutex.Lock()
|
mutex.Lock()
|
||||||
for id, msg := range buffer {
|
for id, msg := range buffer {
|
||||||
_, ok := waitingList[id]
|
_, ok := waitingList[id]
|
||||||
|
|
||||||
if !ok {
|
if !ok {
|
||||||
delete(buffer, id)
|
delete(buffer, id)
|
||||||
mutex.Unlock()
|
mutex.Unlock()
|
||||||
|
|
Loading…
Reference in New Issue