Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 444 for wait4 (0.04 sec)

  1. src/os/exec.go

    	return p.kill()
    }
    
    // Wait waits for the [Process] to exit, and then returns a
    // ProcessState describing its status and an error, if any.
    // Wait releases any resources associated with the Process.
    // On most operating systems, the Process must be a child
    // of the current process or an error will be returned.
    func (p *Process) Wait() (*ProcessState, error) {
    	return p.wait()
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 22:06:47 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  2. src/cmd/vendor/golang.org/x/telemetry/start.go

    // A StartResult is a handle to the result of a call to [Start]. Call
    // [StartResult.Wait] to wait for the completion of all work done on behalf of
    // Start.
    type StartResult struct {
    	wg sync.WaitGroup
    }
    
    // Wait waits for the completion of all work initiated by [Start].
    func (res *StartResult) Wait() {
    	if res == nil {
    		return
    	}
    	res.wg.Wait()
    }
    
    var daemonize = func(cmd *exec.Cmd) {}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 14:52:56 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  3. src/runtime/sema.go

    			// more costly than contention holding up a single goroutine.
    			// It would take O(N) time to calculate how long each goroutine
    			// has been waiting, so instead we charge avg(head-wait, tail-wait)*N.
    			// head-wait is the longest wait and tail-wait is the shortest.
    			// (When we do a lifo insertion, we preserve this property by
    			// copying the old head's acquiretime into the inserted new head.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 19K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/MoreExecutors.java

      /**
       * Converts the given ThreadPoolExecutor into an ExecutorService that exits when the application
       * is complete. It does so by using daemon threads and adding a shutdown hook to wait for their
       * completion.
       *
       * <p>This method waits 120 seconds before continuing with JVM termination, even if the executor
       * has not finished its work.
       *
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 15 10:40:05 UTC 2024
    - 43.7K bytes
    - Viewed (0)
  5. cni/pkg/install/cniconfig.go

    	}
    
    	installLog.Infof("Created CNI config %s", cniConfigFilepath)
    	installLog.Debugf("CNI config: %s", pluginConfig)
    	return cniConfigFilepath, nil
    }
    
    // If configured as chained CNI plugin, waits indefinitely for a main CNI config file to exist before returning
    // Or until cancelled by parent context
    func getCNIConfigFilepath(ctx context.Context, cniConfName, mountedCNINetDir string, chained bool) (string, error) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 21 18:32:01 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  6. cmd/kubeadm/app/cmd/phases/join/kubelet.go

    	return nil
    }
    
    // waitForTLSBootstrappedClient waits for the /etc/kubernetes/kubelet.conf file to be available
    func waitForTLSBootstrappedClient(timeout time.Duration) error {
    	fmt.Println("[kubelet-start] Waiting for the kubelet to perform the TLS Bootstrap")
    
    	// Loop on every falsy return. Return with an error if raised. Exit successfully if true is returned.
    	return wait.PollUntilContextTimeout(context.Background(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 07:10:31 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  7. internal/ringbuffer/ring_buffer.go

    		r.writeCond.Broadcast()
    	}
    
    	// Unlock the mutex so readers/writers can finish.
    	r.mu.Unlock()
    	r.wg.Wait()
    	r.mu.Lock()
    	r.r = 0
    	r.w = 0
    	r.err = nil
    	r.isFull = false
    }
    
    // WriteCloser returns a WriteCloser that writes to the ring buffer.
    // When the returned WriteCloser is closed, it will wait for all data to be read before returning.
    func (r *RingBuffer) WriteCloser() io.WriteCloser {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

      }
    
      /**
       * Converts the given ThreadPoolExecutor into an ExecutorService that exits when the application
       * is complete. It does so by using daemon threads and adding a shutdown hook to wait for their
       * completion.
       *
       * <p>This method waits 120 seconds before continuing with JVM termination, even if the executor
       * has not finished its work.
       *
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 15 10:40:05 UTC 2024
    - 39K bytes
    - Viewed (0)
  9. cmd/batch-expire.go

    	if len(toDel) > 0 {
    		select {
    		case <-ctx.Done():
    		case expireCh <- toDel:
    		}
    	}
    	xioutil.SafeClose(expireCh)
    
    	<-expireDoneCh // waits for the expire goroutine to complete
    	wk.Wait()      // waits for all expire workers to retire
    
    	ri.Complete = !failed && ri.ObjectsFailed == 0
    	ri.Failed = failed || ri.ObjectsFailed > 0
    	globalBatchJobsMetrics.save(job.ID, ri)
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 11 13:50:53 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/TestThread.java

      /**
       * Asserts that a prior call that had caused this thread to block or wait has since returned
       * normally.
       */
      public void assertPriorCallReturns(@Nullable String methodName) throws Exception {
        assertEquals(null, getResponse(methodName).getResult());
      }
    
      /**
       * Asserts that a prior call that had caused this thread to block or wait has since returned the
       * expected boolean value.
       */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 10.8K bytes
    - Viewed (0)
Back to top