- Sort Score
- Num 10 results
- Language All
Results 301 - 310 of 539 for readInt (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/ringbuffer/README.md
# Blocking vs Non-blocking The default behavior of the ring buffer is non-blocking, meaning that reads and writes will return immediately with an error if the operation cannot be completed. If you want to block when reading or writing, you must enable it: ```go rb := ringbuffer.New(1024).SetBlocking(true) ``` Enabling blocking will cause the ring buffer to behave like a buffered [io.Pipe](https://pkg.go.dev/io#Pipe).
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed May 15 00:11:04 GMT 2024 - 2.1K bytes - Click Count (0) -
src/main/java/jcifs/smb1/smb1/SmbTransport.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 31.8K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb1/com/SmbComSeekResponse.java
*/ @Override protected int readParameterWordsWireFormat(final byte[] buffer, final int bufferIndex) { this.offset = SMBUtil.readInt4(buffer, bufferIndex); return 4; } /** * {@inheritDoc} * * @see jcifs.internal.smb1.ServerMessageBlock#readBytesWireFormat(byte[], int) */ @OverrideCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 2.8K bytes - Click Count (0) -
internal/http/dial_linux.go
// https://blog.cloudflare.com/when-tcp-sockets-refuse-to-die/ // This is a sensitive configuration, it is better to set it to high values, > 60 secs since it can // affect clients reading data with a very slow pace (disappropriate with socket buffer sizes) if opts.UserTimeout > 0 { _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_USER_TIMEOUT, opts.UserTimeout) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Jul 23 10:53:03 GMT 2024 - 5K bytes - Click Count (0) -
guava-tests/test/com/google/common/io/CountingInputStreamTest.java
assertEquals(20, counter.skip(30)); assertEquals(20, counter.getCount()); assertEquals(0, counter.skip(20)); assertEquals(20, counter.getCount()); // Test reading a single byte while we're in the right state assertEquals(-1, counter.read()); assertEquals(20, counter.getCount()); } public void testReadArrayEOF() throws IOException {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 3.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/suggest/converter/ReadingConverterChain.java
import java.util.ArrayList; import java.util.LinkedHashSet; import java.util.List; import java.util.Set; /** * A chain of {@link ReadingConverter} implementations that applies each converter in sequence to generate possible reading variations of a given text. * It maintains a list of ReadingConverter instances and iterates through them, applying each converter to the input text and accumulating the results.Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Wed Dec 31 05:38:07 GMT 2025 - 3.8K bytes - Click Count (1) -
src/main/java/jcifs/internal/smb1/trans/nt/NtTransQuerySecurityDescResponse.java
return 0; } @Override protected int readParametersWireFormat(final byte[] buffer, final int bufferIndex, final int len) { this.length = SMBUtil.readInt4(buffer, bufferIndex); return 4; } @Override protected int readDataWireFormat(final byte[] buffer, int bufferIndex, final int len) { final int start = bufferIndex;Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 3.2K bytes - Click Count (0) -
src/cmd/addr2line/main.go
if flag.NArg() != 1 { usage() } f, err := objfile.Open(flag.Arg(0)) if err != nil { log.Fatal(err) } defer f.Close() tab, err := f.PCLineTable() if err != nil { log.Fatalf("reading %s: %v", flag.Arg(0), err) } stdin := bufio.NewScanner(os.Stdin) stdout := bufio.NewWriter(os.Stdout) for stdin.Scan() { p := stdin.Text() if strings.Contains(p, ":") {
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Fri Jun 21 19:58:04 GMT 2024 - 2.4K bytes - Click Count (0) -
android/guava/src/com/google/common/io/ReaderInputStream.java
* draining it is flipped (undrained bytes between position and limit). */ private ByteBuffer byteBuffer; /** Whether we've finished reading the reader. */ private boolean endOfInput; /** Whether we're copying encoded bytes to the caller's buffer. */ private boolean draining; /** Whether we've successfully flushed the encoder. */
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Apr 14 16:36:11 GMT 2025 - 9.3K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbPipeHandleInternal.java
* @throws CIFSException if an error occurs retrieving the session key */ byte[] getSessionKey() throws CIFSException; /** * Gets the input stream for reading from this pipe. * * @return this pipe's input stream * @throws CIFSException if an error occurs getting the input stream */ @Override SmbPipeInputStream getInput() throws CIFSException;Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 3.7K bytes - Click Count (0)