Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 404 for lseek (0.12 sec)

  1. pkg/volume/metrics_block.go

    func (mb *metricsBlock) getBlockInfo(metrics *Metrics) error {
    	dev, err := os.Open(mb.device)
    	if err != nil {
    		return fmt.Errorf("unable to open device %q: %w", mb.device, err)
    	}
    	defer dev.Close()
    
    	end, err := dev.Seek(0, io.SeekEnd)
    	if err != nil {
    		return fmt.Errorf("failed to detect size of %q: %w", mb.device, err)
    	}
    
    	metrics.Capacity = resource.NewQuantity(end, resource.BinarySI)
    
    	return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 19 14:33:37 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  2. src/compress/gzip/issue14937_test.go

    // has a zero MTIME. This is a requirement for the Debian maintainers
    // to be able to have deterministic packages.
    //
    // To patch a .gz file, use the following command:
    //
    //	$ dd if=/dev/zero bs=1 seek=4 count=4 conv=notrunc of=filename.gz
    //
    // See https://golang.org/issue/14937.
    func TestGZIPFilesHaveZeroMTimes(t *testing.T) {
    	// To avoid spurious false positives due to untracked GZIP files that
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Apr 10 16:37:53 UTC 2024
    - 2K bytes
    - Viewed (0)
  3. src/internal/coverage/cfile/testdata/harness.go

    	f.writeCount++
    	if f.writeLimit < 0 || c < f.writeLimit {
    		return f.slws.Write(p)
    	}
    	return 0, fmt.Errorf("manufactured write error")
    }
    
    func (f *failingWriter) Seek(offset int64, whence int) (int64, error) {
    	return f.slws.Seek(offset, whence)
    }
    
    func (f *failingWriter) reset(lim int) {
    	f.writeCount = 0
    	f.writeLimit = lim
    	f.slws = slicewriter.WriteSeeker{}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 21 19:41:02 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  4. src/cmd/vendor/golang.org/x/sys/unix/syscall_linux_arm.go

    	return Timespec{Sec: int32(sec), Nsec: int32(nsec)}
    }
    
    func setTimeval(sec, usec int64) Timeval {
    	return Timeval{Sec: int32(sec), Usec: int32(usec)}
    }
    
    func Seek(fd int, offset int64, whence int) (newoffset int64, err error) {
    	newoffset, errno := seek(fd, offset, whence)
    	if errno != 0 {
    		return 0, errno
    	}
    	return newoffset, nil
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:33 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  5. src/archive/tar/writer.go

    	default:
    		return n, nil
    	}
    }
    
    func (sw *sparseFileWriter) ReadFrom(r io.Reader) (n int64, err error) {
    	rs, ok := r.(io.ReadSeeker)
    	if ok {
    		if _, err := rs.Seek(0, io.SeekCurrent); err != nil {
    			ok = false // Not all io.Seeker can really seek
    		}
    	}
    	if !ok {
    		return io.Copy(struct{ io.Writer }{sw}, r)
    	}
    
    	var readLastByte bool
    	pos0 := sw.pos
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  6. src/internal/poll/fd_windows.go

    		}
    	}
    }
    
    // Seek wraps syscall.Seek.
    func (fd *FD) Seek(offset int64, whence int) (int64, error) {
    	if fd.kind == kindPipe {
    		return 0, syscall.ESPIPE
    	}
    	if err := fd.incref(); err != nil {
    		return 0, err
    	}
    	defer fd.decref()
    
    	fd.l.Lock()
    	defer fd.l.Unlock()
    
    	return syscall.Seek(fd.Sysfd, offset, whence)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 31 16:50:42 UTC 2024
    - 34.1K bytes
    - Viewed (0)
  7. src/testing/fstest/mapfs.go

    	f.offset += int64(n)
    	return n, nil
    }
    
    func (f *openMapFile) Seek(offset int64, whence int) (int64, error) {
    	switch whence {
    	case 0:
    		// offset += 0
    	case 1:
    		offset += f.offset
    	case 2:
    		offset += int64(len(f.f.Data))
    	}
    	if offset < 0 || offset > int64(len(f.f.Data)) {
    		return 0, &fs.PathError{Op: "seek", Path: f.path, Err: fs.ErrInvalid}
    	}
    	f.offset = offset
    	return offset, nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  8. src/cmd/internal/goobj/objfile_test.go

    	"internal/testenv"
    	"os"
    	"testing"
    
    	"cmd/internal/bio"
    	"cmd/internal/objabi"
    )
    
    func dummyWriter(buf *bytes.Buffer) *Writer {
    	wr := &bio.Writer{Writer: bufio.NewWriter(buf)} // hacky: no file, so cannot seek
    	return NewWriter(wr)
    }
    
    func TestReadWrite(t *testing.T) {
    	// Test that we get the same data in a write-read roundtrip.
    
    	// Write a symbol, a relocation, and an aux info.
    	var buf bytes.Buffer
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 15 20:22:12 UTC 2022
    - 3K bytes
    - Viewed (0)
  9. src/net/http/transfer_test.go

    		if _, err := io.CopyN(f, rand.Reader, nBytes); err != nil {
    			return nil, nil, fmt.Errorf("failed to write data to file: %v", err)
    		}
    		if _, err := f.Seek(0, 0); err != nil {
    			return nil, nil, fmt.Errorf("failed to seek to front: %v", err)
    		}
    
    		done = func() {
    			f.Close()
    			os.Remove(f.Name())
    		}
    
    		return f, done, nil
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Nov 17 23:16:28 UTC 2023
    - 9.1K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt

        if (frameLength > 0L) {
          source.readFully(controlFrameBuffer, frameLength)
    
          if (!isClient) {
            controlFrameBuffer.readAndWriteUnsafe(maskCursor!!)
            maskCursor.seek(0)
            toggleMask(maskCursor, maskKey!!)
            maskCursor.close()
          }
        }
    
        when (opcode) {
          OPCODE_CONTROL_PING -> {
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.8K bytes
    - Viewed (0)
Back to top