Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 97 for fdel (0.07 sec)

  1. cmd/handler-utils.go

    	success = true
    
    	// Make sure we remove any existing headers before
    	// proxying the request to another node.
    	for k := range w.Header() {
    		w.Header().Del(k)
    	}
    
    	f := handlers.NewForwarder(&handlers.Forwarder{
    		PassHost:     true,
    		RoundTripper: ep.Transport,
    		ErrorHandler: func(w http.ResponseWriter, r *http.Request, err error) {
    			success = false
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  2. internal/event/target/elasticsearch.go

    	if err := target.send(eventData); err != nil {
    		if xnet.IsNetworkOrHostDown(err, false) {
    			return store.ErrNotConnected
    		}
    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // Close - does nothing and available for interface compatibility.
    func (target *ElasticsearchTarget) Close() error {
    	close(target.quitCh)
    	if target.client != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  3. src/cmd/asm/internal/asm/testdata/ppc64.s

    	FNMSUB F1, F2, F3, F4           // fc8110fc
    	FNMSUBCC F1, F2, F3, F4         // fc8110fd
    	FNMSUBS F1, F2, F3, F4          // ec8110fc
    	FNMSUBSCC F1, F2, F3, F4        // ec8110fd
    	FSEL F1, F2, F3, F4             // fc8110ee
    	FSELCC F1, F2, F3, F4           // fc8110ef
    	FABS F1, F2                     // fc400a10
    	FNABS F1, F2                    // fc400910
    	FABSCC F1, F2                   // fc400a11
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Mon Oct 21 14:11:44 UTC 2024
    - 50.2K bytes
    - Viewed (0)
  4. cmd/admin-router.go

    			adminRouter.Methods(http.MethodPut).Path(adminVersion + "/set-config-kv").HandlerFunc(adminMiddleware(adminAPI.SetConfigKVHandler))
    			adminRouter.Methods(http.MethodDelete).Path(adminVersion + "/del-config-kv").HandlerFunc(adminMiddleware(adminAPI.DelConfigKVHandler))
    		}
    
    		// Enable config help in all modes.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Sep 21 11:35:40 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool-rebalance.go

    				if filterLifecycle(bucket, version.Name, version) {
    					expired++
    					stopFn(version.Size, errors.New("ILM expired object/version will be skipped"))
    					continue
    				}
    
    				// any object with only single DEL marker we don't need
    				// to rebalance, just skip it, this also includes
    				// any other versions that have already expired.
    				remainingVersions := len(fivs.Versions) - expired
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  6. fastapi/dependencies/utils.py

        async_exit_stack: AsyncExitStack,
        embed_body_fields: bool,
    ) -> SolvedDependency:
        values: Dict[str, Any] = {}
        errors: List[Any] = []
        if response is None:
            response = Response()
            del response.headers["content-length"]
            response.status_code = None  # type: ignore
        dependency_cache = dependency_cache or {}
        sub_dependant: Dependant
        for sub_dependant in dependant.dependencies:
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Sat Oct 12 09:36:32 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  7. cmd/test-utils_test.go

    	}
    
    	// Anonymous request return early.
    	if accessKey == "" || secretKey == "" {
    		return req, nil
    	}
    
    	if signer == signerV2 {
    		err = signRequestV2(req, accessKey, secretKey)
    		req.Header.Del("x-amz-content-sha256")
    	} else {
    		req.Header.Set("x-amz-content-sha256", "92b165232fbd011da355eca0b033db22b934ba9af0145a437a832d27310b89f9")
    		err = signRequestV4(req, accessKey, secretKey)
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool-decom.go

    					expired++
    					decommissioned++
    					stopFn(version.Size, errors.New("ILM expired object/version will be skipped"))
    					continue
    				}
    
    				// any object with only single DEL marker we don't need
    				// to decommission, just skip it, this also includes
    				// any other versions that have already expired.
    				remainingVersions := len(fivs.Versions) - expired
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (1)
  9. internal/grid/connection.go

    		gridLogIf(ctx, c.queueMsg(m, muxConnectError{Error: msg}))
    		return
    	}
    
    	// TODO: This causes allocations, but escape analysis doesn't really show the cause.
    	// If another faithful engineer wants to take a stab, feel free.
    	go func(m message) {
    		var start time.Time
    		if m.DeadlineMS > 0 {
    			start = time.Now()
    		}
    		var b []byte
    		var err *RemoteErr
    		func() {
    			defer func() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  10. cmd/erasure-object.go

    	modTime := opts.MTime
    	if opts.MTime.IsZero() {
    		modTime = UTCNow()
    	}
    	fvID := mustGetUUID()
    
    	defer func() {
    		// attempt a heal before returning if there are offline disks
    		// for both del marker and permanent delete situations.
    		for _, disk := range storageDisks {
    			if disk != nil && disk.IsOnline() {
    				continue
    			}
    			er.addPartial(bucket, object, opts.VersionID)
    			break
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 78.5K bytes
    - Viewed (0)
Back to top