Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 15 of 15 for WriteNode (0.68 sec)

  1. cmd/xl-storage_noatime_supported.go

    package cmd
    
    import (
    	"os"
    )
    
    var (
    	// Disallow updating access times
    	readMode = os.O_RDONLY | 0x40000 // O_NOATIME
    
    	// Write with data sync only used only for `xl.meta` writes
    	writeMode = 0x1000 // O_DSYNC
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 1K bytes
    - Viewed (0)
  2. cmd/os-instrumented.go

    	return RenameSys(src, dst)
    }
    
    // OpenFile captures time taken to call os.OpenFile
    func OpenFile(name string, flag int, perm os.FileMode) (f *os.File, err error) {
    	switch flag & writeMode {
    	case writeMode:
    		defer updateOSMetrics(osMetricOpenFileW, name)(err)
    	default:
    		defer updateOSMetrics(osMetricOpenFileR, name)(err)
    	}
    	return os.OpenFile(name, flag, perm)
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Feb 15 01:09:38 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  3. cmd/os_unix.go

    	}
    	return nil
    }
    
    // openFileWithFD return 'fd' based file descriptor
    func openFileWithFD(name string, flag int, perm os.FileMode) (fd int, err error) {
    	switch flag & writeMode {
    	case writeMode:
    		defer updateOSMetrics(osMetricOpenFileWFd, name)(err)
    	default:
    		defer updateOSMetrics(osMetricOpenFileRFd, name)(err)
    	}
    	var e error
    	fd, e = syscall.Open(name, flag|syscall.O_CLOEXEC, uint32(perm))
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  4. src/compress/flate/deflate_test.go

    	select {
    	case b.ready <- true:
    	default:
    	}
    }
    
    func (b *syncBuffer) Write(p []byte) (n int, err error) {
    	n, err = b.buf.Write(p)
    	b.signal()
    	return
    }
    
    func (b *syncBuffer) WriteMode() {
    	b.mu.Lock()
    }
    
    func (b *syncBuffer) ReadMode() {
    	b.mu.Unlock()
    	b.signal()
    }
    
    func (b *syncBuffer) Close() error {
    	b.closed = true
    	b.signal()
    	return nil
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 14 00:03:57 UTC 2023
    - 25.6K bytes
    - Viewed (0)
  5. cmd/xl-storage.go

    			return nil, errDiskNotFound
    		}
    	}
    
    	return w, nil
    }
    
    func (s *xlStorage) openFileSync(filePath string, mode int, skipParent string) (f *os.File, err error) {
    	return s.openFile(filePath, mode|writeMode, skipParent)
    }
    
    func (s *xlStorage) openFile(filePath string, mode int, skipParent string) (f *os.File, err error) {
    	if skipParent == "" {
    		skipParent = s.drivePath
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (0)
Back to top