Method ackWorker

client/conn.go:171–207

()

}

func (c *pconn) ackWorker() {
	defer c.wg.Done()

	var (
		oneTime sync.Once
		pc      rpc.PCaller
		err     error
	)

ackWorkerLoop:
	for {
		ack, got := <-c.ackCh
		if !got { // closed and empty
			break ackWorkerLoop
		}
		oneTime.Do(func() {
			pc = c.pCaller.New()
		})
		if err = ack.Sign(c.parent.privKey); err != nil {
			log.WithField("target", pc.Target()).WithError(err).Error("failed to sign ack")
			continue
		}

		var ackRes types.AckResponse
		// send ack back
		if err = pc.Call(route.DBSAck.String(), ack, &ackRes); err != nil {
			log.WithError(err).Debug("send ack failed")
			continue
		}
	}

	if pc != nil {
		pc.Close()
	}

	log.Debug("ack worker quiting")
}

func (c *pconn) close() error {
	c.stopAckWorkers()