Lines Matching refs:hub
53 var hub *rpctype.RPCClient
58 if hub == nil {
60 if hub, err = hc.connect(corpus); err != nil {
66 if err := hc.sync(hub, corpus); err != nil {
68 hub.Close()
69 hub = nil
94 hub, err := rpctype.NewRPCClient(hc.cfg.HubAddr)
100 return hub, nil
103 func (hc *HubConnector) sync(hub *rpctype.RPCClient, corpus [][]byte) error {
134 if err := hub.Call("Hub.Sync", a, r); err != nil {
184 hub: true,