- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 689 for rewrite (0.09 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)