- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 90 for unlock2 (0.48 sec)
-
cmd/object-api-multipart_test.go
z.serverPools[0].erasureDisksMu.Lock() er.getDisks = func() []StorageAPI { erasureDisks[ridx] = newNaughtyDisk(erasureDisks[ridx], nil, errFaultyDisk) return erasureDisks } z.serverPools[0].erasureDisksMu.Unlock() uploadIDs = append(uploadIDs, res.UploadID) // Create multipart parts. // Need parts to be uploaded before MultipartLists can be called and tested. createPartCases := []struct {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 77.1K bytes - Viewed (0) -
src/cmd/go/internal/modload/buildlist.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 16:04:44 UTC 2024 - 53.8K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
} } func TestSlowStartBatch(t *testing.T) { fakeErr := fmt.Errorf("fake error") callCnt := 0 callLimit := 0 var lock sync.Mutex fn := func() error { lock.Lock() defer lock.Unlock() callCnt++ if callCnt > callLimit { return fakeErr } return nil } tests := []struct { name string count int callLimit int
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
src/crypto/tls/tls_test.go
} // Wait for clientCloseWrite to finish, so we know we // tested the CloseWrite before we defer the // sconn.Close above, which would also cause the // client to unblock like CloseWrite. <-clientDoneChan return nil } clientCloseWrite := func() error { defer close(clientDoneChan) clientConfig := testConfig.Clone()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 60.5K bytes - Viewed (0) -
src/net/http/request.go
// The Server will close the request body. The ServeHTTP // Handler does not need to. // // Body must allow Read to be called concurrently with Close. // In particular, calling Close should unblock a Read waiting // for input. Body io.ReadCloser // GetBody defines an optional func to return a new copy of // Body. It is used for client requests when a redirect requires
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 49.4K bytes - Viewed (0) -
src/runtime/traceback.go
if iscgo && gp.m != nil && gp.m.ncgo > 0 && gp.syscallsp != 0 && gp.m.cgoCallers != nil && gp.m.cgoCallers[0] != 0 { // Lock cgoCallers so that a signal handler won't // change it, copy the array, reset it, unlock it. // We are locked to the thread and are not running // concurrently with a signal handler. // We just have to stop a signal handler from interrupting // in the middle of our copy. gp.m.cgoCallersUse.Store(1)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 55.1K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/execution/plan/DefaultExecutionPlanParallelTest.groovy
assert !finalizedPlan.allExecutionComplete() def nextNode = selection.item if (nextNode instanceof LocalTaskNode && nextNode.task instanceof Async) { nextNode.projectToLock.unlock() } result = nextNode } return result } void assertNoTaskReadyToStart() { coordinator.withStateLock {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 05 22:18:26 UTC 2024 - 93.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
assertThat(stream1.writeBytesMaximum) .isEqualTo(Settings.DEFAULT_INITIAL_WINDOW_SIZE.toLong()) // receiving a window update on the connection will unblock new streams. connection.readerRunnable.windowUpdate(0, 3) assertThat(connection.writeBytesTotal) .isEqualTo(Settings.DEFAULT_INITIAL_WINDOW_SIZE.toLong()) assertThat(connection.writeBytesMaximum)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
src/cmd/go/internal/modget/get.go
// the final LoadPackages call. return true } } mu.Lock() upgrades = append(upgrades, pathSet{path: path, pkgMods: pkgMods, err: err}) mu.Unlock() return false } r.loadPackages(ctx, patterns, findPackage) // Since we built up the candidate lists concurrently, they may be in a
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 18:26:32 UTC 2024 - 66.5K bytes - Viewed (0) -
pkg/scheduler/internal/cache/cache_test.go
} return nil } // getNodeInfo returns cached data for the node name. func (cache *cacheImpl) getNodeInfo(nodeName string) (*v1.Node, error) { cache.mu.RLock() defer cache.mu.RUnlock() n, ok := cache.nodes[nodeName] if !ok { return nil, fmt.Errorf("node %q not found in cache", nodeName) } return n.info.Node(), nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 01:38:03 UTC 2023 - 63.8K bytes - Viewed (0)