commit - f738d8a811c3a647540ab27a5156fdf05d2f64d2
commit + 55922182ebf8ddce9bcdd111e24a504549f91259
blob - 0fcc697f7bb6326693044b9145f9080a391864f4
blob + 93556e57cc2d976b5d72331d29ca1e6a42748333
--- channel.go
+++ channel.go
if err := ch.codec.Unmarshal(ch.rdbuf[:n], fcall); err != nil {
return err
}
- log.Println("channel: recv", fcall)
return nil
}
return ErrClosed
default:
}
- log.Println("channel: send", fcall)
deadline, ok := ctx.Deadline()
if !ok {
blob - db99d90caebaa4a7090817bb8d7114815121e554
blob + 24d78b3be3d6009581e39ed6283df08d6e6dd118
--- server.go
+++ server.go
log.Println("server.run()")
for {
- log.Println("server:", "wait")
select {
case req := <-requests:
- log.Println("request", req)
if _, ok := tags[req.Tag]; ok {
select {
case responses <- newErrorFcall(req.Tag, ErrDuptag):
}(ctx, req)
}
case resp := <-completed:
- log.Println("completed", resp)
// only responses that flip the tag state traverse this section.
active, ok := tags[resp.Tag]
if !ok {