unistack-org/micro
4
0
Fork 3
Code Issues 15 Pull Requests 1 Actions Packages Projects Releases 255 Wiki Activity

superfluous logging

Browse Source
This commit is contained in:
Asim Aslam 2016-12-15 20:45:27 +00:00
parent 71d717a06d
commit d606d00f35
2 changed files with 2 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
server/rpc_stream.go
View File

@ -1,7 +1,6 @@
package server package server
import ( import (
"log"
"sync" "sync"
"golang.org/x/net/context" "golang.org/x/net/context"
@ -35,12 +34,7 @@ func (r *rpcStream) Send(msg interface{}) error {
Seq: r.seq, Seq: r.seq,
} }
err := r.codec.WriteResponse(&resp, msg, false) return r.codec.WriteResponse(&resp, msg, false)
if err != nil {
log.Println("rpc: writing response:", err)
}
return err
} }
func (r *rpcStream) Recv(msg interface{}) error { func (r *rpcStream) Recv(msg interface{}) error {
@ -57,12 +51,7 @@ func (r *rpcStream) Recv(msg interface{}) error {
// we need to stay up to date with sequence numbers // we need to stay up to date with sequence numbers
r.seq = req.Seq r.seq = req.Seq
return r.codec.ReadRequestBody(msg)
if err := r.codec.ReadRequestBody(msg); err != nil {
return err
}
return nil
} }
func (r *rpcStream) Error() error { func (r *rpcStream) Error() error {

3
server/rpcplus_server.go
View File

@ -210,9 +210,6 @@ func (server *server) sendResponse(sending *sync.Mutex, req *request, reply inte
resp.Seq = req.Seq resp.Seq = req.Seq
sending.Lock() sending.Lock()
err = codec.WriteResponse(resp, reply, last) err = codec.WriteResponse(resp, reply, last)
if err != nil {
log.Println("rpc: writing response:", err)
}
sending.Unlock() sending.Unlock()
server.freeResponse(resp) server.freeResponse(resp)
return err return err