- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 273 for 0L (0.06 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketWriter.kt
} } if (isClient) { random.nextBytes(maskKey!!) sinkBuffer.write(maskKey) if (dataSize > 0L) { messageBuffer.readAndWriteUnsafe(maskCursor!!) maskCursor.seek(0L) toggleMask(maskCursor, maskKey) maskCursor.close() } } sinkBuffer.write(messageBuffer, dataSize) sink.flush() }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 6K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
this.throttlePeriodNanos = 0L this.failHandshake = false this.onRequestStart = null this.doNotReadRequestBody = false this.onRequestBody = null this.onResponseStart = null this.onResponseBody = null this.onResponseEnd = null this.shutdownServer = false this.headersDelayNanos = 0L this.bodyDelayNanos = 0L this.trailersDelayNanos = 0L
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 17.8K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/Progress.java
} return bufferedSource; } private Source source(Source source) { return new ForwardingSource(source) { long totalBytesRead = 0L; @Override public long read(Buffer sink, long byteCount) throws IOException { long bytesRead = super.read(sink, byteCount);
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jan 12 03:31:36 UTC 2019 - 3.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/TestLocking.java
*/ public TestLocking() { // Default constructor } int numThreads = 1; int numIter = 1; long delay = 100; String url = null; int numComplete = 0; long ltime = 0L; @Override public void run() { try { final SmbFile f = new SmbFile(url); final SmbFile d = new SmbFile(f.getParent()); final byte[] buf = new byte[1024];
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 4.2K bytes - Viewed (0) -
src/test/java/jcifs/smb1/smb1/SmbComOpenAndXResponseTest.java
@Test void testConstructor() { assertNotNull(response); // Default values from constructor assertEquals(0, response.fid); assertEquals(0, response.fileAttributes); assertEquals(0L, response.lastWriteTime); assertEquals(0, response.dataSize); assertEquals(0, response.grantedAccess); assertEquals(0, response.fileType); assertEquals(0, response.deviceState);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 4.2K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/ContentLengthHelper.java
if (StringUtil.isBlank(mimeType)) { return defaultMaxLength; } final Long maxLength = maxLengthMap.get(mimeType); if (maxLength != null && maxLength >= 0L) { return maxLength; } return defaultMaxLength; } /** * Returns the default maximum content length. * @return The default maximum content length in bytes. */
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 3.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/documents/ApiAdminDocumentsAction.java
} if (!doc.containsKey(indexFieldFavoriteCount)) { doc.put(indexFieldFavoriteCount, 0L); } if (!doc.containsKey(indexFieldClickCount)) { doc.put(indexFieldClickCount, 0L); } if (!doc.containsKey(indexFieldBoost)) { doc.put(indexFieldBoost, 1.0f); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 8.3K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ObjectCountLinkedHashMap.java
return (int) links[entry]; } private void setSuccessor(int entry, int succ) { long succMask = (~0L) >>> 32; links[entry] = (links[entry] & ~succMask) | (succ & succMask); } private void setPredecessor(int entry, int pred) { long predMask = (~0L) << 32; links[entry] = (links[entry] & ~predMask) | ((long) pred << 32); } private void setSucceeds(int pred, int succ) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 5.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
* `this`. */ var isParallel = false /** Number of calls to [TaskRunner.Backend.execute]. Guarded by `this`. */ var executeCallCount = 0 /** Guarded by [taskRunner]. */ var nanoTime = 0L private set /** Backlog of tasks to run. Only one task runs at a time. Guarded by `this`. */ private val serialTaskQueue = ArrayDeque<SerialTask>() /** The task that's currently executing. Guarded by `this`. */
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 11.9K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/UploadProgress.java
delegate.writeTo(bufferedSink); bufferedSink.flush(); } public Sink sink(Sink sink) { return new ForwardingSink(sink) { private long totalBytesWritten = 0L; private boolean completed = false; @Override public void write(Buffer source, long byteCount) throws IOException { super.write(source, byteCount);
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 17:01:12 UTC 2025 - 4.2K bytes - Viewed (1)