- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 163 for EOF (0.01 sec)
-
docs/bucket/lifecycle/README.md
- Enable bucket lifecycle configuration using `mc`: ```sh $ mc ilm import play/testbucket <<EOF { "Rules": [ { "Expiration": { "Date": "2020-01-01T00:00:00.000Z" }, "ID": "OldPictures", "Filter": { "Prefix": "old/"Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 9.1K bytes - Viewed (0) -
docs/multi-user/README.md
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 8.2K bytes - Viewed (0) -
src/archive/zip/reader.go
if r.nread > r.f.UncompressedSize64 { return 0, ErrFormat } if err == nil { return } if err == io.EOF { if r.nread != r.f.UncompressedSize64 { return 0, io.ErrUnexpectedEOF } if r.desr != nil { if err1 := readDataDescriptor(r.desr, r.f); err1 != nil { if err1 == io.EOF { err = io.ErrUnexpectedEOF } else { err = err1 } } else if r.hash.Sum32() != r.f.CRC32 {
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Tue Mar 11 22:19:38 UTC 2025 - 28.4K bytes - Viewed (0) -
src/main/java/jcifs/SmbRandomAccess.java
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.6K bytes - Viewed (0) -
src/archive/tar/fuzz_test.go
f.Fuzz(func(t *testing.T, b []byte) { r := NewReader(bytes.NewReader(b)) type file struct { header *Header content []byte } files := []file{} for { hdr, err := r.Next() if err == io.EOF { break } if err != nil { return } buf := bytes.NewBuffer(nil) if _, err := io.Copy(buf, r); err != nil { continue }
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Thu Jan 13 18:06:33 UTC 2022 - 2.2K bytes - Viewed (0) -
src/archive/tar/writer.go
} } // If the last fragment is a hole, then seek to 1-byte before EOF, and // read a single byte to ensure the file is the right size. if readLastByte && err == nil { _, err = mustReadFull(rs, []byte{0}) sw.pos++ } n = sw.pos - pos0 switch { case err == io.EOF: return n, io.ErrUnexpectedEOF case err == ErrWriteTooLong:
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Mon Feb 03 16:38:43 UTC 2025 - 19.7K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/ServerSentEventReader.kt
* data section was empty. Any number of calls to [Callback.onRetryChange] may occur while * processing an event. * * @return false when EOF is reached */ @Throws(IOException::class) fun processNextEvent(): Boolean { var id = lastId var type: String? = null val data = Buffer() while (true) {
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Oct 03 07:51:20 UTC 2025 - 4.3K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbFileInputStreamTest.java
int n = in.read(buf); assertEquals(3, n); } @Test @DisplayName("read() returns -1 when underlying readDirect hits EOF") void readSingleByteEOF() throws Exception { // Arrange SMB2 EOF via NT status code mapping in SmbFileInputStream
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 12.8K bytes - Viewed (0) -
internal/s3select/select.go
// Start is the byte offset to read from (from the start of the file). Start *uint64 `xml:"Start"` // End is the offset of the last byte that should be returned when Start // is set, otherwise it is the offset from EOF to start reading. End *uint64 `xml:"End"` } // Validate if the scan range is valid. func (s *ScanRange) Validate() error { if s == nil { return nil } if s.Start == nil && s.End == nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 21.2K bytes - Viewed (0) -
internal/grid/muxclient.go
continue case <-pingTimer: if !m.doPing(errResp) { errState = true continue } case req, ok := <-requests: if !ok { // Done send EOF if debugPrint { fmt.Println("Client done, sending EOF to mux", m.MuxID) } msg := message{ Op: OpMuxClientMsg, MuxID: m.MuxID, Flags: FlagEOF, } msg.setZeroPayloadFlag()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 15.9K bytes - Viewed (0)