Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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)
  2. 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)
  3. 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)
  4. 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 (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. cmd/sftp-server-driver.go

    }
    
    func (f *sftpDriver) Filewrite(r *sftp.Request) (w io.WriterAt, err error) {
    	stopFn := globalSftpMetrics.log(r, f.AccessKey())
    	defer func() {
    		if err != nil {
    			// If there is an error, we never started the goroutine.
    			stopFn(0, err)
    		}
    	}()
    
    	flags := r.Pflags()
    	if !flags.Write {
    		// sanity check
    		return nil, os.ErrInvalid
    	}
    
    	bucket, object := path2BucketObject(r.Filepath)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Feb 10 16:35:49 UTC 2025
    - 11.6K bytes
    - Viewed (0)
Back to top