.

go/zodb/storage/zeo/zrpc.go

@@ -80,6 +80,7 @@ type zLink struct {
 // (called after handshake)
 func (zl *zLink) start() {
 	zl.callTab = make(map[int64]chan msg)
+	zl.serveCtx, zl.serveCancel = context.WithCancel(context.Background())
 	zl.serveWg.Add(1)
 	go zl.serveRecv()
 }
@@ -288,12 +289,14 @@ func (zl *zLink) reply(msgid int64, res interface{}) (err error) {
 	return zl.sendPkt(pkb)
 }
 
+/*
 // RegisterMethod registers f to be called when remote	XXX
 // FIXME -> provide methodTable to dial, so that it is available right from start without any race
 func (zl *zLink) RegisterMethod(method string, f func(arg interface{})) {
 	// XXX only "async" (without reply)
 	// XXX
 }
+*/
 
 // ---- raw IO ----