(msess *Session)
| 456 | } |
| 457 | |
| 458 | func (n *ClusterNode) stopMultiplexingSession(msess *Session) { |
| 459 | if msess == nil { |
| 460 | return |
| 461 | } |
| 462 | msess.stopSession(nil) |
| 463 | n.lock.Lock() |
| 464 | delete(n.msess, msess.sid) |
| 465 | n.lock.Unlock() |
| 466 | } |
| 467 | |
| 468 | // TopicMaster is a gRPC endpoint which receives requests sent by proxy topic to master topic. |
| 469 | func (c *Cluster) TopicMaster(msg *ClusterReq, rejected *bool) error { |
no test coverage detected