TBR syncbase: Add a channel timeout to the GetDeltas RPC.
This will ensure that if the remote end goes silent, the RPC will
fail.
Change-Id: I408a9a60d7b0c3449cb9e84834328e51f2cac70d
diff --git a/services/syncbase/vsync/initiator.go b/services/syncbase/vsync/initiator.go
index f6a9bc0..9b607a2 100644
--- a/services/syncbase/vsync/initiator.go
+++ b/services/syncbase/vsync/initiator.go
@@ -16,6 +16,7 @@
"v.io/v23/context"
"v.io/v23/naming"
+ "v.io/v23/options"
"v.io/v23/services/syncbase/nosql"
"v.io/v23/vdl"
"v.io/v23/verror"
@@ -463,7 +464,8 @@
vlog.VI(4).Infof("sync: connectToPeer: trying %v", absName)
var err error
- iSt.stream, err = c.GetDeltas(ctx, iSt.req, iSt.config.sync.name)
+ iSt.stream, err = c.GetDeltas(ctx, iSt.req, iSt.config.sync.name,
+ options.ChannelTimeout(connectionTimeOut))
t.Stop()
if err == nil {
