diff options
author | Wolfy-J <[email protected]> | 2018-05-29 20:31:27 +0300 |
---|---|---|
committer | Wolfy-J <[email protected]> | 2018-05-29 20:31:27 +0300 |
commit | 130da89a94f044fafed584ad5430b59991f317c7 (patch) | |
tree | b6fac7a256b6089eb04ff6bacfbd138ada9382bc /server.go | |
parent | e45daa3bbfd5e95889d00ba3cf9ff6c95101bcb2 (diff) |
updates for the server support
Diffstat (limited to 'server.go')
-rw-r--r-- | server.go | 6 |
1 files changed, 3 insertions, 3 deletions
@@ -43,7 +43,7 @@ func NewRouter(cmd func() *exec.Cmd, factory Factory) *Server { } } -// Configure configures underlying pool and destroys it's previous version if any +// Configure configures underlying pool and destroys it's previous version if any. func (r *Server) Configure(cfg Config) error { r.mu.Lock() previous := r.pool @@ -58,8 +58,8 @@ func (r *Server) Configure(cfg Config) error { r.mu.Lock() - r.pool.Observe(r.poolObserver) r.cfg, r.pool = cfg, pool + r.pool.Observe(r.poolObserver) r.mu.Unlock() @@ -135,7 +135,7 @@ func (r *Server) throw(event int, ctx interface{}) { } } -// Observe pool events +// Observe pool events. func (r *Server) poolObserver(event int, ctx interface{}) { // bypassing to user specified observer r.throw(event, ctx) |