- Sort Score
- Result 10 results
- Languages All
Results 411 - 420 of 563 for readInt (0.04 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
* * Exchanges that do not have a request body may skip creating and closing the request body. * Exchanges that do not have a response body can call * [newFixedLengthSource(0)][newFixedLengthSource] and may skip reading and closing that source. */ class Http1ExchangeCodec( /** The client that configures this stream. May be null for HTTPS proxy tunnels. */ private val client: OkHttpClient?, override val carrier: ExchangeCodec.Carrier,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 17.5K bytes - Viewed (7) -
src/main/java/org/codelibs/fess/dict/stopwords/StopwordsFile.java
import org.codelibs.fess.dict.DictionaryFile; import org.codelibs.fess.util.ComponentUtil; import org.dbflute.optional.OptionalEntity; /** * Manages a dictionary file for stopwords. * This class handles reading, parsing, and updating files that contain * a list of stopwords. Each line in the file represents a single stopword. * * The class provides methods for retrieving, adding, updating, and
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 12.6K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/SuggestHelperTest.java
} catch (Exception e) { assertTrue(true); } } public void test_addElevateWord() { try { suggestHelper.addElevateWord("test", "reading", new String[] { "tag1" }, new String[] { "role1" }, 1.0f, true); assertTrue(true); } catch (Exception e) { assertTrue(true); } }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 19 23:49:30 UTC 2025 - 16K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/ndr/NdrBuffer.java
import java.util.HashMap; import jcifs.smb1.util.Encdec; /** * NDR (Network Data Representation) buffer for encoding and decoding DCE/RPC messages. * This class provides methods for reading and writing primitive types and strings * in NDR format for DCE/RPC communication. */ public class NdrBuffer { int referent; HashMap referents; static class Entry { int referent;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 10.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt
@Throws(IOException::class) internal fun BufferedSource.skipAll() { while (!exhausted()) { skip(buffer.size) } } /** * Attempts to exhaust this, returning true if successful. This is useful when reading a complete * source is helpful, such as when doing so completes a cache body or frees a socket connection for * reuse. */ internal fun Source.discard( timeout: Int, timeUnit: TimeUnit, ): Boolean =
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 10.2K bytes - Viewed (1) -
src/main/java/jcifs/SmbResource.java
* @throws CIFSException if an error occurs accessing the resource */ OutputStream openOutputStream() throws CIFSException; /** * Opens an input stream reading the file (read only) * * @param flags * open flags * @param access * desired access flags * @param sharing
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 28K bytes - Viewed (1) -
cmd/streaming-signature-v4.go
// The s3ChunkedReader returns io.EOF when the final 0-length chunk is read. // // NewChunkedReader is not needed by normal applications. The http package // automatically decodes chunking when reading response bodies. func newSignV4ChunkedReader(req *http.Request, trailer bool) (io.ReadCloser, APIErrorCode) { cred, seedSignature, region, seedDate, errCode := calculateSeedSignature(req, trailer) if errCode != ErrNone {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 18.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java
*/ protected static class ProcessDestroyer extends TimerTask { /** The process to monitor and destroy. */ private final Process p; /** The input stream thread reading process output. */ private final InputStreamThread ist; /** Flag indicating if the destroyer has been executed. */ private final AtomicBoolean executed = new AtomicBoolean(false);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Fri Jul 18 14:34:06 UTC 2025 - 14.7K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/trans/TransPeekNamedPipeResponseTest.java
TransPeekNamedPipeResponse testResponse = new TransPeekNamedPipeResponse(testConfig); // Assert assertNotNull(testResponse); } @Test @DisplayName("Test state changes after reading parameters") void testStateAfterReadingParameters() { // Arrange byte[] buffer = new byte[10]; SMBUtil.writeInt2(1500, buffer, 0); SMBUtil.writeInt2(0xFFFF, buffer, 2);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 15.8K bytes - Viewed (0) -
src/test/java/jcifs/internal/fscc/BasicFileInformationTest.java
assertEquals(TEST_LAST_WRITE_TIME, SMBUtil.readTime(buffer, dstIndex + 16)); assertEquals(TEST_CHANGE_TIME, SMBUtil.readTime(buffer, dstIndex + 24)); assertEquals(TEST_ATTRIBUTES, SMBUtil.readInt4(buffer, dstIndex + 32)); } @Test @DisplayName("Test FileBasicInfo size method") void testFileBasicInfoSize() { // Given FileBasicInfo info = new FileBasicInfo();
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 13K bytes - Viewed (0)