- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for writeBlock (0.15 sec)
-
src/internal/poll/sendfile_linux.go
func SendFile(dstFD *FD, src int, remain int64) (written int64, err error, handled bool) { defer func() { TestHookDidSendFile(dstFD, src, written, err, handled) }() if err := dstFD.writeLock(); err != nil { return 0, err, false } defer dstFD.writeUnlock() if err := dstFD.pd.prepareWrite(dstFD.isFile); err != nil { return 0, err, false } dst := dstFD.Sysfd for remain > 0 { n := maxSendfileSize
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 1.4K bytes - Viewed (0) -
src/internal/poll/sendfile_solaris.go
func SendFile(dstFD *FD, src int, pos, remain int64) (written int64, err error, handled bool) { defer func() { TestHookDidSendFile(dstFD, src, written, err, handled) }() if err := dstFD.writeLock(); err != nil { return 0, err, false } defer dstFD.writeUnlock() if err := dstFD.pd.prepareWrite(dstFD.isFile); err != nil { return 0, err, false } dst := dstFD.Sysfd for remain > 0 { n := maxSendfileSize
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 1.8K bytes - Viewed (0) -
src/internal/poll/sendfile_bsd.go
func SendFile(dstFD *FD, src int, pos, remain int64) (written int64, err error, handled bool) { defer func() { TestHookDidSendFile(dstFD, src, written, err, handled) }() if err := dstFD.writeLock(); err != nil { return 0, err, false } defer dstFD.writeUnlock() if err := dstFD.pd.prepareWrite(dstFD.isFile); err != nil { return 0, err, false } dst := dstFD.Sysfd for remain > 0 { n := maxSendfileSize
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 1.5K bytes - Viewed (0) -
src/internal/poll/writev.go
//go:build unix package poll import ( "io" "runtime" "syscall" ) // Writev wraps the writev system call. func (fd *FD) Writev(v *[][]byte) (int64, error) { if err := fd.writeLock(); err != nil { return 0, err } defer fd.writeUnlock() if err := fd.pd.prepareWrite(fd.isFile); err != nil { return 0, err } var iovecs []syscall.Iovec if fd.iovecs != nil { iovecs = *fd.iovecs }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 18:23:49 UTC 2024 - 1.8K bytes - Viewed (0) -
src/internal/poll/sendfile_windows.go
return 0, syscall.ESPIPE } if ft, _ := syscall.GetFileType(src); ft == syscall.FILE_TYPE_PIPE { return 0, syscall.ESPIPE } if err := fd.writeLock(); err != nil { return 0, err } defer fd.writeUnlock() o := &fd.wop o.handle = src // TODO(brainman): skip calling syscall.Seek if OS allows it curpos, err := syscall.Seek(o.handle, 0, io.SeekCurrent) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 2.2K bytes - Viewed (0) -
src/internal/poll/copy_file_range_linux.go
// locks for both file descriptors (and why this whole machinery is // in the internal/poll package to begin with). if err := dst.writeLock(); err != nil { return 0, err } defer dst.writeUnlock() if err := src.readLock(); err != nil { return 0, err } defer src.readUnlock() var n int for { n, err = unix.CopyFileRange(src.Sysfd, nil, dst.Sysfd, nil, max, 0)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 04 17:40:10 UTC 2024 - 3.9K bytes - Viewed (0) -
src/internal/poll/fd_plan9.go
err = ErrDeadlineExceeded } return n, err } // Write implements io.Writer. func (fd *FD) Write(fn func([]byte) (int, error), b []byte) (int, error) { if err := fd.writeLock(); err != nil { return 0, err } defer fd.writeUnlock() fd.wmu.Lock() if fd.wtimedout { fd.wmu.Unlock() return 0, ErrDeadlineExceeded } fd.waio = newAsyncIO(fn, b) fd.wmu.Unlock() n, err := fd.waio.Wait()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 06 14:00:54 UTC 2024 - 5.4K bytes - Viewed (0) -
src/internal/poll/splice_linux.go
// all of it to the socket. This behavior is similar to the Write // step of an io.Copy in userspace. func splicePump(sock *FD, pipefd int, inPipe int) (int, error) { if err := sock.writeLock(); err != nil { return 0, err } defer sock.writeUnlock() if err := sock.pd.prepareWrite(sock.isFile); err != nil { return 0, err } written := 0 for inPipe > 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 7.6K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/internal/locking/DependencyLockingGraphVisitorTest.groovy
} } def 'invokes locking provider on writeLocks with visited modules'() { given: def identifier = newId(mid, '1.1') startWithoutLockState() addVisitedNode(identifier) when: visitor.writeLocks() then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 05 02:50:41 UTC 2024 - 9.1K bytes - Viewed (0) -
platforms/core-execution/build-cache-local/src/main/java/org/gradle/caching/local/internal/DirectoryBuildCache.java
persistentCache.withFileLock(() -> { // Additional locking necessary because of https://github.com/gradle/gradle/issues/3537 lock.writeLock().lock(); try { storeInsideLock(key, file); } finally { lock.writeLock().unlock(); } }); } private void storeInsideLock(HashCode key, File sourceFile) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:53 UTC 2024 - 7K bytes - Viewed (0)