Search Options

Results per page
Sort
Preferred Languages
Advance

Results 391 - 400 of 923 for Handle (0.11 sec)

  1. cmd/test-utils_test.go

    // need a sample HTTP request to be sent as argument so that the relevant handler is called, the handler registration is expected
    // to be done since its called from within the API handler tests, the reference to the registered HTTP handler has to be sent
    // as an argument.
    func ExecObjectLayerAPINilTest(t TestErrHandler, bucketName, objectName, instanceType string, apiRouter http.Handler, req *http.Request) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  2. cmd/utils.go

    	runtime.SetMutexProfileFraction(0) // Disable until needed
    	runtime.SetBlockProfileRate(0)     // Disable until needed
    }
    
    // Starts a profiler returns nil if profiler is not enabled, caller needs to handle this.
    func startProfiler(profilerType string) (minioProfiler, error) {
    	var prof profilerWrapper
    	prof.ext = "pprof"
    	// Enable profiler and set the name of the file that pkg/pprof
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  3. cmd/erasure-healing.go

    	} else {
    		newReqInfo = logger.NewReqInfo("", "", globalDeploymentID(), "", "Heal", bucket, object)
    	}
    	healCtx := logger.SetReqInfo(GlobalContext, newReqInfo)
    
    	// Healing directories handle it separately.
    	if HasSuffix(object, SlashSeparator) {
    		hr, err := er.healObjectDir(healCtx, bucket, object, opts.DryRun, opts.Remove)
    		return hr, toObjectErr(err, bucket, object)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  4. cmd/peer-rest-client.go

    				return nil
    			}
    			gridConn.Store(gc)
    			return gc
    		},
    	}
    }
    
    // Wrapper to restClient.Call to handle network errors, in case of network error the connection is marked disconnected
    // permanently. The only way to restore the connection is at the xl-sets layer by xlsets.monitorAndConnectEndpoints()
    // after verifying format.json
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  5. cmd/storage-rest-server.go

    			logger.FatalIf(storageReadAllRPC.Register(gm, server.ReadAllHandler, endpoint.Path), "unable to register handler")
    			logger.FatalIf(storageWriteAllRPC.Register(gm, server.WriteAllHandler, endpoint.Path), "unable to register handler")
    			logger.FatalIf(storageRenameFileRPC.Register(gm, server.RenameFileHandler, endpoint.Path), "unable to register handler")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  6. istioctl/pkg/workload/workload.go

    	}
    	return values.Map(injectedCMValues).GetPathString("global.multiCluster.clusterName"), nil
    }
    
    // Because we are placing into an Unstructured, place as a map instead
    // of structured Istio types.  (The go-client can handle the structured data, but the
    // fake go-client used for mocking cannot.)
    func unstructureIstioType(spec any) (map[string]any, error) {
    	b, err := yaml.Marshal(spec)
    	if err != nil {
    		return nil, err
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 25.3K bytes
    - Viewed (0)
  7. cmd/iam-store.go

    	if name == "" {
    		return updatedAt, errInvalidArgument
    	}
    
    	cache := store.lock()
    	defer store.unlock()
    
    	// Handle policy mapping removal.
    	if policy == "" {
    		if store.getUsersSysType() == LDAPUsersSysType {
    			// Add a fallback removal towards previous content that may come back
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Oct 14 16:35:37 UTC 2024
    - 83.2K bytes
    - Viewed (0)
  8. cmd/peer-rest-server.go

    	logger.FatalIf(stopRebalanceRPC.Register(gm, server.StopRebalanceHandler), "unable to register handler")
    	logger.FatalIf(updateMetacacheListingRPC.Register(gm, server.UpdateMetacacheListingHandler), "unable to register handler")
    	logger.FatalIf(cleanupUploadIDCacheMetaRPC.Register(gm, server.HandlerClearUploadID), "unable to register handler")
    
    	logger.FatalIf(gm.RegisterStreamingHandler(grid.HandlerTrace, grid.StreamHandler{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  9. cmd/api-errors.go

    // toAPIErrorCode - Converts embedded errors. Convenience
    // function written to handle all cases where we have known types of
    // errors returned by underlying layers.
    func toAPIErrorCode(ctx context.Context, err error) (apiErr APIErrorCode) {
    	if err == nil {
    		return ErrNone
    	}
    
    	// Errors that are generated by net.Conn and any context errors must be handled here.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 92.1K bytes
    - Viewed (0)
  10. src/main/webapp/js/admin/plugins/daterangepicker/daterangepicker.js

            this.parentEl = (options.parentEl && $(options.parentEl).length) ? $(options.parentEl) : $(this.parentEl);
            this.container = $(options.template).appendTo(this.parentEl);
    
            //
            // handle all the possible options overriding defaults
            //
    
            if (typeof options.locale === 'object') {
    
                if (typeof options.locale.direction === 'string')
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 64.8K bytes
    - Viewed (0)
Back to top