Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 466 for blocked (0.14 sec)

  1. src/runtime/cgo/gcc_netbsd.c

    	// a bit baroque to remove a signal stack here only to add one
    	// in minit, but it's a simple change that keeps NetBSD
    	// working like other OS's. At this point all signals are
    	// blocked, so there is no race.
    	memset(&ss, 0, sizeof ss);
    	ss.ss_flags = SS_DISABLE;
    	sigaltstack(&ss, nil);
    
    	crosscall1(ts.fn, setg_gcc, ts.g);
    	return nil;
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Aug 15 03:55:51 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  2. testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/TrackingHttpHandler.java

         */
        WaitPrecondition getWaitPrecondition();
    
        /**
         * Releases any blocked requests, in preparation for shutdown.
         */
        void cancelBlockedRequests();
    
        /**
         * Asserts that this handler has been completed successfully.
         */
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  3. src/crypto/rand/rand_plan9.go

    		r.mu.Unlock()
    		return 0, err
    	}
    	var (
    		counter uint64
    		block   [aes.BlockSize]byte
    	)
    	inc := func() {
    		counter++
    		if counter == 0 {
    			panic("crypto/rand counter wrapped")
    		}
    		byteorder.LePutUint64(block[:], counter)
    	}
    	blockCipher.Encrypt(r.key[:aes.BlockSize], block[:])
    	inc()
    	blockCipher.Encrypt(r.key[aes.BlockSize:], block[:])
    	inc()
    	r.mu.Unlock()
    
    	n = len(b)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 13 18:57:38 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  4. subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MultithreadedTestRule.java

                    setState(State.Blocking, State.Blocked);
                    waitForState(State.Unblocked, State.Failed);
                } catch (InterruptedException e) {
                    throw UncheckedException.throwAsUncheckedException(e);
                }
            }
    
            public void expectUnblocks(Closure action) {
                try {
                    waitForState(State.Blocked);
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Oct 05 19:36:14 UTC 2023
    - 23.3K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      private static final long SMALL_TIMEOUT_MILLIS = 10;
    
      /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */
      private static final long EXPECTED_HANG_DELAY_MILLIS = 75;
    
      /**
       * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked.
       */
      private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000;
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  6. src/sync/mutex.go

    // relation at all.
    //
    // [the Go memory model]: https://go.dev/ref/mem
    type Mutex struct {
    	state int32
    	sema  uint32
    }
    
    // A Locker represents an object that can be locked and unlocked.
    type Locker interface {
    	Lock()
    	Unlock()
    }
    
    const (
    	mutexLocked = 1 << iota // mutex is locked
    	mutexWoken
    	mutexStarving
    	mutexWaiterShift = iota
    
    	// Mutex fairness.
    	//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  7. src/internal/trace/oldtrace.go

    		// blocked.
    		blocked := false
    		it.events.All()(func(nev *oldtrace.Event) bool {
    			if nev.G != ev.G {
    				return true
    			}
    			// After an EvGoSysCall, the next event on the same G will either be
    			// EvGoSysBlock to denote a blocking syscall, or some other event
    			// (or the end of the trace) if the syscall didn't block.
    			if nev.Type == oldtrace.EvGoSysBlock {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      private static final long SMALL_TIMEOUT_MILLIS = 10;
    
      /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */
      private static final long EXPECTED_HANG_DELAY_MILLIS = 75;
    
      /**
       * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked.
       */
      private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000;
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  9. src/sync/rwmutex.go

    	return r < 0 && r+rwmutexMaxReaders > 0
    }
    
    // RLocker returns a [Locker] interface that implements
    // the [RWMutex.Lock] and [RWMutex.Unlock] methods by calling rw.RLock and rw.RUnlock.
    func (rw *RWMutex) RLocker() Locker {
    	return (*rlocker)(rw)
    }
    
    type rlocker RWMutex
    
    func (r *rlocker) Lock()   { (*RWMutex)(r).RLock() }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  10. tests/integration/helm/install_test.go

    			framework.
    				NewTest(t).
    				Run(setupInstallation(ambientProfileOverride, true, tt.nsConfig, ""))
    		})
    	}
    }
    
    // TestReleaseChannels tests that non-stable CRDs and fields get blocked
    // by the default ValidatingAdmissionPolicy
    func TestReleaseChannels(t *testing.T) {
    	overrideValuesStr := `
    global:
      hub: %s
      tag: %s
      variant: %q
    profile: stable
    `
    
    	framework.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 09 19:04:51 UTC 2024
    - 7.7K bytes
    - Viewed (0)
Back to top