Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 186 for stopped_ (0.19 sec)

  1. staging/src/k8s.io/apimachinery/pkg/watch/watch_test.go

    			}
    			if a, ok := got.Object.(testType); !ok || a != expect.s {
    				t.Fatalf("Expected %v, got %v", expect.s, a)
    			}
    		}
    		_, stillOpen := <-w.ResultChan()
    		if stillOpen {
    			t.Fatal("Never stopped")
    		}
    	}
    
    	sender := func() {
    		f.Add(testType("foo"))
    		f.Action(Modified, testType("qux"))
    		f.Modify(testType("bar"))
    		f.Delete(testType("bar"))
    		f.Error(testType("error: blah"))
    		f.Stop()
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 15 11:34:31 UTC 2018
    - 3.7K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. src/time/sleep.go

    // Before Go 1.23, the garbage collector did not recover
    // timers that had not yet expired or been stopped, so code often
    // immediately deferred t.Stop after calling NewTimer, to make
    // the timer recoverable when it was no longer needed.
    // As of Go 1.23, the garbage collector can recover unreferenced
    // timers, even if they haven't expired or been stopped.
    // The Stop method is no longer necessary to help the garbage collector.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 04 14:21:30 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  7. subprojects/core/src/main/java/org/gradle/api/internal/component/UsageContext.java

        @Deprecated
        default Usage getUsage(){
            // This method kept for backwards compatibility of plugins (like kotlin-multiplatform) using internal APIs.
            // KMP has recently stopped using this method, so we should be able to remove it
            throw new UnsupportedOperationException("This method has been deprecated and should never be called");
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Jan 04 19:31:46 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java

            } catch (final ContainerNotAvailableException e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("ThumbnailGenerator is stopped.", e);
                } else if (logger.isInfoEnabled()) {
                    logger.info("ThumbnailGenerator is stopped.");
                }
                exitCode = Constants.EXIT_FAIL;
            } catch (final Throwable t) {
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/base/Stopwatch.java

       */
      @CanIgnoreReturnValue
      public Stopwatch stop() {
        long tick = ticker.read();
        checkState(isRunning, "This stopwatch is already stopped.");
        isRunning = false;
        elapsedNanos += tick - startTick;
        return this;
      }
    
      /**
       * Sets the elapsed time for this stopwatch to zero, and places it in a stopped state.
       *
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Nov 15 21:38:09 UTC 2022
    - 8.5K bytes
    - Viewed (0)
  10. platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/testing/DaemonEventSequenceBuilder.groovy

            state(busy, numDaemons - busy)
        }
    
        void idle() {
            idle(numDaemons)
        }
    
        void idle(int idle) {
            state(numDaemons - idle, idle)
        }
    
        void stopped() {
            numDaemons = 0
            state(0, 0)
        }
    
        void state(int busy, int idle) {
            state(new DaemonsState(busy, idle))
        }
    
        void state(DaemonsState checkpointState) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:29:13 UTC 2023
    - 2.3K bytes
    - Viewed (0)
Back to top