Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 221 for Stopped (0.13 sec)

  1. subprojects/core/src/main/java/org/gradle/process/internal/worker/WorkerControl.java

        /**
         * Starts the worker process, blocking until successfully started.
         */
        WorkerProcess start();
    
        /**
         * Requests that the worker complete all work and stop. Blocks until the worker process has stopped.
         */
        ExecResult stop();
    
        /**
         * Requests that the worker stop immediately, without waiting for it to complete its work.
         */
        void stopNow();
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 30 19:54:37 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  2. samples/jwt-server/src/main.go

    		}
    	}
    
    	response.WriteHeader(http.StatusOK)
    	response.Write([]byte(string(jwtKey)))
    }
    
    func (s *JWTServer) startHTTP(address string, wg *sync.WaitGroup) {
    	defer func() {
    		wg.Done()
    		log.Printf("Stopped JWT HTTP server")
    	}()
    
    	listener, err := net.Listen("tcp", address)
    	if err != nil {
    		log.Fatalf("Failed to create HTTP server: %v", err)
    	}
    	// Store the port for test only.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 16 23:56:50 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  3. platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/Stoppable.java

     */
    public interface Stoppable {
        /**
         * <p>Requests a graceful stop of this object. Blocks until all concurrent activity has been completed.</p>
         *
         * <p>If this object has already been stopped, this method does nothing.</p>
         */
        void stop();
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 19:07:35 UTC 2024
    - 989 bytes
    - Viewed (0)
  4. src/cmd/compile/internal/base/timings.go

    					}
    					// events associated with stop replace prior events
    					if e := t.events[i]; e != nil {
    						events = e
    					}
    				}
    			} else {
    				// previous phase stopped
    				if qt.start {
    					// between a stopped and started phase; unaccounted time
    					unaccounted += dt
    				} else {
    					// previous stop implicitly started current phase
    					label = qt.label
    					events = t.events[i]
    				}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 14 00:03:57 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

          finalizeReferentCalled = true;
        }
      }
    
      /**
       * Keeps a weak reference to the underlying reference queue. When this reference is cleared, we
       * know that the background thread has stopped and released its strong reference.
       */
      private WeakReference<ReferenceQueue<Object>> queueReference;
    
    
      public void testThatFinalizerStops() {
        weaklyReferenceQueue();
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jun 10 19:21:11 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  6. pkg/scheduler/metrics/metric_recorder.go

    	interval time.Duration
    
    	// stopCh is used to stop the goroutine which periodically flushes metrics.
    	stopCh <-chan struct{}
    	// IsStoppedCh indicates whether the goroutine is stopped. It's used in tests only to make sure
    	// the metric flushing goroutine is stopped so that tests can collect metrics for verification.
    	IsStoppedCh chan struct{}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 16 07:27:08 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  7. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/DefaultFileLockContentionHandlerTest.groovy

            handler.start(11, {})
            handler.start(12, {})
    
            then:
            2 * factory.create(_ as String) >> Mock(ManagedExecutor)
        }
    
        def "cannot start contention handling when the handler was stopped"() {
            handler.stop()
    
            when:
            handler.start(10, {})
    
            then:
            thrown(IllegalStateException)
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:49 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  8. src/runtime/sys_wasm.go

    func wasmDiv()
    
    func wasmTruncS()
    func wasmTruncU()
    
    //go:wasmimport gojs runtime.wasmExit
    func wasmExit(code int32)
    
    // adjust Gobuf as it if executed a call to fn with context ctxt
    // and then stopped before the first instruction in fn.
    func gostartcall(buf *gobuf, fn, ctxt unsafe.Pointer) {
    	sp := buf.sp
    	sp -= goarch.PtrSize
    	*(*uintptr)(unsafe.Pointer(sp)) = buf.pc
    	buf.sp = sp
    	buf.pc = uintptr(fn)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 02 05:28:55 UTC 2023
    - 758 bytes
    - Viewed (0)
  9. pkg/kube/controllers/queue.go

    		// Process updates until we return false, which indicates the queue is terminated
    		for q.processNextItem() {
    		}
    		close(q.closed)
    	}()
    	select {
    	case <-stop:
    	case <-q.closed:
    	}
    	q.log.Infof("stopped")
    }
    
    // syncSignal defines a dummy signal that is enqueued when .Run() is called. This allows us to detect
    // when we have processed all items added to the queue prior to Run().
    type syncSignal struct{}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Aug 08 16:43:05 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  10. src/os/wait_waitid.go

    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    // We used to use this code for Darwin, but according to issue #19314
    // waitid returns if the process is stopped, even when using WEXITED.
    
    //go:build linux
    
    package os
    
    import (
    	"runtime"
    	"syscall"
    	"unsafe"
    )
    
    const _P_PID = 1
    
    // blockUntilWaitable attempts to block until a call to p.Wait will
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Aug 07 00:27:57 UTC 2023
    - 1.3K bytes
    - Viewed (0)
Back to top