- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 815 for fslock (0.15 sec)
-
src/cmd/vet/testdata/print/print.go
var x float64 var p *int var imap map[int]int var fslice []float64 var c complex64 // Some good format/argtypes fmt.Printf("") fmt.Printf("%b %b %b", 3, i, x) fmt.Printf("%c %c %c %c", 3, i, 'x', r) fmt.Printf("%d %d %d", 3, i, imap) fmt.Printf("%e %e %e %e", 3e9, x, fslice, c) fmt.Printf("%E %E %E %E", 3e9, x, fslice, c) fmt.Printf("%f %f %f %f", 3e9, x, fslice, c) fmt.Printf("%F %F %F %F", 3e9, x, fslice, c)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 09 01:28:01 UTC 2023 - 27.5K bytes - Viewed (0) -
internal/lock/lock_nix.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package lock import ( "os" "syscall" ) // Internal function implements support for both // blocking and non blocking lock type. func lockedOpenFile(path string, flag int, perm os.FileMode, lockType int) (*LockedFile, error) { switch flag { case syscall.O_RDONLY:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Aug 19 01:35:22 UTC 2021 - 2.8K bytes - Viewed (0) -
src/syscall/zerrors_aix_ppc64.go
F_SETLKW = 0xd F_SETLKW64 = 0xd F_SETOWN = 0x9 F_TEST = 0x3 F_TLOCK = 0x2 F_TSTLK = 0xf F_ULOCK = 0x0 F_UNLCK = 0x3 F_WRLCK = 0x2 HUPCL = 0x400 ICANON = 0x2
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 12 16:18:12 UTC 2019 - 47.2K bytes - Viewed (0) -
pkg/util/iptables/iptables_linux.go
return false, nil } return true, nil }); err != nil { return nil, fmt.Errorf("failed to acquire old iptables lock: %v", err) } success = true return l, nil } func grabIptablesFileLock(f *os.File) error { return unix.Flock(int(f.Fd()), unix.LOCK_EX|unix.LOCK_NB)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 2.6K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/ProducerGuard.java
private final Striped<Lock> locks = Striped.lock(Runtime.getRuntime().availableProcessors() * 4); @Override public <V> V guardByKey(T key, Supplier<V> supplier) { Lock lock = locks.get(key); lock.lock(); try { return supplier.get(); } finally { lock.unlock(); } } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 16:02:31 UTC 2024 - 4.7K bytes - Viewed (0) -
src/syscall/zerrors_linux_386.go
F_SETPIPE_SZ = 0x407 F_SETSIG = 0xa F_SHLCK = 0x8 F_TEST = 0x3 F_TLOCK = 0x2 F_ULOCK = 0x0 F_UNLCK = 0x2 F_WRLCK = 0x1 ICMPV6_FILTER = 0x1 IFA_F_DADFAILED = 0x8
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Aug 19 16:12:50 UTC 2022 - 57.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/mux.go
// won't ever see that event, and will always see any event after they are // added. func (m *Broadcaster) blockQueue(f func()) { m.incomingBlock.Lock() defer m.incomingBlock.Unlock() select { case <-m.stopped: return default: } var wg sync.WaitGroup wg.Add(1) m.incoming <- Event{ Type: internalRunFunctionMarker,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 16 15:26:36 UTC 2022 - 9.4K bytes - Viewed (0) -
cmd/admin-handlers.go
if err != nil { errResp(err) return } } nsLock := objectAPI.NewNSLock(minioMetaBucket, "health-check-in-progress") lkctx, err := nsLock.GetLock(ctx, newDynamicTimeout(deadline, deadline)) if err != nil { // returns a locked lock errResp(err) return } defer nsLock.Unlock(lkctx) healthCtx, healthCancel := context.WithTimeout(lkctx.Context(), deadline)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
cmd/bucket-object-lock.go
return ObjectLocked{} } if !ret.RetainUntilDate.Before(t) { return ObjectLocked{} } return nil } // https://docs.aws.amazon.com/AmazonS3/latest/dev/object-lock-overview.html#object-lock-retention-modes // If you try to delete objects protected by governance mode and have s3:BypassGovernanceRetention, the operation will succeed.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 13.2K bytes - Viewed (0) -
cmd/lock-rest-client.go
err = errLockNotInitialized default: err = errors.New(r.Err) } return ok, err } // RLock calls read lock REST API. func (c *lockRESTClient) RLock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCRLock, &args) } // Lock calls lock REST API. func (c *lockRESTClient) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCLock, &args) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Nov 24 17:07:14 UTC 2023 - 3.3K bytes - Viewed (0)