Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 74 for Sendfile (0.06 seconds)

  1. cmd/xl-storage.go

    // tries to verify whether the disk has bitrot.
    //
    // Additionally ReadFile also starts reading from an offset. ReadFile
    // semantics are same as io.ReadFull.
    func (s *xlStorage) ReadFile(ctx context.Context, volume string, path string, offset int64, buffer []byte, verifier *BitrotVerifier) (int64, error) {
    	if offset < 0 {
    		return 0, errInvalidArgument
    	}
    
    	volumeDir, err := s.getVolDir(volume)
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
  2. internal/store/queuestore.go

    	defer func(store *QueueStore[I]) {
    		store.RUnlock()
    		if err != nil && !os.IsNotExist(err) {
    			// Upon error we remove the entry.
    			store.Del(key)
    		}
    	}(store)
    
    	raw, err = os.ReadFile(filepath.Join(store.directory, key.String()))
    	if err != nil {
    		return raw, err
    	}
    
    	if len(raw) == 0 {
    		return raw, os.ErrNotExist
    	}
    
    	if key.Compress {
    		raw, err = s2.Decode(nil, raw)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  3. cmd/sftp-server.go

    	if sshPrivateKey == "" {
    		logger.Fatal(fmt.Errorf("invalid arguments passed, private key file is mandatory for --sftp='ssh-private-key=path/to/id_ecdsa'"), "unable to start SFTP server")
    	}
    
    	privateBytes, err := os.ReadFile(sshPrivateKey)
    	if err != nil {
    		logger.Fatal(fmt.Errorf("invalid arguments passed, private key file is not accessible: %v", err), "unable to start SFTP server")
    	}
    
    	private, err := ssh.ParsePrivateKey(privateBytes)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  4. cmd/storage-interface.go

    	// File operations.
    	ListDir(ctx context.Context, origvolume, volume, dirPath string, count int) ([]string, error)
    	ReadFile(ctx context.Context, volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error)
    	AppendFile(ctx context.Context, volume string, path string, buf []byte) (err error)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  5. docs/debugging/inspect/main.go

    			base = base[:idx]
    		}
    		for {
    			// Automatically read "file.ext", "file-2.ext", "file-3.ext"...
    			fn := base + ext
    			if n > 1 {
    				fn = fmt.Sprintf("%s-%d%s", base, n, ext)
    			}
    
    			if b, err := os.ReadFile(fn); err == nil {
    				privateKeys = append(privateKeys, b)
    				fmt.Println("Added private key from", fn)
    			} else {
    				break
    			}
    			n++
    		}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Feb 17 17:09:42 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  6. cmd/xl-storage-format-v2_test.go

    		if dataDir != tc.expectedDataDir {
    			t.Fatalf("Expected %s but got %s", tc.expectedDataDir, dataDir)
    		}
    		count++
    	}
    }
    
    func Benchmark_mergeXLV2Versions(b *testing.B) {
    	data, err := os.ReadFile("testdata/xl.meta-v1.2.zst")
    	if err != nil {
    		b.Fatal(err)
    	}
    	dec, _ := zstd.NewReader(nil)
    	data, err = dec.DecodeAll(data, nil)
    	if err != nil {
    		b.Fatal(err)
    	}
    
    	var xl xlMetaV2
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37.8K bytes
    - Click Count (0)
  7. cmd/xl-storage-errors.go

    func isSysErrCrossDevice(err error) bool {
    	return errors.Is(err, syscall.EXDEV)
    }
    
    // Check if given error corresponds to too many open files
    func isSysErrTooManyFiles(err error) bool {
    	return errors.Is(err, syscall.ENFILE) || errors.Is(err, syscall.EMFILE)
    }
    
    func osIsNotExist(err error) bool {
    	return errors.Is(err, os.ErrNotExist)
    }
    
    func osIsPermission(err error) bool {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Mar 06 16:56:29 GMT 2023
    - 3.8K bytes
    - Click Count (0)
  8. docs/debugging/reorder-disks/main.go

    				result = append(result, localDisk{index: index, path: u.Path})
    			}
    		}
    	}
    
    	return result, nil
    }
    
    func getFormatJSON(path string) (format, error) {
    	formatJSON, err := os.ReadFile(filepath.Join(path, ".minio.sys/format.json"))
    	if err != nil {
    		return format{}, err
    	}
    	var f format
    	err = json.Unmarshal(formatJSON, &f)
    	if err != nil {
    		return format{}, err
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 5.4K bytes
    - Click Count (0)
  9. api/go1.25.txt

    pkg os, method (*Root) Lchown(string, int, int) error #67002
    pkg os, method (*Root) Link(string, string) error #67002
    pkg os, method (*Root) MkdirAll(string, fs.FileMode) error #67002
    pkg os, method (*Root) ReadFile(string) ([]uint8, error) #73126
    pkg os, method (*Root) Readlink(string) (string, error) #67002
    pkg os, method (*Root) RemoveAll(string) error #67002
    pkg os, method (*Root) Rename(string, string) error #67002
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Jun 02 16:09:57 GMT 2025
    - 6.8K bytes
    - Click Count (0)
  10. cmd/update.go

    //
    //	"/.dockerenv":        "file",
    //	"/run/.containerenv": "file",
    func IsDocker() bool {
    	var err error
    	for _, envfile := range []string{
    		"/.dockerenv",
    		"/run/.containerenv",
    	} {
    		_, err = os.Stat(envfile)
    		if err == nil {
    			return true
    		}
    	}
    	if osIsNotExist(err) {
    		// if none of the files are present we may be running inside
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 18.9K bytes
    - Click Count (0)
Back to Top