(server *Server)
| 93 | } |
| 94 | |
| 95 | func newStateMgr(server *Server) *StateMgr { |
| 96 | return &StateMgr{ |
| 97 | server: server, |
| 98 | syncReadyTimeout: time.Second * 10, |
| 99 | currentState: Init, |
| 100 | StateEventC: make(chan *StateEvent, 16), |
| 101 | peers: make(map[uint32]*PeerState), |
| 102 | } |
| 103 | } |
| 104 | |
| 105 | func (self *StateMgr) getState() ServerState { |
| 106 | return self.currentState |
no outgoing calls