Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 7,062 for seek (0.06 sec)

  1. src/bytes/reader_test.go

    		{seek: io.SeekCurrent, off: 1, wantpos: 1<<33 + 1, readerr: io.EOF},
    		{seek: io.SeekStart, n: 5, want: "01234"},
    		{seek: io.SeekCurrent, n: 5, want: "56789"},
    		{seek: io.SeekEnd, off: -1, n: 1, wantpos: 9, want: "9"},
    	}
    
    	for i, tt := range tests {
    		pos, err := r.Seek(tt.off, tt.seek)
    		if err == nil && tt.seekerr != "" {
    			t.Errorf("%d. want seek error %q", i, tt.seekerr)
    			continue
    		}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Dec 13 18:45:54 UTC 2021
    - 8K bytes
    - Viewed (0)
  2. src/test/java/jcifs/tests/RandomAccessFileTest.java

                    try ( SmbRandomAccessFile raf = new SmbRandomAccessFile(f, "r") ) {
                        raf.seek(10);
                        Assert.assertEquals(-1, raf.read());
                    }
    
                    byte[] buf = new byte[4];
                    try ( SmbRandomAccessFile raf = new SmbRandomAccessFile(f, "r") ) {
                        raf.seek(6);
                        Assert.assertEquals(2, raf.read(buf));
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 11.4K bytes
    - Viewed (0)
  3. src/main/java/jcifs/SmbRandomAccess.java

    
        /**
         * Current position in file
         * 
         * @return current position
         */
        long getFilePointer ();
    
    
        /**
         * Seek to new position
         * 
         * @param pos
         */
        void seek ( long pos );
    
    
        /**
         * Get the current file length
         * 
         * @return file length
         * @throws SmbException
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 2.5K bytes
    - Viewed (0)
  4. src/archive/tar/reader.go

    		// io.Seeker, but calling Seek always returns an error and performs
    		// no action. Thus, we try an innocent seek to the current position
    		// to see if Seek is really supported.
    		pos1, err := sr.Seek(0, io.SeekCurrent)
    		if pos1 >= 0 && err == nil {
    			// Seek seems supported, so perform the real Seek.
    			pos2, err := sr.Seek(n-1, io.SeekCurrent)
    			if pos2 < 0 || err != nil {
    				return err
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Mar 08 01:59:14 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  5. internal/s3select/select.go

    	return &ObjectReadSeekCloser{
    		segmentReader: segmentReader,
    		size:          actualSize,
    		offset:        0,
    		reader:        nil,
    	}
    }
    
    // Seek call to implement io.Seeker
    func (rsc *ObjectReadSeekCloser) Seek(offset int64, whence int) (int64, error) {
    	// fmt.Printf("actual: %v offset: %v (%v) whence: %v\n", rsc.size, offset, rsc.offset, whence)
    	switch whence {
    	case io.SeekStart:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  6. src/bytes/reader.go

    	return nil
    }
    
    // Seek implements the [io.Seeker] interface.
    func (r *Reader) Seek(offset int64, whence int) (int64, error) {
    	r.prevRune = -1
    	var abs int64
    	switch whence {
    	case io.SeekStart:
    		abs = offset
    	case io.SeekCurrent:
    		abs = r.i + offset
    	case io.SeekEnd:
    		abs = int64(len(r.s)) + offset
    	default:
    		return 0, errors.New("bytes.Reader.Seek: invalid whence")
    	}
    	if abs < 0 {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Jul 16 18:17:37 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  7. LICENSES/third_party/forked/libcontainer/NOTICE

    United States and other governments.  
    It is your responsibility to ensure that your use and/or transfer does not
    violate applicable laws. 
    
    For more information, please see http://www.bis.doc.gov
    
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Tue Oct 22 13:56:22 UTC 2024
    - 518 bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt

          sinkBuffer.write(maskKey)
    
          if (length > 0) {
            val payloadStart = sinkBuffer.size
            sinkBuffer.write(payload)
    
            sinkBuffer.readAndWriteUnsafe(maskCursor!!)
            maskCursor.seek(payloadStart)
            toggleMask(maskCursor, maskKey)
            maskCursor.close()
          }
        } else {
          sinkBuffer.writeByte(b1)
          sinkBuffer.write(payload)
        }
    
        sink.flush()
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  9. tensorflow/c/checkpoint_reader.cc

      CHECK(v2_reader_ != nullptr);
      CHECK(v2_reader_->status().ok());
    
      // First pass: filters out the entries of the slices.
      std::unordered_set<string> filtered_keys;
      BundleEntryProto entry;
      v2_reader_->Seek(kHeaderEntryKey);
      for (v2_reader_->Next(); v2_reader_->Valid(); v2_reader_->Next()) {
        CHECK(entry.ParseFromArray(v2_reader_->value().data(),
                                   v2_reader_->value().size()))
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 16:27:48 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  10. fastapi/datastructures.py

            To be awaitable, compatible with async, this is run in threadpool.
            """
            return await super().read(size)
    
        async def seek(
            self,
            offset: Annotated[
                int,
                Doc(
                    """
                    The position in bytes to seek to in the file.
                    """
                ),
            ],
        ) -> None:
            """
            Move to a position in the file.
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Apr 02 02:48:51 UTC 2024
    - 5.6K bytes
    - Viewed (0)
Back to top