i am able to locate the place where connection is removed. the print on
line 504 is printed once per connection (irrespective of number of
operations in it)
498 func (s *Server) removeConn(c io.Closer) {
499 s.mu.Lock()
500 defer s.mu.Unlock()
501 if s.conns != nil {
502 delete(s.conns, c)
503 c.Close()
504 fmt.Printf("grpc/server.go: Server.removeConn() finished \n")
505 s.cv.Signal()
506 }
507 }
line 503 also invokes "Close()" on the connection, it should invoke the
below method:
144 func (ht *serverHandlerTransport) Close() error {
145 fmt.Printf(
"grpc/transport/handler_server.go:serverHandlerTransport.Close()")
146 ht.closeOnce.Do(ht.closeCloseChanOnce)
147 return nil
148 }
149
150 func (ht *serverHandlerTransport) closeCloseChanOnce() {
151 close(ht.closedCh)
152 }
but i am not able to see this invocation. Am i checking the correct
"Close()" method ?
moreover, what can grpc applications do to read from this channel ?
Thanks,
Vimal
--
You received this message because you are subscribed to the Google Groups
"grpc.io" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at https://groups.google.com/group/grpc-io.
To view this discussion on the web visit
https://groups.google.com/d/msgid/grpc-io/82c3ba5b-f084-45f0-86a1-0e4e9d2dd8e4%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
