Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for Vries (0.12 sec)

  1. cmd/api-router.go

    	globalObjectAPI = o
    	globalObjLayerMutex.Unlock()
    }
    
    // objectAPIHandler implements and provides http handlers for S3 API.
    type objectAPIHandlers struct {
    	ObjectAPI func() ObjectLayer
    }
    
    // getHost tries its best to return the request host.
    // According to section 14.23 of RFC 2616 the Host header
    // can include the port number if the default value of 80 is not used.
    func getHost(r *http.Request) string {
    	if r.URL.IsAbs() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 04 18:05:56 GMT 2024
    - 22.8K bytes
    - Viewed (0)
  2. src/archive/zip/reader.go

    		rs := io.NewSectionReader(r, off, size-off)
    		if readDirectoryHeader(&File{}, rs) == nil {
    			baseOffset = 0
    		}
    	}
    
    	return d, baseOffset, nil
    }
    
    // findDirectory64End tries to read the zip64 locator just before the
    // directory end and returns the offset of the zip64 directory end if
    // found.
    func findDirectory64End(r io.ReaderAt, directoryEndOffset int64) (int64, error) {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 27.7K bytes
    - Viewed (0)
  3. cmd/object-api-utils.go

    }
    
    // compressSelfTest performs a self-test to ensure that compression
    // algorithms completes a roundtrip. If any algorithm
    // produces an incorrect checksum it fails with a hard error.
    //
    // compressSelfTest tries to catch any issue in the compression implementation
    // early instead of silently corrupting data.
    func compressSelfTest() {
    	// 4 MB block.
    	// Approx runtime ~30ms
    	data := make([]byte, 4<<20)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
  4. internal/kms/kms.go

    		KeyID      string `json:"keyid"`
    		Ciphertext []byte `json:"ciphertext"`
    	}
    	return json.Marshal(JSON{
    		KeyID:      d.KeyID,
    		Ciphertext: d.Ciphertext,
    	})
    }
    
    // UnmarshalText tries to decode text as JSON representation
    // of a DEK and sets DEK's key ID and ciphertext to the
    // decoded values.
    //
    // It sets DEK's plaintext to nil.
    func (d *DEK) UnmarshalText(text []byte) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  5. cmd/bitrot.go

    }
    
    // bitrotSelfTest performs a self-test to ensure that bitrot
    // algorithms compute correct checksums. If any algorithm
    // produces an incorrect checksum it fails with a hard error.
    //
    // bitrotSelfTest tries to catch any issue in the bitrot implementation
    // early instead of silently corrupting data.
    func bitrotSelfTest() {
    	checksums := map[BitrotAlgorithm]string{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 7.6K bytes
    - Viewed (0)
  6. internal/lock/lock_windows.go

    	}
    
    	if st.IsDir() {
    		f.Close()
    		return nil, &os.PathError{
    			Op:   "open",
    			Path: path,
    			Err:  syscall.EISDIR,
    		}
    	}
    
    	return &LockedFile{File: f}, nil
    }
    
    // TryLockedOpenFile - tries a new write lock, functionality
    // it is similar to LockedOpenFile with with syscall.LOCK_EX
    // mode but along with syscall.LOCK_NB such that the function
    // doesn't wait forever but instead returns if it cannot
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Oct 18 18:08:15 GMT 2023
    - 7.9K bytes
    - Viewed (0)
  7. istioctl/pkg/dashboard/dashboard.go

    			}
    			return portForward(name, namespace, "SkyWalking",
    				"http://%s", bindAddress, skywalkingPort, client, cmd.OutOrStdout(), browser)
    		},
    	}
    
    	return cmd
    }
    
    // portForward first tries to forward localhost:remotePort to podName:remotePort, falls back to dynamic local port
    func portForward(podName, namespace, flavor, urlFormat, localAddress string, remotePort int,
    	client kube.CLIClient, writer io.Writer, browser bool,
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Apr 15 01:29:35 GMT 2024
    - 20.5K bytes
    - Viewed (0)
  8. cmd/encryption-v1.go

    		reqInfo := (&logger.ReqInfo{}).AppendTags("size", strconv.FormatUint(size, 10))
    		ctx := logger.SetReqInfo(GlobalContext, reqInfo)
    		logger.CriticalIf(ctx, err)
    	}
    	return int64(size)
    }
    
    // DecryptObjectInfo tries to decrypt the provided object if it is encrypted.
    // It fails if the object is encrypted and the HTTP headers don't contain
    // SSE-C headers or the object is not encrypted but SSE-C headers are provided. (AWS behavior)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 36.5K bytes
    - Viewed (0)
  9. cmd/xl-storage.go

    // for io.EOF.
    //
    // If an EOF happens after reading some but not all the bytes,
    // ReadFile returns ErrUnexpectedEOF.
    //
    // If the BitrotVerifier is not nil or not verified ReadFile
    // tries to verify whether the disk has bitrot.
    //
    // Additionally ReadFile also starts reading from an offset. ReadFile
    // semantics are same as io.ReadFull.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool-rebalance.go

    	return nil
    }
    
    // updates rebalance.bin from let's say 2 pool setup in the middle
    // of a rebalance, was expanded can cause z.rebalMeta to be outdated
    // due to a missing new pool. This function tries to handle this
    // scenario, albeit rare it seems to have occurred in the wild.
    //
    // since we do not explicitly disallow it, but it is okay for them
    // expand and then we continue to rebalance.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
Back to top