Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
hub
/
github.com/redis/go-redis
/ enqueue
Method
enqueue
internal/pool/want_conn.go:82–86 ·
view source on GitHub ↗
(w *wantConn)
Source
from the content-addressed store, hash-verified
80
}
81
82
func
(q *wantConnQueue) enqueue(w *wantConn) {
83
q.mu.Lock()
84
defer
q.mu.Unlock()
85
q.items = append(q.items, w)
86
}
87
88
func
(q *wantConnQueue) dequeue() (*wantConn, bool) {
89
q.mu.Lock()
Callers
15
queuedNewConn
Method · 0.80
TestWantConnQueue_enqueue_dequeue
Function · 0.80
TestWantConnQueue_ConcurrentAccess
Function · 0.80
TestWantConnQueue_ThreadSafety
Function · 0.80
BenchmarkWantConnQueue_Enqueue
Function · 0.80
BenchmarkWantConnQueue_Dequeue
Function · 0.80
BenchmarkWantConnQueue_EnqueueDequeue
Function · 0.80
TestWantConnQueue_dropFrontDone_AllDone
Function · 0.80
TestWantConnQueue_dropFrontDone_NoneDone
Function · 0.80
TestWantConnQueue_dropFrontDone_PartialDone
Function · 0.80
TestWantConnQueue_dropFrontDone_SingleElement
Function · 0.80
TestWantConnQueue_dropFrontDone_MultipleCalls
Function · 0.80
Calls
no outgoing calls
Tested by
15
TestWantConnQueue_enqueue_dequeue
Function · 0.64
TestWantConnQueue_ConcurrentAccess
Function · 0.64
TestWantConnQueue_ThreadSafety
Function · 0.64
BenchmarkWantConnQueue_Enqueue
Function · 0.64
BenchmarkWantConnQueue_Dequeue
Function · 0.64
BenchmarkWantConnQueue_EnqueueDequeue
Function · 0.64
TestWantConnQueue_dropFrontDone_AllDone
Function · 0.64
TestWantConnQueue_dropFrontDone_NoneDone
Function · 0.64
TestWantConnQueue_dropFrontDone_PartialDone
Function · 0.64
TestWantConnQueue_dropFrontDone_SingleElement
Function · 0.64
TestWantConnQueue_dropFrontDone_MultipleCalls
Function · 0.64
TestWantConnQueue_dropFrontDone_ConcurrentWithEnqueue
Function · 0.64