Method serveConn

client/blockcache/bcache/service.go:185–204

(conn net.Conn, stopC chan struct{})

}

func (s *bcacheStore) serveConn(conn net.Conn, stopC chan struct{}) {
	defer conn.Close()
	for {
		select {
		case <-stopC:
			return
		default:
		}
		p := &BlockCachePacket{}
		if err := p.ReadFromConn(conn, proto.NoReadDeadlineTime); err != nil {
			if err != io.EOF {
				log.LogDebugf("serve BcacheServer: %v", err.Error())
			}
			return
		}
		if err := s.handlePacket(conn, p); err != nil {
			log.LogDebugf("serve handlePacket fail: %v", err)
		}
	}
}

func (s *bcacheStore) handlePacket(conn net.Conn, p *BlockCachePacket) (err error) {
	switch p.Opcode {