func (m *Manager) EnsureClient(le *types.ListenEndpoint) error {
	c := call{le, make(chan error)}
	m.ensureCh <- &c
	return <-c.retCh
}
// Takes in the listen address, which is the same as that given in
// server/config. Ensures there is a client connected to that address which is
// periodically calling the manager's command
Takes in the listen address, which is the same as that given in
server/config. Ensures there is a client connected to that address which is
periodically calling the manager's command
// Takes in the listen address which is the same as that given in // server / config . Ensures there is a client connected to that address which is // periodically calling the manager ' s command
func (m *Manager) EnsureClient(le *types.ListenEndpoint) error {
	c := call{le, make(chan error)}
	m.ensureCh <- &c
	return <-c.retCh
}
func ( m * Manager ) EnsureClient ( le * types . ListenEndpoint ) error { c := call { le , make ( chan error ) } m . ensureCh <- & c return <- c . retCh }
Takes in the listen address, which is the same as that given in
server/config.
Takes in the listen address which is the same as that given in server / config .