Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 273 for 0L (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top