Search Options

Results per page
Sort
Preferred Languages
Advance

Results 371 - 380 of 532 for readId (0.04 sec)

  1. docs/debugging/inspect/export.go

    				// Read metadata CRC (added in v2, ignore if not found)
    				b = nbuf
    			}
    
    			_, e = msgp.CopyToJSON(buf, bytes.NewReader(v))
    			if e != nil {
    				return nil, e
    			}
    			data = b
    		case 3:
    			v, b, e := msgp.ReadBytesZC(b)
    			if e != nil {
    				return nil, e
    			}
    			if _, nbuf, e := msgp.ReadUint32Bytes(b); e == nil {
    				// Read metadata CRC (added in v2, ignore if not found)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jan 17 19:38:44 UTC 2025
    - 9.1K bytes
    - Viewed (1)
  2. src/test/java/jcifs/internal/smb2/lock/Smb2LockResponseTest.java

                SMBUtil.writeInt2(4, buffer, 0);
    
                // When
                int read1 = response1.readBytesWireFormat(buffer, 0);
                int read2 = response2.readBytesWireFormat(buffer, 0);
    
                // Then
                assertEquals(4, read1);
                assertEquals(4, read2);
            }
        }
    
        @Nested
        @DisplayName("Edge case tests")
        class EdgeCaseTests {
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 17.1K bytes
    - Viewed (0)
  3. cmd/http-tracer.go

    		// http stats requests and audit if enabled.
    		respRecorder := xhttp.NewResponseRecorder(w)
    
    		// Setup a http request body recorder
    		reqRecorder := &xhttp.RequestRecorder{Reader: r.Body}
    		r.Body = reqRecorder
    
    		// Create tracing data structure and associate it to the request context
    		tc := mcontext.TraceCtxt{
    			AmzReqID:         w.Header().Get(xhttp.AmzRequestID),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 6K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/HttpHeaders.kt

      var peek: String? = null
    
      while (true) {
        // Read a scheme name for this challenge if we don't have one already.
        if (peek == null) {
          skipCommasAndWhitespace()
          peek = readToken()
          if (peek == null) return
        }
    
        val schemeName = peek
    
        // Read a token68, a sequence of parameters, or nothing.
        val commaPrefixed = skipCommasAndWhitespace()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  5. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerContextTest.java

                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt();
                    }
                }
            });
    
            Thread reader = new Thread(new Runnable() {
                @Override
                public void run() {
                    try {
                        statusSetLatch.countDown();
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 25.6K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/dict/synonym/SynonymFile.java

         * @param in      The input stream to read the dictionary from.
         * @throws DictionaryException if the input stream cannot be parsed.
         */
        protected void reload(final SynonymUpdater updater, final InputStream in) {
            final List<SynonymItem> itemList = new ArrayList<>();
            try (BufferedReader reader = new BufferedReader(new InputStreamReader(in, Constants.UTF_8))) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  7. guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java

        assertEquals(-1, ArbitraryInstances.get(InputStream.class).read());
        assertEquals(-1, ArbitraryInstances.get(ByteArrayInputStream.class).read());
        assertEquals(-1, ArbitraryInstances.get(Readable.class).read(CharBuffer.allocate(1)));
        assertEquals(-1, ArbitraryInstances.get(Reader.class).read());
        assertEquals(-1, ArbitraryInstances.get(StringReader.class).read());
        assertEquals(0, ArbitraryInstances.get(Buffer.class).capacity());
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 22.3K bytes
    - Viewed (0)
  8. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.io.ByteArrayInputStream;
    import java.io.ByteArrayOutputStream;
    import java.io.File;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.io.PrintStream;
    import java.io.PrintWriter;
    import java.io.Reader;
    import java.io.Serializable;
    import java.io.StringReader;
    import java.io.StringWriter;
    import java.io.Writer;
    import java.lang.reflect.AnnotatedElement;
    import java.lang.reflect.Array;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 21.4K bytes
    - Viewed (0)
  9. pom.xml

    								<user>${packaging.fess.user}</user>
    								<group>${packaging.fess.group}</group>
    							</mapper>
    						</data>
    						<!-- Add readme files -->
    						<data>
    							<type>files</type>
    							<paths>
    								<path>${project.basedir}/LICENSE</path>
    								<path>${project.basedir}/README.md</path>
    							</paths>
    							<dst>${packaging.fess.home.dir}</dst>
    							<mapper>
    								<type>perm</type>
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Sep 04 05:22:58 UTC 2025
    - 49.6K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/util/InputStreamThread.java

    import java.util.function.Consumer;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    
    /**
     * A thread that reads from an input stream line by line and maintains a buffer of recent lines.
     * This class provides functionality to read input stream data asynchronously,
     * optionally process each line with a callback function, and maintain a circular buffer
     * of recent lines for retrieval.
     */
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 4.6K bytes
    - Viewed (0)
Back to top