- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 484 for _end (0.02 sec)
-
src/test/java/jcifs/smb/DirFileEntryEnumIterator1Test.java
batches.add(new String[] { "c" }); // second batch batches.add(new String[] {}); // last -> NO_MORE_FILES // send() answer that mutates the provided response when(tree.send(any(Trans2FindFirst2.class), any(Trans2FindFirst2Response.class))).thenAnswer((InvocationOnMock inv) -> { Trans2FindFirst2Response resp = inv.getArgument(1);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 12.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbFileOutputStream.java
} file.send(reqx, rspx); fp += rspx.count; len -= rspx.count; off += rspx.count; } else { req.setParam(file.fid, fp, len - w, b, off, w); fp += rsp.count; len -= rsp.count; off += rsp.count; file.send(req, rsp); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 11K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbRandomAccessFile.java
} int r, n; final SmbComReadAndXResponse response = new SmbComReadAndXResponse(b, off); do { r = len > readSize ? readSize : len; file.send(new SmbComReadAndX(file.fid, fp, r, null), response); n = response.dataLength; if (n <= 0) { return (int) (fp - start > 0L ? fp - start : -1); } fp += n;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 14.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
import okio.Buffer import okio.ForwardingTimeout import okio.Sink import okio.Source import okio.Timeout /** * A socket connection that can be used to send HTTP/1.1 messages. This class strictly enforces the * following lifecycle: * * 1. [Send request headers][writeRequest]. * 2. Open a sink to write the request body. Either [known][newKnownLengthSink] or * [chunked][newChunkedSink].
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/jcifs/smb/SmbFileOutputStream.java
* the smb URL syntax. If the second argument is <code>true</code>, then * bytes will be written to the end of the file rather than the beginning. * * @param file * An <code>SmbFile</code> representing the file to write to * @param append * Append to the end of file * @throws SmbException if an SMB error occurs */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 12.8K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFileInputStream.java
final Smb2ReadResponse resp = th.send(request, RequestParam.NO_RETRY); n = resp.getDataLength(); } catch (final SmbException e) { if (e.getNtStatus() == 0xC0000011) { // NT_STATUS_END_OF_FILE log.debug("Reached end of file", e); n = -1;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 15.6K bytes - Viewed (0) -
cmd/globals.go
// global Trace system to send HTTP request/response // and Storage/OS calls info to registered listeners. globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8) // global Listen system to send S3 API events to registered listeners globalHTTPListen = pubsub.New[event.Event, pubsub.Mask](0) // global console system to send console logs to // registered listeners
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 16.2K bytes - Viewed (1) -
cmd/metacache-stream.go
} } } // readN will return all the requested number of entries in order // or all if n < 0. // Will return io.EOF if end of stream is reached. // If requesting 0 objects nil error will always be returned regardless of at end of stream. // Use peek to determine if at end of stream. func (r *metacacheReader) readN(n int, inclDeleted, inclDirs, inclVersions bool, prefix string) (metaCacheEntriesSorted, error) { r.checkInit()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed May 07 15:37:12 UTC 2025 - 19.5K bytes - Viewed (0) -
cmd/global-heal.go
bucket, version.Name, err)) } } if !send(result) { return } } // All versions resulted in 'ObjectNotFound/VersionNotFound' if versionNotFound == len(fivs.Versions) { return } send(healEntryDone(entry.name)) // Wait and proceed if there are active requests waitForLowHTTPReq() }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 04 13:49:12 UTC 2025 - 16.2K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/exec/CrawlerTest.java
assertEquals(4, executionOrder.size()); assertTrue(executionOrder.contains("web-start")); assertTrue(executionOrder.contains("web-end")); assertTrue(executionOrder.contains("data-start")); assertTrue(executionOrder.contains("data-end")); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 30.5K bytes - Viewed (0)