Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 12 for _seek (0.03 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 21.2K bytes
    - Click Count (0)
  2. 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
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Oct 07 19:46:36 GMT 2025
    - 26.9K bytes
    - Click Count (0)
  3. docs/uk/docs/tutorial/request-files.md

    * `write(data)`: Записує `data` (`str` або `bytes`) у файл.
    * `read(size)`: Читає `size` (`int`) байтів/символів з файлу.
    * `seek(offset)`: Переміщується до позиції `offset` (`int`) у файлі.
        * Наприклад, `await myfile.seek(0)` поверне курсор на початок файлу.
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Feb 22 22:01:44 GMT 2025
    - 11.2K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/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 -> {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 16:11:23 GMT 2025
    - 10K bytes
    - Click Count (0)
  5. src/main/java/jcifs/smb1/smb1/SmbRandomAccessFile.java

        }
    
        /**
         * Sets the file pointer to the specified position.
         *
         * @param pos the new file pointer position
         * @throws SmbException if an I/O error occurs
         */
        public void seek(final long pos) throws SmbException {
            fp = pos;
        }
    
        /**
         * Returns the length of the file.
         *
         * @return the file length in bytes
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 14.1K bytes
    - Click Count (0)
  6. cmd/ftp-server-driver.go

    	if err != nil {
    		return 0, nil, err
    	}
    	defer func() {
    		if err != nil && obj != nil {
    			obj.Close()
    		}
    	}()
    
    	_, err = obj.Seek(offset, io.SeekStart)
    	if err != nil {
    		return 0, nil, err
    	}
    
    	info, err := obj.Stat()
    	if err != nil {
    		return 0, nil, err
    	}
    	n = info.Size - offset
    	return n, obj, nil
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 14.3K bytes
    - Click Count (0)
  7. src/main/java/jcifs/smb/SmbRandomAccessFile.java

                throw SmbException.wrap(e);
            }
        }
    
        @Override
        public long getFilePointer() {
            return this.fp;
        }
    
        @Override
        public void seek(final long pos) {
            this.fp = pos;
        }
    
        @Override
        public long length() throws SmbException {
            return this.file.length();
        }
    
        @Override
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 18.8K bytes
    - Click Count (0)
  8. internal/event/config_test.go

    		{reader4, "us-east-1", targetList1, true},
    		{reader3, "", targetList2, false},
    		{reader2, "us-east-1", targetList2, false},
    	}
    
    	for i, testCase := range testCases {
    		if _, err := testCase.reader.Seek(0, 0); err != nil {
    			panic(err)
    		}
    		_, err := ParseConfig(testCase.reader, testCase.region, testCase.targetList)
    		expectErr := (err != nil)
    
    		if expectErr != testCase.expectErr {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 28.9K bytes
    - Click Count (0)
  9. src/archive/tar/reader_test.go

    	}
    
    }
    
    type reader struct{ io.Reader }
    type readSeeker struct{ io.ReadSeeker }
    type readBadSeeker struct{ io.ReadSeeker }
    
    func (rbs *readBadSeeker) Seek(int64, int) (int64, error) { return 0, fmt.Errorf("illegal seek") }
    
    // TestReadTruncation test the ending condition on various truncated files and
    // that truncated files are still detected even if the underlying io.Reader
    // satisfies io.Seeker.
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Dec 15 16:34:13 GMT 2025
    - 47.5K bytes
    - Click Count (0)
  10. docs/LICENSE

              violation; or
    
           2. upon express reinstatement by the Licensor.
    
         For the avoidance of doubt, this Section 6(b) does not affect any
         right the Licensor may have to seek remedies for Your violations
         of this Public License.
    
      c. For the avoidance of doubt, the Licensor may also offer the
         Licensed Material under separate terms or conditions or stop
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon May 10 16:50:06 GMT 2021
    - 18.2K bytes
    - Click Count (0)
Back to Top