From 020a24f1c39de6e366512e42500f0c36877b1c29 Mon Sep 17 00:00:00 2001 From: Xiang Li Date: Sat, 23 Jul 2016 16:21:44 -0700 Subject: [PATCH] *: regenerate proto for handling eof error --- etcdserver/etcdserverpb/rpc.pb.gw.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/etcdserver/etcdserverpb/rpc.pb.gw.go b/etcdserver/etcdserverpb/rpc.pb.gw.go index 04722f77f..20a58ff09 100644 --- a/etcdserver/etcdserverpb/rpc.pb.gw.go +++ b/etcdserver/etcdserverpb/rpc.pb.gw.go @@ -103,6 +103,9 @@ func request_Watch_Watch_0(ctx context.Context, marshaler runtime.Marshaler, cli handleSend := func() error { var protoReq WatchRequest err = dec.Decode(&protoReq) + if err == io.EOF { + return err + } if err != nil { grpclog.Printf("Failed to decode request: %v", err) return err @@ -175,6 +178,9 @@ func request_Lease_LeaseKeepAlive_0(ctx context.Context, marshaler runtime.Marsh handleSend := func() error { var protoReq LeaseKeepAliveRequest err = dec.Decode(&protoReq) + if err == io.EOF { + return err + } if err != nil { grpclog.Printf("Failed to decode request: %v", err) return err