diff options
author | kiel barry <kiel.j.barry@gmail.com> | 2018-05-03 16:41:22 +0800 |
---|---|---|
committer | Péter Szilágyi <peterke@gmail.com> | 2018-05-03 16:41:22 +0800 |
commit | 2ad511ce0912194e9f30010f01fc338c585f8634 (patch) | |
tree | a3f20b6850a40c6b8b1229f8c5ac239153475dc0 /rpc | |
parent | 541f299fbbf3c4f4f0ee49c5ecb832f08cc22656 (diff) | |
download | dexon-2ad511ce0912194e9f30010f01fc338c585f8634.tar.gz dexon-2ad511ce0912194e9f30010f01fc338c585f8634.tar.zst dexon-2ad511ce0912194e9f30010f01fc338c585f8634.zip |
rpc: golint error with context as last parameter (#16657)
* rpc/*: golint error with context as last parameter
* Update json.go
Diffstat (limited to 'rpc')
-rw-r--r-- | rpc/http.go | 2 | ||||
-rw-r--r-- | rpc/inproc.go | 2 | ||||
-rw-r--r-- | rpc/server.go | 8 |
3 files changed, 6 insertions, 6 deletions
diff --git a/rpc/http.go b/rpc/http.go index 0c2e060fb..feaa7348c 100644 --- a/rpc/http.go +++ b/rpc/http.go @@ -191,7 +191,7 @@ func (srv *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) { defer codec.Close() w.Header().Set("content-type", contentType) - srv.ServeSingleRequest(codec, OptionMethodInvocation, ctx) + srv.ServeSingleRequest(ctx, codec, OptionMethodInvocation) } // validateRequest returns a non-zero response code and error message if the diff --git a/rpc/inproc.go b/rpc/inproc.go index 595a7ca65..cbe65d10e 100644 --- a/rpc/inproc.go +++ b/rpc/inproc.go @@ -21,7 +21,7 @@ import ( "net" ) -// NewInProcClient attaches an in-process connection to the given RPC server. +// DialInProc attaches an in-process connection to the given RPC server. func DialInProc(handler *Server) *Client { initctx := context.Background() c, _ := newClient(initctx, func(context.Context) (net.Conn, error) { diff --git a/rpc/server.go b/rpc/server.go index 0f29035ed..7f304d8d9 100644 --- a/rpc/server.go +++ b/rpc/server.go @@ -125,7 +125,7 @@ func (s *Server) RegisterName(name string, rcvr interface{}) error { // If singleShot is true it will process a single request, otherwise it will handle // requests until the codec returns an error when reading a request (in most cases // an EOF). It executes requests in parallel when singleShot is false. -func (s *Server) serveRequest(codec ServerCodec, singleShot bool, options CodecOption, ctx context.Context) error { +func (s *Server) serveRequest(ctx context.Context, codec ServerCodec, singleShot bool, options CodecOption) error { var pend sync.WaitGroup defer func() { @@ -216,14 +216,14 @@ func (s *Server) serveRequest(codec ServerCodec, singleShot bool, options CodecO // stopped. In either case the codec is closed. func (s *Server) ServeCodec(codec ServerCodec, options CodecOption) { defer codec.Close() - s.serveRequest(codec, false, options, context.Background()) + s.serveRequest(context.Background(), codec, false, options) } // ServeSingleRequest reads and processes a single RPC request from the given codec. It will not // close the codec unless a non-recoverable error has occurred. Note, this method will return after // a single request has been processed! -func (s *Server) ServeSingleRequest(codec ServerCodec, options CodecOption, ctx context.Context) { - s.serveRequest(codec, true, options, ctx) +func (s *Server) ServeSingleRequest(ctx context.Context, codec ServerCodec, options CodecOption) { + s.serveRequest(ctx, codec, true, options) } // Stop will stop reading new requests, wait for stopPendingRequestTimeout to allow pending requests to finish, |