Search Options

Results per page
Sort
Preferred Languages
Advance

Results 631 - 640 of 859 for err (0.03 sec)

  1. internal/config/subnet/config.go

    	if err = config.CheckValidKeys(config.SubnetSubSys, kvs, DefaultKVS); err != nil {
    		return cfg, err
    	}
    
    	var proxyURL *xnet.URL
    	proxy := env.Get(config.EnvMinIOSubnetProxy, kvs.Get(config.Proxy))
    	if len(proxy) > 0 {
    		proxyURL, err = xnet.ParseHTTPURL(proxy)
    		if err != nil {
    			return cfg, err
    		}
    
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  2. internal/grid/muxserver.go

    	if !m.checkSeq(seq) {
    		msg := fmt.Sprintf("receive sequence number mismatch. want %d, got %d", m.RecvSeq, seq)
    		return pongMsg{Err: &msg}
    	}
    	select {
    	case <-m.ctx.Done():
    		err := context.Cause(m.ctx).Error()
    		return pongMsg{Err: &err}
    	default:
    		atomic.StoreInt64(&m.LastPing, time.Now().Unix())
    		return pongMsg{}
    	}
    }
    
    // disconnect will disconnect the mux.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  3. cmd/healthcheck-handler.go

    		defer cancel()
    
    		if _, err := GlobalKMS.GenerateKey(ctx, &kms.GenerateKeyRequest{AssociatedData: kms.Context{"healthcheck": ""}}); err != nil {
    			switch r.Method {
    			case http.MethodHead:
    				apiErr := toAPIError(r.Context(), err)
    				writeResponse(w, apiErr.HTTPStatusCode, nil, mimeNone)
    			case http.MethodGet:
    				writeErrorResponse(r.Context(), w, toAPIError(r.Context(), err), r.URL)
    			}
    			return
    		}
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jun 26 07:44:34 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  4. cmd/erasure-metadata-utils.go

    	errorCounts := make(map[error]int)
    	for _, err := range errs {
    		if IsErrIgnored(err, ignoredErrs...) {
    			continue
    		}
    		// Errors due to context cancellation may be wrapped - group them by context.Canceled.
    		if errors.Is(err, context.Canceled) {
    			errorCounts[context.Canceled]++
    			continue
    		}
    		errorCounts[err]++
    	}
    
    	max := 0
    	for err, count := range errorCounts {
    		switch {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  5. src/cmd/asm/internal/asm/endtoend_test.go

    			if len(mm) != 1 {
    				t.Errorf("%s: invalid errorcheck line:\n%s", fileline, line)
    			} else if err := errors[fileline]; err == "" {
    				t.Errorf("%s: missing error, want %s", fileline, all)
    			} else if !strings.Contains(err, mm[0][1]) {
    				t.Errorf("%s: wrong error for %s:\n%s", fileline, all, err)
    			}
    		} else {
    			if errors[fileline] != "" {
    				t.Errorf("unexpected error on %s: %v", fileline, errors[fileline])
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Thu Dec 07 18:42:59 UTC 2023
    - 11.6K bytes
    - Viewed (0)
  6. cmd/signature-v4_test.go

    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	obj, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    		t.Fatal(err)
    	}
    
    	// sha256 hash of "payload"
    	payloadSHA256 := "239f59ed55e737c77147cf55ad0c1b030b6d7ee748a7426952f9b852d5a935e5"
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  7. internal/grid/README.md

        conn := manager.Connection(host).Subroute("asubroute")
    	
        payload := []byte("request")
        stream, err := conn.NewStream(ctx, grid.HandlerDiskInfo, payload)
    	if err != nil {
            return err
        }
        // Read results from the stream
        err = stream.Results(func(result []byte) error {
            fmt.Println("Got result", string(result))
    
            // Return the response for reuse
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  8. docs/extensions/s3zip/examples/aws-js/main.js

    s3.listObjectsV2({Bucket : 'your-bucket', Prefix: 'path/to/file.zip/'}).
        on('build', function(req) { req.httpRequest.headers['X-Minio-Extract'] = 'true'; }).
        send(function(err, data) {
            if (err) {
                console.log("Error", err);
            } else {
                console.log("Success", data);
            }
        });
    
    
    // Download a file in the archive and store it in /tmp/data.csv
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jun 10 15:17:03 UTC 2021
    - 1K bytes
    - Viewed (0)
  9. cmd/bucket-encryption.go

    	sseCfg, _, err := globalBucketMetadataSys.GetSSEConfig(bucket)
    	return sseCfg, err
    }
    
    // validateBucketSSEConfig parses bucket encryption configuration and validates if it is supported by MinIO.
    func validateBucketSSEConfig(r io.Reader) (*sse.BucketSSEConfig, error) {
    	encConfig, err := sse.ParseBucketSSEConfig(r)
    	if err != nil {
    		return nil, err
    	}
    
    	if len(encConfig.Rules) == 1 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 1.7K bytes
    - Viewed (0)
  10. cmd/xl-storage-errors_test.go

    		pathErr = &os.PathError{Err: syscall.ENOTEMPTY}
    		ok = isSysErrNotEmpty(pathErr)
    		if !ok {
    			t.Fatalf("Unexpected error expecting %s", syscall.ENOTEMPTY)
    		}
    	} else {
    		pathErr = &os.PathError{Err: syscall.Errno(0x91)}
    		ok = isSysErrNotEmpty(pathErr)
    		if !ok {
    			t.Fatal("Unexpected error expecting 0x91")
    		}
    	}
    	if runtime.GOOS == globalWindowsOSName {
    		pathErr = &os.PathError{Err: syscall.Errno(0x03)}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 1.7K bytes
    - Viewed (0)
Back to top