jiazhai commented on pull request #366:
URL: https://github.com/apache/pulsar-client-go/pull/366#issuecomment-696759873
Try to provide a brief summary for the deadlock.
In pulsar/internal/connection.go we have 2 channels, `closeCh` and
`incomingRequestsCh`, which are init as
```
closeCh: make(chan interface{}),
incomingRequestsCh: make(chan *request, 10), < === buffer limited
```
`incomingRequestsCh` is a buffered channel with length 10.
when connection is closed, method `func (c *connection) Close()` will call
`func (c *connection) TriggerClose()`, which closed `closeCh` by
`close(c.closeCh)`,
this will cause go routine (in connection.go.run()) exit, then no one will
fetch messages in `incomingRequestsCh`. `incomingRequestsCh`, whose buffer
length is 10, will be filled with incoming requests by method `func (c
*connection) SendRequestNoWait(req *pb.BaseCommand)`,
Then the 10th request, it will be blocked,
As show in above dump thread, `internalAck` in `runEventsLoop` is blocked,
then other requests like re-connection will not get handled, and caused `
"consumers" : [ ], <-- NO CONSUMERS HERE`
Backing to `func (c *connection) Close()`, the connection
`handler.ConnectionClosed()` will hang, because channel `pc.eventsCh` is
blocked as ackRequest is waiting.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
