- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 92 for readdir (0.17 sec)
-
src/image/jpeg/reader.go
29, 22, 15, 23, 30, 37, 44, 51, 58, 59, 52, 45, 38, 31, 39, 46, 53, 60, 61, 54, 47, 55, 62, 63, } // Deprecated: Reader is not used by the [image/jpeg] package and should // not be used by others. It is kept for compatibility. type Reader interface { io.ByteReader io.Reader } // bits holds the unprocessed bits that have been taken from the byte-stream.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 12:02:45 UTC 2023 - 22.5K bytes - Viewed (0) -
src/image/png/reader.go
const ( dsStart = iota dsSeenIHDR dsSeenPLTE dsSeentRNS dsSeenIDAT dsSeenIEND ) const pngHeader = "\x89PNG\r\n\x1a\n" type decoder struct { r io.Reader img image.Image crc hash.Hash32 width, height int depth int palette color.Palette cb int stage int idatLength uint32
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 12:02:45 UTC 2023 - 26K bytes - Viewed (0) -
src/mdo/reader-stax.vm
} //-- void setAddLocationInformation(boolean) #end public ${root.name} read(Reader reader) throws XMLStreamException { #if ( $locationTracking ) return read(reader, true, null); #else return read(reader, true); #end } /** * @param reader a reader object. * @param strict a strict object. * @throws XMLStreamException XMLStreamException if
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon Mar 25 10:50:01 UTC 2024 - 38.1K bytes - Viewed (0) -
pkg/volume/emptydir/empty_dir.go
// In this case, delete ready file and print a warning for it. klog.Warningf("volume ready file dir %s exist, but volume dir %s does not. Remove ready dir", readyDir, dir) if err := os.RemoveAll(readyDir); err != nil && !os.IsNotExist(err) { klog.Warningf("failed to remove ready dir [%s]: %v", readyDir, err) } } } switch { case ed.medium == v1.StorageMediumDefault: err = ed.setupDir(dir)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 19K bytes - Viewed (0) -
src/mime/multipart/multipart.go
peek, _ := br.Peek(br.Buffered()) p.n, p.err = scanUntilBoundary(peek, p.mr.dashBoundary, p.mr.nlDashBoundary, p.total, p.readErr) if p.n == 0 && p.err == nil { // Force buffered I/O to read more into buffer. _, p.readErr = br.Peek(len(peek) + 1) if p.readErr == io.EOF { p.readErr = io.ErrUnexpectedEOF } } } // Read out from "data to return" part of buffer. if p.n == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 16:12:35 UTC 2024 - 14.1K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer.go
if len(p) == 0 { return 0, r.readErr(false) } r.mu.Lock() defer r.mu.Unlock() if err := r.readErr(true); err != nil { return 0, err } r.wg.Add(1) defer r.wg.Done() n, err = r.read(p) for err == ErrIsEmpty && r.block { r.writeCond.Wait() if err = r.readErr(true); err != nil { break } n, err = r.read(p) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 13.3K bytes - Viewed (0) -
src/debug/buildinfo/buildinfo.go
} else { bo = binary.LittleEndian } var readPtr func([]byte) uint64 if ptrSize == 4 { readPtr = func(b []byte) uint64 { return uint64(bo.Uint32(b)) } } else if ptrSize == 8 { readPtr = bo.Uint64 } else { return "", "", errNotGoExe } vers = readString(x, ptrSize, readPtr, readPtr(data[16:])) mod = readString(x, ptrSize, readPtr, readPtr(data[16+ptrSize:])) } if vers == "" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 12.6K bytes - Viewed (0) -
src/bufio/bufio.go
// NewReaderSize returns a new [Reader] whose buffer has at least the specified // size. If the argument io.Reader is already a [Reader] with large enough // size, it returns the underlying [Reader]. func NewReaderSize(rd io.Reader, size int) *Reader { // Is it already a Reader? b, ok := rd.(*Reader) if ok && len(b.buf) >= size { return b } r := new(Reader) r.reset(make([]byte, max(size, minReadBufferSize)), rd)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 12 14:39:08 UTC 2023 - 21.8K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer_test.go
fmt.Println(args...) } } // Inject random reader/writer sleeps. const maxSleep = int(1 * time.Millisecond) doSleep := !testing.Short() rb := New(4 << 10).SetBlocking(true) // Reader var readErr error var wg sync.WaitGroup wg.Add(1) go func() { readRng := rand.New(rand.NewSource(1)) defer wg.Done() defer rb.CloseWithError(readErr) buf := make([]byte, 1024) for { // Read
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 26.8K bytes - Viewed (0) -
cmd/erasure-healing.go
var found int var notFound int var foundNotEmpty int var otherFound int for _, readErr := range errs { switch { case readErr == nil: found++ case readErr == errFileNotFound || readErr == errVolumeNotFound: notFound++ case readErr == errVolumeNotEmpty: foundNotEmpty++ default: otherFound++ } } found = found + foundNotEmpty + otherFound
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.8K bytes - Viewed (0)