- Sort Score
- Result 10 results
- Languages All
Results 481 - 490 of 690 for rlock (0.03 sec)
-
impl/maven-core/lifecycle-executor.txt
- plugin in any default values - check to see if anything is missing
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 9.7K bytes - Viewed (0) -
cni/pkg/cmd/root.go
installer := install.NewInstaller(&cfg.InstallConfig, installDaemonReady) repair.StartRepair(ctx, cfg.RepairConfig) log.Info("initialization complete, watching node CNI dir") // installer.Run() will block indefinitely, and attempt to permanently "keep" // the CNI binary installed. if err = installer.Run(ctx); err != nil { if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Aug 16 15:33:47 UTC 2024 - 12.7K bytes - Viewed (0) -
cmd/object-api-interface.go
CreatedAt time.Time // only for site replication NoLock bool // does not lock the make bucket call if set to 'true' } // DeleteBucketOptions provides options for DeleteBucket calls. type DeleteBucketOptions struct { NoLock bool // does not lock the delete bucket call if set to 'true' NoRecreate bool // do not recreate bucket on delete failures
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 22 21:57:20 UTC 2024 - 17.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /** * Serializes execution of tasks, somewhat like an "asynchronous {@code synchronized} block." Each * {@linkplain #submit enqueued} callable will not be submitted to its associated executor until the * previous callable has returned -- and, if the previous callable was an {@link AsyncCallable}, not
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0) -
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 }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Aug 12 08:38:15 UTC 2024 - 10.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/SuppliersTest.java
if (System.nanoTime() - t0 > timeout) { thrown.set( new TimeoutException( "timed out waiting for other threads to block" + " synchronizing on supplier")); break; } Thread.yield(); } count.getAndIncrement();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 17.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/base/SuppliersTest.java
if (System.nanoTime() - t0 > timeout) { thrown.set( new TimeoutException( "timed out waiting for other threads to block" + " synchronizing on supplier")); break; } Thread.yield(); } count.getAndIncrement();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 17.9K bytes - Viewed (0) -
docs/bucket/replication/README.md
- Multi destination replication ## How to use? Ensure that versioning is enabled on the source and target buckets with `mc version` command. If object locking is required, the buckets should have been created with `mc mb --with-lock`
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jan 24 23:46:33 UTC 2023 - 18.2K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/NtStatus.java
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ package jcifs.smb1.smb1; public interface NtStatus { /* Don't bother to edit this. Everthing within the interface * block is automatically generated from the ntstatus package. */ public static final int NT_STATUS_OK = 0x00000000; public static final int NT_STATUS_UNSUCCESSFUL = 0xC0000001;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 11.1K bytes - Viewed (0) -
cmd/os_unix.go
if err := Mkdir(dirPath, perm); err != nil { if osIsExist(err) { return nil } return err } return nil } // The buffer must be at least a block long. // refer https://github.com/golang/go/issues/24015 const blockSize = 8 << 10 // 8192 // By default at least 128 entries in single getdents call (1MiB buffer) var ( direntPool = sync.Pool{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 9.3K bytes - Viewed (0)