Search Options

Results per page
Sort
Preferred Languages
Advance

Results 741 - 750 of 757 for iterator (0.13 sec)

  1. cmd/notification.go

    			if err := f(); err != nil {
    				g.errs[index].Err = err
    
    				if contextCanceled(ctx) {
    					// context already canceled no retries.
    					retryCount = 0
    				}
    
    				// Last iteration log the error.
    				if i == retryCount-1 {
    					reqInfo := (&logger.ReqInfo{}).AppendTags("peerAddress", addr.String())
    					ctx := logger.SetReqInfo(ctx, reqInfo)
    					peersLogOnceIf(ctx, err, addr.String())
    				}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 46K bytes
    - Viewed (0)
  2. cmd/test-utils_test.go

    	// initialize a new mux router.
    	// goriilla/mux is the library used to register all the routes and handle them.
    	muxRouter := mux.NewRouter().SkipClean(true).UseEncodedPath()
    	if len(apiFunctions) > 0 {
    		// Iterate the list of API functions requested for and register them in mux HTTP handler.
    		registerAPIFunctions(muxRouter, objLayer, apiFunctions...)
    		muxRouter.Use(globalMiddlewares...)
    		return muxRouter
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  3. tensorflow/c/c_api.h

    // it will be stopped and joined.
    TF_CAPI_EXPORT extern void TF_DeleteServer(TF_Server* server);
    
    // Register a listener method that processes printed messages.
    //
    // If any listeners are registered, the print operator will call all listeners
    // with the printed messages and immediately return without writing to the
    // logs.
    TF_CAPI_EXPORT extern void TF_RegisterLogListener(
        void (*listener)(const char*));
    
    Registered: Tue Dec 30 12:39:10 UTC 2025
    - Last Modified: Thu Oct 26 21:08:15 UTC 2023
    - 82.3K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/cache/CacheLoadingTest.java

       * for any given call to {@code cache.get} or {@code cache.getUnchecked} is the value returned, or
       * the exception thrown.
       *
       * <p>As we iterate from {@code 0} to {@code nThreads}, threads with an even index will call
       * {@code getUnchecked}, and threads with an odd index will call {@code get}. If the cache throws
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 30 22:03:28 UTC 2025
    - 91.1K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    				}
    			}
    		}(index, disk)
    	}
    	wg.Wait()
    
    	// Reduce errors for each object
    	for objIndex := range objects {
    		diskErrs := make([]error, len(storageDisks))
    		// Iterate over disks to fetch the error
    		// of deleting of the current object
    		for i := range delObjErrs {
    			// delObjErrs[i] is not nil when disks[i] is also not nil
    			if delObjErrs[i] != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/cache/CacheLoadingTest.java

       * for any given call to {@code cache.get} or {@code cache.getUnchecked} is the value returned, or
       * the exception thrown.
       *
       * <p>As we iterate from {@code 0} to {@code nThreads}, threads with an even index will call
       * {@code getUnchecked}, and threads with an odd index will call {@code get}. If the cache throws
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 30 22:03:28 UTC 2025
    - 91.1K bytes
    - Viewed (0)
  7. CHANGELOG/CHANGELOG-1.34.md

    - Extended resources backed by DRA feature allowed cluster operator to specify `extendedResourceName` in `DeviceClass`, and application operator to continue using extended resources in pod's requests to request for DRA devices matching the DeviceClass.
      
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Wed Dec 10 01:13:50 UTC 2025
    - 333.3K bytes
    - Viewed (2)
  8. cmd/erasure-server-pool.go

    			dObjectsByPool[i], dErrsByPool[i] = pool.DeleteObjects(ctx, bucket, objects, opts)
    			return nil
    		}, i)
    	}
    	eg.Wait() // wait to check all the pools.
    
    	for i := range dobjects {
    		// Iterate over pools
    		for pool := range z.serverPools {
    			if dErrsByPool[pool][i] == nil && dObjectsByPool[pool][i].found {
    				// A fast exit when the object is found and removed
    				dobjects[i] = dObjectsByPool[pool][i]
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 89.2K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.21.md

    - Kube-proxy iptables: new metric sync_proxy_rules_iptables_total that exposes the number of rules programmed per table in each iteration ([#99653](https://github.com/kubernetes/kubernetes/pull/99653), [@aojea](https://github.com/aojea)) [SIG Instrumentation and Network]
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Fri Oct 14 07:03:14 UTC 2022
    - 367.3K bytes
    - Viewed (0)
  10. fess-crawler/src/main/resources/org/codelibs/fess/crawler/mime/tika-mimetypes.xml

        <_comment>SAS DMDB Data Mining Database File</_comment>
        <glob pattern="*.s7m"/>
        <glob pattern="*.sas7bdmd"/>
      </mime-type>
      <mime-type type="application/x-sas-itemstor">
        <_comment>SAS Item Store (ItemStor) File</_comment>
        <glob pattern="*.sr7"/>
        <glob pattern="*.sas7bitm"/>
      </mime-type>
      <mime-type type="application/x-sas-utility">
        <_comment>SAS Utility</_comment>
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Oct 16 07:46:32 UTC 2025
    - 320.2K bytes
    - Viewed (5)
Back to top