Method p2mSenderLoop

server/cluster.go:110–121

()

}

func (n *ClusterNode) p2mSenderLoop() {
	for req := range n.p2mSender {
		if req == nil {
			// Stop
			return
		}

		if err := n.proxyToMaster(req); err != nil {
			logs.Warn.Println("p2mSenderLoop: call failed", n.name, err)
		}
	}
}

// ClusterSess is a basic info on a remote session where the message was created.
type ClusterSess struct {