Cluster session: either a proxy or a multiplexing session.
()
| 246 | |
| 247 | // Cluster session: either a proxy or a multiplexing session. |
| 248 | func (s *Session) isCluster() bool { |
| 249 | return s.isProxy() || s.isMultiplex() |
| 250 | } |
| 251 | |
| 252 | func (s *Session) scheduleClusterWriteLoop() { |
| 253 | if globals.cluster != nil && globals.cluster.proxyEventQueue != nil { |
no test coverage detected