// Poll all watched objects for updates.  The parameter n indicates how many logstreams to wait on before waking them.
Poll all watched objects for updates.  The parameter n indicates how many logstreams to wait on before waking them.
// Poll all watched objects for updates . The parameter n indicates how many logstreams to wait on before waking them .
func (ts *TestServer) PollWatched(n int) {
	glog.Info("Testserver starting poll")
	glog.Infof("TestServer polling filesystem patterns")
	if err := ts.t.Poll(); err != nil {
		glog.Info(err)
	}
	glog.Infof("TestServer reloading programs")
	if err := ts.r.LoadAllPrograms(); err != nil {
		glog.Info(err)
	}
	glog.Infof("TestServer tailer gcing")
	if err := ts.t.Gc(); err != nil {
		glog.Info(err)
	}
	glog.Info("TestServer waking idle routines")
	ts.awaken(n)
	glog.Info("Testserver finishing poll")
}
func ( ts * TestServer ) PollWatched ( n int ) { glog . Info ( " " ) glog . Infof ( " " ) if err := ts . t . Poll ( ) ; err != nil { glog . Info ( err ) } glog . Infof ( " " ) if err := ts . r . LoadAllPrograms ( ) ; err != nil { glog . Info ( err ) } glog . Infof ( " " ) if err := ts . t . Gc ( ) ; err != nil { glog . Info ( err ) } glog . Info ( " " ) ts . awaken ( n ) glog . Info ( " " ) }
Poll all watched objects for updates.
Poll all watched objects for updates .