Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 689 for rewrite (0.09 sec)

  1. cmd/xl-storage-format-v2_gen.go

    		return
    	}
    	if (zb0001Mask & 0x1) == 0 { // if not omitted
    		// write "V2Obj"
    		err = en.Append(0xa5, 0x56, 0x32, 0x4f, 0x62, 0x6a)
    		if err != nil {
    			return
    		}
    		if z.ObjectV2 == nil {
    			err = en.WriteNil()
    			if err != nil {
    				return
    			}
    		} else {
    			// map header, size 1
    			// write "DDir"
    			err = en.Append(0x81, 0xa4, 0x44, 0x44, 0x69, 0x72)
    			if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  2. cmd/sts-handlers_test.go

    	}
    
    	gotBuckets := set.NewStringSet()
    	for _, b := range accInfo.Buckets {
    		gotBuckets.Add(b.Name)
    		if !(b.Access.Read && b.Access.Write) {
    			c.Fatalf("root user should have read and write access to bucket: %v", b.Name)
    		}
    	}
    	shouldHaveBuckets := set.CreateStringSet(bucket2, bucket)
    	if !gotBuckets.Equals(shouldHaveBuckets) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 97.1K bytes
    - Viewed (0)
  3. src/bufio/bufio.go

    // If nn < len(p), it also returns an error explaining
    // why the write is short.
    func (b *Writer) Write(p []byte) (nn int, err error) {
    	for len(p) > b.Available() && b.err == nil {
    		var n int
    		if b.Buffered() == 0 {
    			// Large write, empty buffer.
    			// Write directly from p to avoid copy.
    			n, b.err = b.wr.Write(p)
    		} else {
    			n = copy(b.buf[b.n:], p)
    			b.n += n
    			b.Flush()
    		}
    		nn += n
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 12 14:39:08 UTC 2023
    - 21.8K bytes
    - Viewed (0)
  4. internal/http/response-recorder.go

    	}
    	return 0, ErrNotImplemented
    }
    
    func (lrw *ResponseRecorder) Write(p []byte) (int, error) {
    	if !lrw.headersLogged {
    		// We assume the response code to be '200 OK' when WriteHeader() is not called,
    		// that way following Golang HTTP response behavior.
    		lrw.WriteHeader(http.StatusOK)
    	}
    	n, err := lrw.ResponseWriter.Write(p)
    	lrw.bytesWritten += n
    	if lrw.ttfbBody == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  5. cmd/erasure-errors.go

    import "errors"
    
    // errErasureReadQuorum - did not meet read quorum.
    var errErasureReadQuorum = errors.New("Read failed. Insufficient number of drives online")
    
    // errErasureWriteQuorum - did not meet write quorum.
    var errErasureWriteQuorum = errors.New("Write failed. Insufficient number of drives online")
    
    // errNoHealRequired - returned when healing is attempted on a previously healed disks.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 04 23:10:08 UTC 2022
    - 1.2K bytes
    - Viewed (0)
  6. internal/ioutil/ioutil_test.go

    func TestDeadlineWriter(t *testing.T) {
    	w := NewDeadlineWriter(&sleepWriter{timeout: 500 * time.Millisecond}, 450*time.Millisecond)
    	_, err := w.Write([]byte("1"))
    	if err != context.DeadlineExceeded {
    		t.Error("DeadlineWriter shouldn't be successful - should return context.DeadlineExceeded")
    	}
    	_, err = w.Write([]byte("1"))
    	if err != context.DeadlineExceeded {
    		t.Error("DeadlineWriter shouldn't be successful - should return context.DeadlineExceeded")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/smb1/AndXServerMessageBlock.java

             */
            return 0;
        }
    
        /* 
         * We overload this method from ServerMessageBlock because
         * we want writeAndXWireFormat to write the parameterWords
         * and bytes. This is so we can write batched smbs because
         * all but the first smb of the chaain do not have a header
         * and therefore we do not want to writeHeaderWireFormat. We
         * just recursivly call writeAndXWireFormat.
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 11.3K bytes
    - Viewed (0)
  8. docs/distributed/samples/myminio-iam-info-openid.zip

    ling","admin:Prometheus","admin:ServerInfo","admin:ServerTrace"],"Resource":["arn:aws:s3:::*"]}]},readonly":{"Version":"2012-10-17","Statement":[{"Effect":"Allow","Action":["s3:GetBucketLocation","s3:GetObject"],"Resource":["arn:aws:s3:::*"]}]},readwrite":{"Version":"2012-10-17","Statement":[{"Effect":"Allow","Action":["s3:*"],"Resource":["arn:aws:s3:::*"]}]},writeonly":{"Version":"2012-10-17","Statement":[{"Effect":"Allow","Action":["s3:PutObject"],"Resource":["arn:aws:s3:::*"]}]}} iam-assets/users.json...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 2K bytes
    - Viewed (0)
  9. internal/grid/msg_gen.go

    func (z *connectReq) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 4
    	// write "ID"
    	err = en.Append(0x84, 0xa2, 0x49, 0x44)
    	if err != nil {
    		return
    	}
    	err = en.WriteBytes((z.ID)[:])
    	if err != nil {
    		err = msgp.WrapError(err, "ID")
    		return
    	}
    	// write "Host"
    	err = en.Append(0xa4, 0x48, 0x6f, 0x73, 0x74)
    	if err != nil {
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 22.4K bytes
    - Viewed (0)
  10. internal/dsync/locker.go

    	// * a boolean to indicate success/failure of the operation
    	// * an error on failure of lock request operation.
    	RLock(ctx context.Context, args LockArgs) (bool, error)
    
    	// Do write lock for given LockArgs. It should return
    	// * a boolean to indicate success/failure of the operation
    	// * an error on failure of lock request operation.
    	Lock(ctx context.Context, args LockArgs) (bool, error)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 18 20:44:38 UTC 2022
    - 2.7K bytes
    - Viewed (0)
Back to top