Search Options

Results per page
Sort
Preferred Languages
Advance

Results 431 - 440 of 859 for err (0.01 sec)

  1. 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)
  2. internal/ioutil/append-file_nix.go

    	if osync {
    		flags |= os.O_SYNC
    	}
    	appendFile, err := os.OpenFile(dst, flags, 0o666)
    	if err != nil {
    		return err
    	}
    	defer appendFile.Close()
    
    	srcFile, err := os.Open(src)
    	if err != nil {
    		return err
    	}
    	defer srcFile.Close()
    	_, err = io.Copy(appendFile, srcFile)
    	return err
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 1.3K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. internal/config/dns/etcd_dns.go

    	ctx, cancel := context.WithTimeout(context.Background(), defaultContextTimeout)
    	r, err := c.etcdClient.Get(ctx, key, clientv3.WithPrefix())
    	defer cancel()
    	if err != nil {
    		return nil, err
    	}
    
    	if r.Count == 0 {
    		key = strings.TrimSuffix(key, etcdPathSeparator)
    		r, err = c.etcdClient.Get(ctx, key)
    		if err != nil {
    			return nil, err
    		}
    		// only if we are looking at `domain` as true
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 26 15:03:08 UTC 2024
    - 8K bytes
    - Viewed (0)
  8. cmd/batch-expire.go

    		}
    	}
    
    	for _, tag := range ef.Tags {
    		if err := tag.Validate(); err != nil {
    			return err
    		}
    	}
    
    	for _, meta := range ef.Metadata {
    		if err := meta.Validate(); err != nil {
    			return err
    		}
    	}
    	if err := ef.Purge.Validate(); err != nil {
    		return err
    	}
    	if err := ef.Size.Validate(); err != nil {
    		return err
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  9. internal/bucket/lifecycle/expiration_test.go

    		t.Run(fmt.Sprintf("Test %d", i+1), func(t *testing.T) {
    			var expiration Expiration
    			err := xml.Unmarshal([]byte(tc.inputXML), &expiration)
    			if err != nil {
    				t.Fatalf("%d: %v", i+1, err)
    			}
    
    			err = expiration.Validate()
    			if err != tc.expectedErr {
    				t.Fatalf("%d: got: %v, expected: %v", i+1, err, tc.expectedErr)
    			}
    		})
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Feb 21 20:28:34 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  10. cmd/erasure-utils.go

    		// We have written all the blocks, write the last remaining block.
    		if write < int64(len(block)) {
    			n, err := dst.Write(block[:write])
    			if err != nil {
    				return 0, err
    			}
    			totalWritten += int64(n)
    			break
    		}
    
    		// Copy the block.
    		n, err := dst.Write(block)
    		if err != nil {
    			return 0, err
    		}
    
    		// Decrement output size.
    		write -= int64(n)
    
    		// Increment written.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 3.1K bytes
    - Viewed (0)
Back to top