- Sort Score
- Result 10 results
- Languages All
Results 671 - 680 of 823 for Threads (0.15 sec)
-
src/main/java/jcifs/internal/smb1/SMB1SigningDigest.java
update(sequence, 0, sequence.length); index += 8; if (msg.getCommand() == ServerMessageBlock.SMB_COM_READ_ANDX) { /* * SmbComReadAndXResponse reads directly from the stream into separate byte[] b. */ final SmbComReadAndXResponse raxr = (SmbComReadAndXResponse) msg; final int length = msg.getLength() - raxr.getDataLength();
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 11.9K bytes - Viewed (0) -
internal/s3select/csv/reader.go
type queueItem struct { input []byte // raw input sent to the worker dst chan [][]string // result of block decode err error // any error encountered will be set here } // Read - reads single record. // Once Read is called the previous record should no longer be referenced. func (r *Reader) Read(dst sql.Record) (sql.Record, error) { // If we have have any records left, return these before any error.Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 8.8K bytes - Viewed (0) -
internal/event/target/amqp.go
return err } ch, confirms, err := target.channel() if err != nil { return err } defer ch.Close() return target.send(eventData, ch, confirms) } // SendFromStore - reads an event from store and sends it to AMQP091. func (target *AMQPTarget) SendFromStore(key store.Key) error { if err := target.init(); err != nil { return err } ch, confirms, err := target.channel()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Aug 21 04:25:07 UTC 2025 - 10K bytes - Viewed (0) -
internal/mountinfo/mountinfo_linux.go
if len(crossMounts) > 0 { // if paths didn't match then we do have cross-device mount. return fmt.Errorf(msg, path, crossMounts) } return nil } // readProcMounts reads the given mountFilePath (normally /proc/mounts) and produces a hash // of the contents. If the out argument is not nil, this fills it with MountPoint structs. func readProcMounts(mountFilePath string) (mountInfos, error) {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 4.7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartReader.kt
import okio.Buffer import okio.BufferedSource import okio.ByteString.Companion.encodeUtf8 import okio.Options import okio.Source import okio.Timeout import okio.buffer /** * Reads a stream of [RFC 2046][rfc_2046] multipart body parts. Callers read parts one-at-a-time * until [nextPart] returns null. After calling [nextPart] any preceding parts should not be read. *
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed May 28 02:11:14 UTC 2025 - 7.3K bytes - Viewed (0) -
cmd/storage-errors.go
return errFileNotFound } if isSysErrIO(err) { return errFaultyDisk } if isSysErrInvalidArg(err) { storageLogIf(context.Background(), err) // For some odd calls with O_DIRECT reads // filesystems can return EINVAL, handle // these as FileNotFound instead. return errFileNotFound } if isSysErrNoSpace(err) { return errDiskFull } return err
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 6.4K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/suggest/index/SuggestIndexerTest.java
assertTrue(oldWordsCount > 0); // Minimal sleep to ensure timestamp separation (reduced from 2000ms to 100ms total) Thread.sleep(50); ZonedDateTime threshold = ZonedDateTime.now(); Thread.sleep(50); // Index new data after threshold document = new HashMap<>(); document.put(field, "検索エンジン");
Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Mon Nov 24 03:40:05 UTC 2025 - 28.4K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
} logger.info("Disconnected from {}", address); } connected = false; } /** * Gets the thread pool from the underlying client. * * @return The thread pool. */ @Override public ThreadPool threadPool() { return client.threadPool(); } /**Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sun Nov 23 02:01:26 UTC 2025 - 26.2K bytes - Viewed (0) -
guava/src/com/google/common/base/Joiner.java
* useForNull} has no effect on the instance it is invoked on! You must store and use the new joiner * instance returned by the method. This makes joiners thread-safe, and safe to store as {@code * static final} constants. * * {@snippet : * // Bad! Do not do this! * Joiner joiner = Joiner.on(','); * joiner.skipNulls(); // does nothing!Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Apr 14 15:16:19 UTC 2025 - 21K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/IntervalControlHelper.java
} } /** * Applies delay based on the configured interval rules. * This method calculates the appropriate delay for the current time * and applies it by sleeping the current thread. */ public void delayByRules() { final long delay = getDelay(); if (delay > 0) { ThreadUtil.sleep(delay); } } /**Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sun Nov 23 12:34:02 UTC 2025 - 10K bytes - Viewed (0)