- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 414 for took (0.17 sec)
-
cmd/local-locker_test.go
Quorum: 0, }) if !ok || err != nil { t.Fatal("failed:", err, ok) } } } start := time.Now() l.expireOldLocks(time.Hour) t.Logf("Scan Took: %v. Left: %d/%d", time.Since(start).Round(time.Millisecond), len(l.lockUID), len(l.lockMap)) if len(l.lockMap) != locks { t.Fatalf("objects deleted, want %d != got %d", locks, len(l.lockMap)) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 11.8K bytes - Viewed (0) -
src/test/java/jcifs/tests/RandomAccessFileTest.java
assertArrayEquals("Data matches at offset " + p, actual, verify); p += read; } assertEquals("Expecting EOF", -1, is.read(buffer, 0, 1)); log.debug("Read " + length + " took " + ( System.currentTimeMillis() - start )); } /** * @param bufSize * @param length * @param os * @throws IOException */
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 11.4K bytes - Viewed (0) -
src/test/java/jcifs/tests/ReadWriteTest.java
p += read; } if ( expectEof ) { assertEquals("Expecting EOF", -1, is.read(buffer, 0, 1)); } log.debug("Read " + length + " took " + ( System.currentTimeMillis() - start )); } /** * @param bufSize * @param length * @param os * @throws IOException */
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 13.2K bytes - Viewed (0) -
internal/grid/muxclient.go
} // respHandler func (m *muxClient) handleOneWayStream(respHandler chan<- Response, respServer <-chan Response) { if debugPrint { start := time.Now() defer func() { fmt.Println("Mux", m.MuxID, "Request took", time.Since(start).Round(time.Millisecond)) }() } defer func() { // addErrorNonBlockingClose will close the response channel // - maybe async, so we shouldn't do it here. if m.respErr.Load() == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/dsync/drwmutex.go
// so exit out and release any locks that did get acquired done = true } } case <-ctx.Done(): // Capture timedout locks as failed or took too long locksFailed++ if locksFailed > tolerance { // We know that we are not going to get the lock anymore, // so exit out and release any locks that did get acquired done = true } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
docs/bigdata/README.md
examples/jars/spark-examples*.jar 10 ``` The job should produce an output as shown below. Note the value of pi in the output. ``` 17/03/22 23:21:10 INFO DAGScheduler: Job 0 finished: reduce at SparkPi.scala:38, took 1.302805 s Pi is roughly 3.1445191445191445 ``` Job status can also be viewed in a browser by navigating to the YARN ResourceManager Web UI and clicking on job history server information. ### **4.2 WordCount**
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 14.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
// for 5.5 seconds happens about 2% of the time. boolean longWait = TimeUnit.NANOSECONDS.toSeconds(thread.timeSpentBlocked) >= 5; // Count how long it actually took to return; we'll accept any number between the expected delay // and the approximate actual delay, to be robust to variance in thread scheduling. char overWaitNanosFirstDigit = Long.toString(
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 46.8K bytes - Viewed (0) -
CHANGELOG.md
* Upgrade: [Okio 3.9.0][okio_3_9_0]. * Upgrade: [Kotlin 1.9.23][kotlin_1_9_23]. * Upgrade: [UnicodeĀ® IDNA 15.1.0][idna_15_1_0] ## Version 5.0.0-alpha.12 _2023-12-17_ We took too long to cut this release and there's a lot of changes in it. We've been busy. Although this release is labeled _alpha_, the only unstable thing in it is our new APIs. This
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:31:39 GMT 2024 - 21.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
// for 5.5 seconds happens about 2% of the time. boolean longWait = TimeUnit.NANOSECONDS.toSeconds(thread.timeSpentBlocked) >= 5; // Count how long it actually took to return; we'll accept any number between the expected delay // and the approximate actual delay, to be robust to variance in thread scheduling. char overWaitNanosFirstDigit = Long.toString(
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 46.8K bytes - Viewed (0) -
src/main/java/jcifs/smb/Kerb5Authenticator.java
} try { NegTokenInit tok = new NegTokenInit(initialToken); if ( log.isDebugEnabled() ) { log.debug("Have initial token " + tok); } if ( tok.getMechanisms() != null ) { Set<ASN1ObjectIdentifier> mechs = new HashSet<>(Arrays.asList(tok.getMechanisms())); boolean foundKerberos = false;
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 13K bytes - Viewed (0)