1 files changed, 28 insertions, 0 deletions
diff --git a/src/hub/src/spreadspace.org/sfive/s5srv.go b/src/hub/src/spreadspace.org/sfive/s5srv.go
index 15806d9..3bfccbe 100644
--- a/src/hub/src/spreadspace.org/sfive/s5srv.go
+++ b/src/hub/src/spreadspace.org/sfive/s5srv.go
@@ -83,6 +83,34 @@ func (self StatsSinkServer) appendActor() {
 	}
 }
 
+func (self StatsSinkServer) getUpdatesAfterInvoke(id int) (values []StatisticsData, err error) {
+	token := getUpdatesAfterToken{id: id, response: make(chan getUpdatesResult, 1)}
+	defer close(token.response)
+	self.getUpdatesAfterChan <- token
+	res := <-token.response
+	values = res.values
+	err = res.err
+	return
+}
+
+func (self StatsSinkServer) getUpdatesInvoke(filter *StatsFilter) (values []StatisticsData, err error) {
+	token := getUpdatesToken{filter: filter, response: make(chan getUpdatesResult, 1)}
+	defer close(token.response)
+	self.getUpdatesChan <- token
+	res := <-token.response
+	values = res.values
+	err = res.err
+	return
+}
+
+func (self StatsSinkServer) getStatsInvoke(filter *StatsFilter) (StatsResult, error) {
+	token := queryStatsToken{filter: filter, response: make(chan queryStatsResult, 1)}
+	defer close(token.response)
+	self.getStatsChan <- token
+	res := <-token.response
+	return res.stats, res.err
+}
+
 func (self StatsSinkServer) Close() {
 	self.quit <- true
 	<-self.done