Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 166 for Read (0.13 sec)

  1. internal/ioutil/read_file.go

    )
    
    // ReadFileWithFileInfo reads the named file and returns the contents.
    // A successful call returns err == nil, not err == EOF.
    // Because ReadFile reads the whole file, it does not treat an EOF from Read
    // as an error to be reported.
    func ReadFileWithFileInfo(name string) ([]byte, fs.FileInfo, error) {
    	f, err := OsOpenFile(name, readMode, 0o666)
    	if err != nil {
    		return nil, nil, err
    	}
    	defer f.Close()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 09 18:17:51 GMT 2023
    - 2.3K bytes
    - Viewed (0)
  2. internal/s3select/csv/reader.go

    	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.
    	for len(r.current) <= r.recordsRead {
    		if r.err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  3. cni/pkg/repair/netns.go

    	if err != nil {
    		return "", fmt.Errorf("network id: %v", err)
    	}
    	fs, err := procfs.NewFS("/host/proc")
    	if err != nil {
    		return "", fmt.Errorf("read procfs: %v", err)
    	}
    	procs, err := fs.AllProcs()
    	if err != nil {
    		return "", fmt.Errorf("read procs: %v", err)
    	}
    	oldest := uint64(math.MaxUint64)
    	best := ""
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Dec 20 22:14:13 GMT 2023
    - 4.8K bytes
    - Viewed (0)
  4. cmd/streaming-signature-v4.go

    var errChunkTooBig = errors.New("chunk too big: choose chunk size <= 16MiB")
    
    // newSignV4ChunkedReader returns a new s3ChunkedReader that translates the data read from r
    // out of HTTP "chunked" format before returning it.
    // The s3ChunkedReader returns io.EOF when the final 0-length chunk is read.
    //
    // NewChunkedReader is not needed by normal applications. The http package
    // automatically decodes chunking when reading response bodies.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 18.2K bytes
    - Viewed (0)
  5. cmd/erasure-decode_test.go

    			t.Errorf("Test %d: should fail but it passed", i)
    		}
    		if err == nil {
    			if content := writer.Bytes(); !bytes.Equal(content, data[test.offset:test.offset+test.length]) {
    				t.Errorf("Test %d: read returns wrong file content.", i)
    			}
    		}
    
    		for i, r := range bitrotReaders {
    			if r == nil {
    				disks[i] = OfflineDisk
    			}
    		}
    		if err == nil && !test.shouldFail {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 21.1K bytes
    - Viewed (1)
  6. operator/cmd/mesh/manifest-diff.go

    ) (bool, error) {
    	a, err := os.ReadFile(args[0])
    	if err != nil {
    		return false, fmt.Errorf("could not read %q: %v", args[0], err)
    	}
    	b, err := os.ReadFile(args[1])
    	if err != nil {
    		return false, fmt.Errorf("could not read %q: %v", args[1], err)
    	}
    
    	diff, err := compare.ManifestDiffWithRenameSelectIgnore(string(a), string(b), renameResources, selectResources,
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  7. cmd/erasure-healing-common_test.go

    		t.Fatalf("Failed to read xl meta data %v", reducedErr)
    	}
    
    	// Test 1: Test that all disks are returned without any failures with
    	// unmodified meta data
    	partsMetadata, errs := readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true)
    	if err != nil {
    		t.Fatalf("Failed to read xl meta data %v", err)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 23K bytes
    - Viewed (1)
  8. cmd/bitrot.go

    	defer xioutil.ODirectPoolSmall.Put(bufp)
    
    	for left > 0 {
    		// Read expected hash...
    		h.Reset()
    		n, err := io.ReadFull(r, hashBuf)
    		if err != nil {
    			// Read's failed for object with right size, file is corrupt.
    			return err
    		}
    		// Subtract hash length..
    		left -= int64(n)
    		if left < shardSize {
    			shardSize = left
    		}
    
    		read, err := io.CopyBuffer(h, io.LimitReader(r, shardSize), *bufp)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 7.6K bytes
    - Viewed (0)
  9. cmd/object-api-utils.go

    	minioMetaTmpDeletedBucket = minioMetaTmpBucket + "/.trash"
    
    	// DNS separator (period), used for bucket name validation.
    	dnsDelimiter = "."
    	// On compressed files bigger than this;
    	compReadAheadSize = 100 << 20
    	// Read this many buffers ahead.
    	compReadAheadBuffers = 5
    	// Size of each buffer.
    	compReadAheadBufSize = 1 << 20
    	// Pad Encrypted+Compressed files to a multiple of this.
    	compPadEncrypted = 256
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
  10. cmd/tier-journal.go

    		return nil
    	}
    
    	return errors.New("no local drive found")
    }
    
    // rotate rotates the journal. If a read-only journal already exists it does
    // nothing. Otherwise renames the active journal to a read-only journal and
    // opens a new active journal.
    func (jd *tierDiskJournal) rotate() error {
    	// Do nothing if a read-only journal file already exists.
    	if _, err := os.Stat(jd.ReadOnlyPath()); err == nil {
    		return nil
    	}
    Go
    - Registered: Sun Feb 25 19:28:16 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.4K bytes
    - Viewed (0)
Back to top