Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 1,204 for read1 (0.03 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/TemporaryFileInputStream.java

         * This method delegates to {@link FileInputStream#mark(int)}.
         *
         * @param readlimit the maximum limit of bytes that can be read before the mark position becomes invalid
         */
        @Override
        public synchronized void mark(final int readlimit) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  2. src/test/java/jcifs/internal/smb2/io/Smb2WriteResponseTest.java

        @Nested
        @DisplayName("Integration Tests")
        class IntegrationTests {
    
            @Test
            @DisplayName("Should maintain state after multiple reads")
            void testMultipleReads() throws SMBProtocolDecodingException {
                // First read
                byte[] buffer1 = createValidWriteResponse(1024, 512);
                response.readBytesWireFormat(buffer1, 0);
                assertEquals(1024, response.getCount());
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  3. src/test/java/jcifs/smb/SmbRandomAccessFileTest.java

        }
    
        @Test
        @DisplayName("read(byte[],off,0): returns 0 without I/O")
        void read_lenZero_returnsZero() throws Exception {
            SmbRandomAccessFile raf = newInstance("r", false, false, false);
            byte[] buf = new byte[4];
            assertEquals(0, raf.read(buf, 0, 0));
        }
    
        @Test
        @DisplayName("read(): returns -1 when underlying read reports EOF")
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 18.1K bytes
    - Viewed (0)
  4. guava/src/com/google/common/base/Ticker.java

      /** Constructor for use by subclasses. */
      protected Ticker() {}
    
      /** Returns the number of nanoseconds elapsed since this ticker's fixed point of reference. */
      public abstract long read();
    
      /**
       * A ticker that reads the current time using {@link System#nanoTime}.
       *
       * @since 10.0
       */
      public static Ticker systemTicker() {
        return SYSTEM_TICKER;
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/suggest/index/contents/querylog/QueryLogReader.java

    /**
     * The {@code QueryLogReader} interface provides methods to read query logs and close the reader.
     * It extends the {@code Closeable} interface, ensuring that resources can be released when no longer needed.
     */
    public interface QueryLogReader extends Closeable {
        /**
         * Reads a query log.
         * @return The query log.
         */
        QueryLog read();
    
        @Override
        void close();
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Fri Jul 04 14:00:23 UTC 2025
    - 1.1K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

       * [Call.request] is a redirect to a different address.
       *
       * Prior to OkHttp 4.3 this was incorrectly invoked when the client was ready to read headers.
       * This was misleading for tracing because it was too early.
       */
      open fun responseHeadersStart(call: Call) {
      }
    
      /**
       * Invoked immediately after receiving response headers.
       *
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  7. src/main/java/jcifs/netbios/SessionServicePacket.java

            return ((src[srcIndex++] & 0x01) << 16) + ((src[srcIndex++] & 0xFF) << 8) + (src[srcIndex++] & 0xFF);
        }
    
        static int readn(final InputStream in, final byte[] b, final int off, final int len) throws IOException {
            int i = 0, n;
    
            while (i < len) {
                n = in.read(b, off + i, len - i);
                if (n <= 0) {
                    break;
                }
                i += n;
            }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/smb1/SmbNamedPipe.java

    /**
     * This class will allow a Java program to read and write data to Named
     * Pipes and Transact NamedPipes.
     *
     * <p>There are three Win32 function calls provided by the Windows SDK
     * that are important in the context of using jCIFS. They are:
     *
     * <ul>
     * <li> <code>CallNamedPipe</code> A message-type pipe call that opens,
     *      writes to, reads from, and closes the pipe in a single operation.
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb1/trans/SmbComTransaction.java

        /**
         * Reads setup data from wire format
         * @param buffer source buffer
         * @param bufferIndex starting index in source buffer
         * @param len length of data to read
         * @return number of bytes read
         */
        protected abstract int readSetupWireFormat(byte[] buffer, int bufferIndex, int len);
    
        /**
         * Reads parameters from wire format
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 17.3K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/BasePublicSuffixList.kt

          }
        }
      }
    
      abstract val path: Any
    
      /**
       * Reads the public suffix list treating the operation as uninterruptible. We always want to read
       * the list otherwise we'll be left in a bad state. If the thread was interrupted prior to this
       * operation, it will be re-interrupted after the list is read.
       */
      private fun readTheListUninterruptibly() {
        var interrupted = false
        try {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 28 07:33:49 UTC 2025
    - 3.6K bytes
    - Viewed (0)
Back to top