Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 988 for readOp (0.23 sec)

  1. internal/s3select/select.go

    		return rsc.offset, errors.New("seek past end of object")
    	}
    	if rsc.reader != nil {
    		_ = rsc.reader.Close()
    		rsc.reader = nil
    	}
    	return rsc.offset, nil
    }
    
    // Read call to implement io.Reader
    func (rsc *ObjectReadSeekCloser) Read(p []byte) (n int, err error) {
    	if rsc.reader == nil {
    		rsc.reader, err = rsc.segmentReader(rsc.offset)
    		if err != nil {
    			return 0, err
    		}
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  2. docs/site-replication/run-multi-site-ldap.sh

    if [ $? -ne 0 ]; then
    	echo "expecting bucket to be present. exiting.."
    	exit_1
    fi
    
    ./mc cp README.md minio2/newbucket/
    
    sleep 5
    ./mc stat --no-list minio1/newbucket/README.md
    if [ $? -ne 0 ]; then
    	echo "expecting object to be present. exiting.."
    	exit_1
    fi
    
    ./mc stat --no-list minio3/newbucket/README.md
    if [ $? -ne 0 ]; then
    	echo "expecting object to be present. exiting.."
    	exit_1
    fi
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 24 08:03:58 UTC 2024
    - 10.1K bytes
    - Viewed (2)
  3. cmd/local-locker_gen.go

    				return
    			}
    		case "Writes":
    			z.Writes, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "Writes")
    				return
    			}
    		case "Reads":
    			z.Reads, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "Reads")
    				return
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	return
    }
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  4. docs/site-replication/run-multi-site-oidc.sh

    if [ $? -ne 0 ]; then
    	echo "expecting bucket to be present. exiting.."
    	exit_1
    fi
    
    ./mc cp README.md minio2/newbucket/
    
    sleep 5
    ./mc stat --no-list minio1/newbucket/README.md
    if [ $? -ne 0 ]; then
    	echo "expecting object to be present. exiting.."
    	exit_1
    fi
    
    ./mc stat --no-list minio3/newbucket/README.md
    if [ $? -ne 0 ]; then
    	echo "expecting object to be present. exiting.."
    	exit_1
    fi
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 24 08:03:58 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  5. cmd/streaming-signature-v4_test.go

    import (
    	"bufio"
    	"bytes"
    	"fmt"
    	"io"
    	"strings"
    	"testing"
    )
    
    // Test read chunk line.
    func TestReadChunkLine(t *testing.T) {
    	type testCase struct {
    		reader         *bufio.Reader
    		expectedErr    error
    		chunkSize      []byte
    		chunkSignature []byte
    	}
    	// List of readers used.
    	readers := []io.Reader{
    		// Test - 1
    		bytes.NewReader([]byte("1000;chunk-signature=111123333333333333334444211\r\n")),
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 5.7K bytes
    - Viewed (0)
  6. cmd/object-multipart-handlers.go

    	if isCompressed {
    		wantEncryption := crypto.Requested(r.Header) || isEncrypted
    		s2c, cb := newS2CompressReader(reader, actualPartSize, wantEncryption)
    		idxCb = cb
    		defer s2c.Close()
    		reader = etag.Wrap(s2c, reader)
    		length = -1
    	}
    
    	srcInfo.Reader, err = hash.NewReader(ctx, reader, length, "", "", actualPartSize)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  7. cmd/object-api-interface.go

    	if etag != "" {
    		header.Set("ETag", etag)
    	}
    	Range := &HTTPRangeSpec{Start: startOffset, End: startOffset + length}
    
    	reader, err := api.GetObjectNInfo(ctx, bucket, object, Range, header, opts)
    	if err != nil {
    		return err
    	}
    	defer reader.Close()
    
    	_, err = xioutil.Copy(writer, reader)
    	return err
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  8. cmd/dummy-data-generator_test.go

    	checkEq(readAll(r), readAll(NewDummyDataGen(100-int64(len(alphabets)), 0)))
    }
    
    // Compares all the bytes returned by the given readers. Any Read
    // errors cause a `false` result. A string describing the error is
    // also returned.
    func cmpReaders(r1, r2 io.Reader) (bool, string) {
    	bufLen := 32 * 1024
    	b1, b2 := make([]byte, bufLen), make([]byte, bufLen)
    	for i := 0; true; i++ {
    		n1, e1 := io.ReadFull(r1, b1)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  9. internal/dsync/drwmutex_test.go

    		panic("Failed to acquire read lock")
    	}
    	// fmt.Println("1st read lock acquired, waiting...")
    
    	drwm2 := NewDRWMutex(ds, "simplelock")
    	ctx2, cancel2 := context.WithCancel(context.Background())
    	if !drwm2.GetRLock(ctx2, cancel2, id, source, Options{Timeout: time.Second}) {
    		panic("Failed to acquire read lock")
    	}
    	// fmt.Println("2nd read lock acquired, waiting...")
    
    	go func() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Dec 24 03:49:07 UTC 2022
    - 9.7K bytes
    - Viewed (0)
  10. internal/ioutil/read_file.go

    	_, err = io.ReadFull(f, dst)
    	return dst, st, err
    }
    
    // ReadFile reads the named file and returns the contents.
    // A successful call returns err == nil, not err == EOF.
    // Because ReadFile reads the whole file, it does not treat an EOF from Read
    // as an error to be reported.
    //
    // passes NOATIME flag for reads on Unix systems to avoid atime updates.
    func ReadFile(name string) ([]byte, error) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Dec 09 18:17:51 UTC 2023
    - 2.3K bytes
    - Viewed (0)
Back to top