"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "nsqadmin/nsqadmin.go" between
nsq-1.2.0.tar.gz and nsq-1.2.1.tar.gz

About: nsq is a realtime distributed and and decentralized messaging platform.

nsqadmin.go  (nsq-1.2.0)	:	nsqadmin.go  (nsq-1.2.1)
skipping to change at line 182		skipping to change at line 182
var once sync.Once		var once sync.Once
exitFunc := func(err error) {		exitFunc := func(err error) {
once.Do(func() {		once.Do(func() {
if err != nil {		if err != nil {
n.logf(LOG_FATAL, "%s", err)		n.logf(LOG_FATAL, "%s", err)
}		}
exitCh <- err		exitCh <- err
})		})
}		}
httpServer := NewHTTPServer(&Context{n})		httpServer := NewHTTPServer(n)
n.waitGroup.Wrap(func() {		n.waitGroup.Wrap(func() {
exitFunc(http_api.Serve(n.httpListener, http_api.CompressHandler( httpServer), "HTTP", n.logf))		exitFunc(http_api.Serve(n.httpListener, http_api.CompressHandler( httpServer), "HTTP", n.logf))
})		})
n.waitGroup.Wrap(n.handleAdminActions)		n.waitGroup.Wrap(n.handleAdminActions)
err := <-exitCh		err := <-exitCh
return err		return err
}		}
func (n *NSQAdmin) Exit() {		func (n *NSQAdmin) Exit() {
End of changes. 1 change blocks.
1 lines changed or deleted		1 lines changed or added

---