- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 224 for sharding (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
CONTRIBUTING.md
disable the sharding so that all the test outputs are in one file. However, it may slow down the tests for not running in parallel and may cause the test to timeout but it could be useful when you need to execute a single test or more in general your filtered/selected tests have a very low execution time and the shardingCreated: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Sat Jan 11 04:47:59 GMT 2025 - 15.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt
// At this point we don't have a hostname match. But we still be able to carry the request if // our connection coalescing requirements are met. See also: // https://hpbn.co/optimizing-application-delivery/#eliminate-domain-sharding // https://daniel.haxx.se/blog/2016/08/18/http2-connection-coalescing/ // 1. This connection must be HTTP/2. if (http2Connection == null) return false // 2. The routes must share an IP address.
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Oct 07 21:55:03 GMT 2025 - 14.6K bytes - Click Count (0) -
src/archive/zip/reader.go
f.Modified = modified.In(timeZone(msdosModified.Sub(modified))) } } // Assume that uncompressed size 2³²-1 could plausibly happen in // an old zip32 file that was sharding inputs into the largest chunks // possible (or is just malicious; search the web for 42.zip). // If needUSize is true still, it means we didn't see a zip64 extension.
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Thu Jan 15 18:35:56 GMT 2026 - 28.5K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbFileOutputStream.java
} SmbFileOutputStream(final SmbFile file, final boolean append, final int openFlags, final int access, final int sharing) throws SmbException { this.file = file; this.append = append; this.openFlags = openFlags; this.sharing = sharing; this.access = access | SmbConstants.FILE_WRITE_DATA; try (SmbTreeHandleImpl th = file.ensureTreeConnected()) {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 12.8K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbRandomAccessFile.java
private final boolean unsharedFile; private SmbFileHandleImpl handle; private final int sharing; /** * Instantiate a random access file from URL * * @param url the SMB URL of the file to access * @param mode the access mode ("r" for read-only, "rw" for read-write) * @param sharing the sharing flags for file access * @param tc the CIFS context to use for the connectionCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 18.8K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerTest.kt
"FINE: Q10000 scheduled after 100 µs: task", "FINE: Q10000 starting : task", "FINE: Q10000 finished run in 0 µs: task", "FINE: Q10000 run again after 50 µs: task", "FINE: Q10000 starting : task", "FINE: Q10000 finished run in 0 µs: task", "FINE: Q10000 run again after 150 µs: task", "FINE: Q10000 starting : task", "FINE: Q10000 finished run in 0 µs: task",
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Feb 03 22:17:59 GMT 2026 - 23K bytes - Click Count (0) -
src/main/java/jcifs/smb1/smb1/SmbFileOutputStream.java
write, and/or delete the file while the jCIFS user has the file open. * * @param url An smb URL representing the file to write to * @param shareAccess File sharing flag: <code>SmbFile.FILE_NOSHARE</code> or any combination of <code>SmbFile.FILE_READ</code>, <code>SmbFile.FILE_WRITE</code>, and <code>SmbFile.FILE_DELETE</code> * @throws SmbException if an SMB error occursCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 11K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
/** * Called when the service transitions from {@linkplain State#NEW NEW} to {@linkplain * State#STARTING STARTING}. This occurs when {@link Service#startAsync} is called the first * time. */ public void starting() {} /** * Called when the service transitions from {@linkplain State#STARTING STARTING} to {@linkplain * State#RUNNING RUNNING}. This occurs when a service has successfully started. */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 10.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java
} } @Override public synchronized void starting() { assertTrue(stateHistory.isEmpty()); assertThat(service.state()).isNotEqualTo(State.NEW); stateHistory.add(State.STARTING); } @Override public synchronized void running() { assertEquals(State.STARTING, Iterables.getOnlyElement(stateHistory)); stateHistory.add(State.RUNNING);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 28.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java
} } @Override public synchronized void starting() { assertTrue(stateHistory.isEmpty()); assertThat(service.state()).isNotEqualTo(State.NEW); stateHistory.add(State.STARTING); } @Override public synchronized void running() { assertEquals(State.STARTING, Iterables.getOnlyElement(stateHistory)); stateHistory.add(State.RUNNING);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 28.7K bytes - Click Count (0)