Method Serve

pkg/rpc/dfdaemon/client/client_v2.go:77–89

Serve starts the pool.

()

// Serve starts the pool.
func (p *pool) Serve() {
	ticker := time.NewTicker(gcInterval)
	defer ticker.Stop()

	for {
		select {
		case <-ticker.C:
			p.runGC()
		case <-p.done:
			return
		}
	}
}

// Stop stops the pool.
func (p *pool) Stop() {