Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 484 for _end (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top