- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for cancelList (0.05 sec)
-
cmd/metacache-server-pool.go
var mu sync.Mutex var wg sync.WaitGroup var errs []error allAtEOF := true var inputs []chan metaCacheEntry mu.Lock() // Ask all sets and merge entries. listCtx, cancelList := context.WithCancel(ctx) defer cancelList() for _, pool := range z.serverPools { for _, set := range pool.sets { wg.Add(1) innerResults := make(chan metaCacheEntry, 100) inputs = append(inputs, innerResults)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
import okhttp3.Request import okhttp3.RequestBody import okhttp3.SimpleProvider import okhttp3.internal.http.CancelTest.CancelMode.CANCEL import okhttp3.internal.http.CancelTest.CancelMode.INTERRUPT import okhttp3.internal.http.CancelTest.ConnectionType.H2 import okhttp3.internal.http.CancelTest.ConnectionType.HTTP import okhttp3.internal.http.CancelTest.ConnectionType.HTTPS import okhttp3.testing.PlatformRule import okio.Buffer import okio.BufferedSink
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 9.9K bytes - Viewed (0) -
native-image-tests/src/main/resources/testlist.txt
okhttp3.internal.connection.ConnectionPoolTest okhttp3.internal.connection.ConnectionSpecSelectorTest okhttp3.internal.connection.RouteExceptionTest okhttp3.internal.connection.RouteSelectorTest okhttp3.internal.http.CancelTest okhttp3.internal.http.HttpDateTest okhttp3.internal.http.StatusLineTest okhttp3.internal.http.ThreadInterruptTest okhttp3.internal.http2.FrameLogTest okhttp3.internal.http2.HpackTest
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu May 11 14:48:57 UTC 2023 - 2.8K bytes - Viewed (0)