- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for writeBlock (0.22 sec)
-
src/compress/flate/deflate.go
} } n := copy(d.window[d.windowEnd:], b) d.windowEnd += n return n } func (d *compressor) writeBlock(tokens []token, index int) error { if index > 0 { var window []byte if d.blockStart <= index { window = d.window[d.blockStart:index] } d.blockStart = index d.w.writeBlock(tokens, false, window) return d.w.err } return nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 13:32:40 UTC 2024 - 20.3K bytes - Viewed (0) -
src/runtime/pprof/pprof.go
return n } // countMutex returns the number of records in the mutex profile. func countMutex() int { n, _ := runtime.MutexProfile(nil) return n } // writeBlock writes the current blocking profile to w. func writeBlock(w io.Writer, debug int) error { return writeProfileInternal(w, debug, "contention", pprof_blockProfileInternal) } // writeMutex writes the current mutex profile to w.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:52:17 UTC 2024 - 30.6K bytes - Viewed (0) -
src/cmd/link/internal/ld/data.go
func writeDatblkToOutBuf(ctxt *Link, out *OutBuf, addr int64, size int64) { writeBlocks(ctxt, out, ctxt.outSem, ctxt.loader, ctxt.datap, addr, size, zeros[:]) } func dwarfblk(ctxt *Link, out *OutBuf, addr int64, size int64) { // Concatenate the section symbol lists into a single list to pass // to writeBlocks. // // NB: ideally we would do a separate writeBlocks call for each
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 12 15:10:50 UTC 2024 - 100.5K bytes - Viewed (0) -
src/internal/poll/fd_unix.go
} err = fd.eofError(n, err) return n, oobn, sysflags, err } } // Write implements io.Writer. func (fd *FD) Write(p []byte) (int, 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 nn int for { max := len(p) if fd.IsStream && max-nn > maxRW { max = nn + maxRW
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 04:09:44 UTC 2024 - 17.9K bytes - Viewed (0) -
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/fd_windows.go
return n, err } rawToSockaddrInet6(o.rsa, sa6) return n, err } // Write implements io.Writer. func (fd *FD) Write(buf []byte) (int, error) { if err := fd.writeLock(); err != nil { return 0, err } defer fd.writeUnlock() if fd.isFile { fd.l.Lock() defer fd.l.Unlock() } ntotal := 0 for len(buf) > 0 { b := buf if len(b) > maxRW { b = b[:maxRW] }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 31 16:50:42 UTC 2024 - 34.1K bytes - Viewed (0)