- Sort Score
- Result 10 results
- Languages All
Results 891 - 900 of 7,014 for _return (0.07 sec)
-
cmd/erasure-utils.go
n, err := dst.Write(block[:write]) if err != nil { return 0, err } totalWritten += int64(n) break } // Copy the block. n, err := dst.Write(block) if err != nil { return 0, err } // Decrement output size. write -= int64(n) // Increment written. totalWritten += int64(n) } // Success. return totalWritten, nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jan 31 02:11:45 UTC 2024 - 3.1K bytes - Viewed (0) -
guava/src/com/google/common/collect/HashBiMap.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 13 14:11:58 UTC 2023 - 24.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
connection.idleAtNs = System.nanoTime() if (connectionPool.connectionBecameIdle(connection)) { return connection.socket() } } return null } private fun <E : IOException?> timeoutExit(cause: E): E { if (timeoutEarlyExit) return cause if (!timeout.exit()) return cause val e = InterruptedIOException("timeout") if (cause != null) e.initCause(cause)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ResponseCommonTest.kt
): Long { check(!closed) return data.read(sink, byteCount) } override fun timeout(): Timeout { return Timeout.NONE } } return source.buffer().asResponseBody(null, -1) } private fun newResponse( responseBody: ResponseBody, code: Int = 200, ): Response { return Response.Builder() .request(
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.6K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/workload.go
if err != nil { return fmt.Errorf("failed to marshal workloads: %v", err) } if outputFormat == "yaml" { if out, err = yaml.JSONToYAML(out); err != nil { return err } } fmt.Fprintln(c.Stdout, string(out)) return nil } func waypointName(wl *ZtunnelWorkload, services []*ZtunnelService) string { if wl.Waypoint == nil { return "None" }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Jul 24 09:07:30 UTC 2024 - 4.2K bytes - Viewed (0) -
guava/src/com/google/common/cache/AbstractCache.java
public CacheStats snapshot() { return new CacheStats( negativeToMaxValue(hitCount.sum()), negativeToMaxValue(missCount.sum()), negativeToMaxValue(loadSuccessCount.sum()), negativeToMaxValue(loadExceptionCount.sum()), negativeToMaxValue(totalLoadTime.sum()), negativeToMaxValue(evictionCount.sum())); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jun 15 18:00:07 UTC 2021 - 9.1K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/TestLogHandler.java
synchronized (lock) { list.clear(); } } /** Returns a snapshot of the logged records. */ /* * TODO(cpovirk): consider higher-level APIs here (say, assertNoRecordsLogged(), * getOnlyRecordLogged(), getAndClearLogRecords()...) * * TODO(cpovirk): consider renaming this method to reflect that it takes a snapshot (and/or return * an ImmutableList) */ public List<LogRecord> getStoredLogRecords() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Jun 21 20:53:25 UTC 2024 - 2.8K bytes - Viewed (0) -
src/main/java/jcifs/SmbWatchHandle.java
* {@link jcifs.Configuration#getNotifyBufferSize()}). * If the server cannot fulfill the request because the changes did not fit the buffer * it will return an empty list of changes. * * @return changes since the last invocation * @throws CIFSException */ List<FileNotifyInformation> watch () throws CIFSException; /** * {@inheritDoc} *
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 2.3K bytes - Viewed (0) -
cmd/namespace-lock.go
}) { timeout.LogFailure() defer cancel() if err := newCtx.Err(); err == context.Canceled { return LockContext{ctx: ctx, cancel: func() {}}, err } return LockContext{ctx: ctx, cancel: func() {}}, OperationTimedOut{} } timeout.LogSuccess(UTCNow().Sub(start)) return LockContext{ctx: newCtx, cancel: cancel}, nil } // Unlock - block until write lock is released.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 9.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/primitives/ByteArrayAsListTest.java
protected abstract List<Byte> create(Byte[] elements); @Override public Byte[] createArray(int length) { return new Byte[length]; } /** Returns the original element list, unchanged. */ @Override public List<Byte> order(List<Byte> insertionOrder) { return insertionOrder; } } public static class SampleBytes extends SampleElements<Byte> { public SampleBytes() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Jun 01 09:32:35 UTC 2023 - 5.5K bytes - Viewed (0)