func (c *PipelineClient) PendingRequests() int {
	c.connClientsLock.Lock()
	n := 0
	for _, cc := range c.connClients {
		n += cc.PendingRequests()
	}
	c.connClientsLock.Unlock()
	return n
}
func (c *PipelineClient) PendingRequests() int {
	c.connClientsLock.Lock()
	n := 0
	for _, cc := range c.connClients {
		n += cc.PendingRequests()
	}
	c.connClientsLock.Unlock()
	return n
}
func ( c * PipelineClient ) PendingRequests ( ) int { c . connClientsLock . Lock ( ) n := 0 for _ , cc := range c . connClients { n += cc . PendingRequests ( ) } c . connClientsLock . Unlock ( ) return n }
// PendingRequests returns the current number of pending requests pipelined
// to the server.
//
// This number may exceed MaxPendingRequests*MaxConns by up to two times, since
// each connection to the server may keep up to MaxPendingRequests requests
// in the queue before sending them to the server.
//
// This function may be used for balancing load among multiple PipelineClient
// instances.
PendingRequests returns the current number of pending requests pipelined to the server . This number may exceed MaxPendingRequests * MaxConns by up to two times since each connection to the server may keep up to MaxPendingRequests requests in the queue before sending them to the server . This function may be used for balancing load among multiple PipelineClient instances .