Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 101 for coroutines (0.05 sec)

  1. CHANGELOG/CHANGELOG-1.17.md

    ### Other (Bug, Cleanup or Flake)
    
    - Add delays between goroutines for vm instance update ([#88094](https://github.com/kubernetes/kubernetes/pull/88094), [@aramase](https://github.com/aramase)) [SIG Cloud Provider]
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Thu Jan 28 10:44:33 UTC 2021
    - 346.2K bytes
    - Viewed (1)
  2. cmd/metrics-v3-system-process.go

    	processCPUTotalSecondsMD          = NewCounterMD(processCPUTotalSeconds, "Total user and system CPU time spent in seconds")
    	processGoRoutineTotalMD           = NewGaugeMD(processGoRoutineTotal, "Total number of go routines running")
    	processIORCharBytesMD             = NewCounterMD(processIORCharBytes, "Total bytes read by the process from the underlying storage system including cache, /proc/[pid]/io rchar")
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Jun 20 17:55:03 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  3. cmd/admin-handlers_test.go

    	}
    
    	result := &serviceResult{}
    	if err := json.Unmarshal(resp, result); err != nil {
    		t.Error(err)
    	}
    	_ = result
    
    	// Wait until testServiceSignalReceiver() called in a goroutine quits.
    	wg.Wait()
    }
    
    // Test for service restart management REST API.
    func TestServiceRestartHandler(t *testing.T) {
    	testServicesCmdHandler(restartCmd, t)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (1)
  4. src/main/java/jcifs/netbios/Name.java

         */
        public String scope;
        /**
         * Type
         */
        public int hexCode;
        int srcHashCode; /*
                          * srcHashCode must be set by name resolution
                          * routines before entry into addressCache
                          */
        private final Configuration config;
    
        Name(final Configuration cfg) {
            this.config = cfg;
        }
    
        /**
         * @return the name
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 8K bytes
    - Viewed (0)
  5. tensorflow/c/c_api_experimental.cc

      // CPU tensor to GPU).
      // Setting a larger thread pool does not help with the Swift caller, as we use
      // a different TFE context for each thread of execution (for running graph
      // functions, and their send/recvs corountines).
      config.set_inter_op_parallelism_threads(1);
    
      TF_Buffer* ret = TF_NewBuffer();
      TF_CHECK_OK(MessageToBuffer(config, ret));
      return ret;
    }
    
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Mon Aug 18 03:53:25 UTC 2025
    - 29.5K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb1/netbios/Name.java

        public String scope;
        /** The NetBIOS name type/suffix (hexadecimal code) */
        public int hexCode;
        int srcHashCode; /* srcHashCode must be set by name resolution
                          * routines before entry into addressCache
                          */
    
        Name() {
        }
    
        /**
         * Creates a NetBIOS name with the specified attributes.
         *
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  7. cmd/batch-expire.go

    				cancelCause(err)
    				xioutil.SafeClose(results)
    				return
    			}
    			for result := range prefixResultCh {
    				results <- result
    			}
    		}
    		xioutil.SafeClose(results)
    	}()
    
    	// Goroutine to periodically save batch-expire job's in-memory state
    	saverQuitCh := make(chan struct{})
    	go func() {
    		saveTicker := time.NewTicker(10 * time.Second)
    		defer saveTicker.Stop()
    		quit := false
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Apr 22 11:16:32 UTC 2025
    - 23K bytes
    - Viewed (0)
  8. cmd/data-scanner_test.go

    		LockEnabled: true,
    	}
    
    	expiryWorker := func(wg *sync.WaitGroup, readyCh chan<- struct{}, taskCh <-chan expiryOp, gotExpired *[]ObjectToDelete) {
    		defer wg.Done()
    		// signal the calling goroutine that the worker is ready tor receive tasks
    		close(readyCh)
    		var expired []ObjectToDelete
    		for t := range taskCh {
    			switch v := t.(type) {
    			case noncurrentVersionsTask:
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  9. cmd/bucket-metadata-sys.go

    				"load-bucket-metadata-"+buckets[index], logger.WarningKind)
    		}
    	}
    
    	// Hold lock here to update in-memory map at once,
    	// instead of serializing the Go routines.
    	sys.Lock()
    	for i, meta := range bucketMetas {
    		if errs[i] != nil {
    			continue
    		}
    		sys.metadataMap[buckets[i]] = meta
    	}
    	sys.Unlock()
    
    	for i, meta := range bucketMetas {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  10. doc/asm.html

    </p>
    
    <h3 id="arm">ARM</h3>
    
    <p>
    The registers <code>R10</code> and <code>R11</code>
    are reserved by the compiler and linker.
    </p>
    
    <p>
    <code>R10</code> points to the <code>g</code> (goroutine) structure.
    Within assembler source code, this pointer must be referred to as <code>g</code>;
    the name <code>R10</code> is not recognized.
    </p>
    
    <p>
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Nov 28 19:15:27 UTC 2023
    - 36.3K bytes
    - Viewed (0)
Back to top