- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 89 for Unlock (0.15 sec)
-
cmd/naughty-disk_test.go
} func (d *naughtyDisk) Close() (err error) { if err = d.calcError(); err != nil { return err } return d.disk.Close() } func (d *naughtyDisk) calcError() (err error) { d.mu.Lock() defer d.mu.Unlock() d.callNR++ if err, ok := d.errors[d.callNR]; ok { return err } if d.defaultErr != nil { return d.defaultErr } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/erasure-decode.go
var bytesWritten int64 var bufs [][]byte for block := startBlock; block <= endBlock; block++ { var blockOffset, blockLength int64 switch { case startBlock == endBlock: blockOffset = offset % e.blockSize blockLength = length case block == startBlock: blockOffset = offset % e.blockSize blockLength = e.blockSize - blockOffset case block == endBlock: blockOffset = 0
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
ci/official/containers/linux_arm64/builder.devtoolset/gcc9-fixups.patch
+ { while (*ep != NULL) if (!strncmp (*ep, name, len) && (*ep)[len] == '=') { @@ -332,6 +333,7 @@ unsetenv (const char *name) } else ++ep; + } UNLOCK; diff --git a/support/Makefile b/support/Makefile index a253698..2f4e2a9 100644 --- a/support/Makefile +++ b/support/Makefile @@ -167,13 +167,6 @@ CFLAGS-support_paths.c = \ -DINSTDIR_PATH=\"$(prefix)\" \
Others - Registered: Tue May 07 12:40:20 GMT 2024 - Last Modified: Mon Sep 18 14:52:45 GMT 2023 - 8.9K bytes - Viewed (0) -
cmd/shared-lock.go
for { select { case <-ctx.Done(): return case <-lkctx.Context().Done(): // The context of the lock is canceled, this can happen // if one lock lost quorum due to cluster instability // in that case, try to lock again. break keepLock case ld.lockContext <- lkctx: // Send the lock context to anyone asking for it } } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 13 09:26:38 GMT 2023 - 2.3K bytes - Viewed (0) -
src/test/java/jcifs/tests/OplockTests.java
tree.send(create); Smb2CreateRequest create2 = new Smb2CreateRequest(sess.getConfig(), "\\foocc"); create2.setOverrideTimeout(1000); create2.setCreateDisposition(Smb2CreateRequest.FILE_OPEN_IF); create2.setRequestedOplockLevel(Smb2CreateRequest.SMB2_OPLOCK_LEVEL_BATCH);
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Thu Jan 05 13:09:03 GMT 2023 - 6.1K bytes - Viewed (0) -
internal/lock/lock_windows.go
} } return &LockedFile{File: f}, nil } // TryLockedOpenFile - tries a new write lock, functionality // it is similar to LockedOpenFile with with syscall.LOCK_EX // mode but along with syscall.LOCK_NB such that the function // doesn't wait forever but instead returns if it cannot // acquire a write lock. func TryLockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Oct 18 18:08:15 GMT 2023 - 7.9K bytes - Viewed (0) -
cmd/object-api-interface_gen.go
z.CreatedAt, bts, err = msgp.ReadTimeBytes(bts) if err != nil { err = msgp.WrapError(err, "CreatedAt") return } case "NoLock": z.NoLock, bts, err = msgp.ReadBoolBytes(bts) if err != nil { err = msgp.WrapError(err, "NoLock") return } default: bts, err = msgp.Skip(bts) if err != nil { err = msgp.WrapError(err) return } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 8.1K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/BUILD
deps = [ "//tensorflow/c:env", ], ) cc_library( name = "cleanup", hdrs = ["cleanup.h"], ) cc_library( name = "ram_file_block_cache", srcs = ["ram_file_block_cache.cc"], hdrs = ["ram_file_block_cache.h"], deps = [ ":cleanup", "//tensorflow/c:env", "//tensorflow/c:logging", "//tensorflow/c:tf_status",
Plain Text - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Mar 27 18:00:18 GMT 2024 - 3.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
* be removed from the execution schedule. */ fun cancelAll() { lock.assertNotHeld() taskRunner.lock.withLock { if (cancelAllAndDecide()) { taskRunner.kickCoordinator(this) } } } fun shutdown() { lock.assertNotHeld() taskRunner.lock.withLock { shutdown = true if (cancelAllAndDecide()) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0) -
internal/dsync/lock-args_gen.go
Klaus Post <******@****.***> 1700528975 -0800
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 9.5K bytes - Viewed (0)