- Sort Score
- Result 10 results
- Languages All
Results 431 - 440 of 859 for err (0.04 sec)
-
internal/lock/lock_nix.go
Op: "open", Path: path, Err: syscall.EINVAL, } } f, err := os.OpenFile(path, flag|syscall.O_SYNC, perm) if err != nil { return nil, err } if err = syscall.Flock(int(f.Fd()), lockType); err != nil { f.Close() if err == syscall.EWOULDBLOCK { err = ErrAlreadyLocked } return nil, err } st, err := os.Stat(path) if err != nil { f.Close() return nil, err }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 19 01:35:22 UTC 2021 - 2.8K bytes - Viewed (0) -
cmd/lock-rest-server.go
// Consequently, if err != nil, reply is always false return l.makeResp(resp, err) } // RLockHandler - Acquires an RLock. func (l *lockRESTServer) RLockHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) { resp := lockRPCRLock.NewResponse() success, err := l.ll.RLock(context.Background(), *args) if err == nil && !success { err = errLockConflict }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 5.8K bytes - Viewed (0) -
cmd/background-heal-ops.go
return } var res madmin.HealResultItem var err error switch task.bucket { case nopHeal: err = errSkipFile case SlashSeparator: res, err = healDiskFormat(ctx, objAPI, task.opts) default: if task.object == "" { res, err = objAPI.HealBucket(ctx, task.bucket, task.opts) } else { res, err = objAPI.HealObject(ctx, task.bucket, task.object, task.versionID, task.opts)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
internal/ioutil/append-file_nix.go
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 1.3K bytes - Viewed (0) -
cmd/url_test.go
b.ResetTimer() if err := req.ParseForm(); err != nil { b.Fatal(err) } b.RunParallel(func(pb *testing.PB) { for pb.Next() { req.Form.Get("uploadId") } }) // Benchmark ends here. Stop timer. b.StopTimer() } // BenchmarkURLQuery - benchmark URL memory allocations func BenchmarkURLQuery(b *testing.B) {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Nov 16 17:28:29 UTC 2021 - 2K bytes - Viewed (0) -
internal/event/target/nats_contrib_test.go
Enable: true, Address: xnet.Host{ Name: "localhost", Port: (xnet.Port(opts.Port)), IsPortSet: true, }, Subject: "test", } con, err := clientConfig.connectNats() if err != nil { t.Errorf("Could not connect to nats: %v", err) } defer con.Close() } func TestNatsConnUserPass(t *testing.T) { opts := natsserver.DefaultTestOptions opts.Port = 14223 opts.Username = "testminio"
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 2.3K bytes - Viewed (0) -
internal/crypto/sse.go
sealedKey, err := SSEC.ParseMetadata(metadata) if err != nil { return } err = key.Unseal(clientKey, sealedKey, SSEC.String(), bucket, object) return } // EncryptSinglePart encrypts an io.Reader which must be the // body of a single-part PUT request. func EncryptSinglePart(r io.Reader, key ObjectKey) io.Reader {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Aug 30 15:26:43 UTC 2022 - 4.4K bytes - Viewed (0) -
internal/disk/disk_unix.go
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 19 01:35:22 UTC 2021 - 1.2K bytes - Viewed (0) -
internal/logger/target/http/http.go
func (h *Target) SendFromStore(key store.Key) (err error) { var eventData []byte eventData, err = h.store.GetRaw(key) if err != nil { if os.IsNotExist(err) { return nil } return err } count := 1 v := strings.Split(key.Name, ":") if len(v) == 2 { count, err = strconv.Atoi(v[0]) if err != nil { return err } }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Sep 11 22:20:42 UTC 2024 - 15.6K bytes - Viewed (0) -
internal/crypto/sse-c.go
return key, ErrMissingCustomerKeyMD5 } clientKey, err := base64.StdEncoding.DecodeString(h.Get(xhttp.AmzServerSideEncryptionCustomerKey)) if err != nil || len(clientKey) != 32 { // The client key must be 256 bits long return key, ErrInvalidCustomerKey } keyMD5, err := base64.StdEncoding.DecodeString(h.Get(xhttp.AmzServerSideEncryptionCustomerKeyMD5)) if md5Sum := md5.Sum(clientKey); err != nil || !bytes.Equal(md5Sum[:], keyMD5) {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 5.2K bytes - Viewed (0)