- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 436 for readlink (0.09 sec)
-
cmd/encryption-v1_test.go
decryptedRangeRef := func(s []int64, skipLen, readLen int64, isFromEnd bool) (o, l, skip int64, sn uint32, ps int) { oSize := lsum(s) if isFromEnd { skipLen = oSize - readLen } if skipLen < 0 || readLen < 0 || oSize < 0 || skipLen+readLen > oSize { t.Fatalf("Impossible read specified: %d %d %d", skipLen, readLen, oSize) } var cumulativeSum, cumulativeEncSum int64
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Sep 24 04:17:08 UTC 2022 - 19.9K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn.go
type DeadlineConn struct { net.Conn readDeadline time.Duration // sets the read deadline on a connection. readSetAt time.Time writeDeadline time.Duration // sets the write deadline on a connection. writeSetAt time.Time } // Sets read deadline func (c *DeadlineConn) setReadDeadline() { if c.readDeadline > 0 { now := time.Now() if now.Sub(c.readSetAt) > updateInterval {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 26 17:40:11 UTC 2024 - 2.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
private ReentrantLock lockA; private ReentrantLock lockB; private ReentrantLock lockC; private ReentrantReadWriteLock.ReadLock readLockA; private ReentrantReadWriteLock.ReadLock readLockB; private ReentrantReadWriteLock.ReadLock readLockC; private ReentrantReadWriteLock.WriteLock writeLockA; private ReentrantReadWriteLock.WriteLock writeLockB; private ReentrantReadWriteLock.WriteLock writeLockC;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 16.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
private ReentrantLock lockA; private ReentrantLock lockB; private ReentrantLock lockC; private ReentrantReadWriteLock.ReadLock readLockA; private ReentrantReadWriteLock.ReadLock readLockB; private ReentrantReadWriteLock.ReadLock readLockC; private ReentrantReadWriteLock.WriteLock writeLockA; private ReentrantReadWriteLock.WriteLock writeLockB; private ReentrantReadWriteLock.WriteLock writeLockC;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 16.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java
Object key = new Object(); Lock readLock = striped.get(key).readLock(); WeakReference<Object> garbage = new WeakReference<>(new Object()); GcFinalization.awaitClear(garbage); Lock writeLock = striped.get(key).writeLock(); readLock.lock(); assertFalse(writeLock.tryLock()); readLock.unlock(); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Jun 26 12:58:35 UTC 2024 - 8.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/StripedTest.java
Object key = new Object(); Lock readLock = striped.get(key).readLock(); WeakReference<Object> garbage = new WeakReference<>(new Object()); GcFinalization.awaitClear(garbage); Lock writeLock = striped.get(key).writeLock(); readLock.lock(); assertFalse(writeLock.tryLock()); readLock.unlock(); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Jun 26 12:58:35 UTC 2024 - 8.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/cbean/ca/bs/BsElevateWordCA.java
} public void setReading_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda) { setReading_Terms("reading", opLambda, null); } public void setReading_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda, OperatorCall<BsElevateWordCA> aggsLambda) { setReading_Terms("reading", opLambda, aggsLambda); }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 54.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/esreq/AdminEsreqAction.java
header = ReaderUtil.readLine(reader); if (header == null) { throwValidationError(messages -> messages.addErrorsInvalidHeaderForRequestFile(GLOBAL, "no header"), () -> asListHtml(this::saveToken)); return redirect(getClass()); // no-op } String line; while ((line = ReaderUtil.readLine(reader)) != null) {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 6.2K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/goals/Encrypt.java
super(messageBuilderFactory, secDispatcher); } @Override protected int doExecute(DefaultEncryptInvoker.LocalContext context) throws Exception { String cleartext = context.reader.readLine("Enter the password to encrypt: ", '*'); context.terminal.writer().println(secDispatcher.encrypt(cleartext, null)); return OK; }
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 1.8K bytes - Viewed (0) -
cmd/callhome.go
} } } func performCallhome(ctx context.Context) { deadline := 10 * time.Second // Default deadline is 10secs for callhome objectAPI := newObjectLayerFn() if objectAPI == nil { internalLogIf(ctx, errors.New("Callhome: object layer not ready")) return } healthCtx, healthCancel := context.WithTimeout(ctx, deadline) defer healthCancel() healthInfoCh := make(chan madmin.HealthInfo)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 17 16:53:34 UTC 2024 - 5.3K bytes - Viewed (0)