Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 175 for signaled (0.05 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java

      // TODO: Test blocking to re-enter monitor after being signaled.
      // TODO: Test interrupts with both interruptible and uninterruptible monitor.
      // TODO: Test multiple waiters: If guard is still satisfied, signal next waiter.
      // TODO: Test multiple waiters: If guard is no longer satisfied, do not signal next waiter.
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 8K bytes
    - Viewed (0)
  2. cmd/admin-heal-ops.go

    }
    
    // traverseAndHeal - traverses on-disk data and performs healing
    // according to settings. At each "safe" point it also checks if an
    // external quit signal has been received and quits if so. Since the
    // healing traversal may be mutating on-disk data when an external
    // quit signal is received, this routine cannot quit immediately and
    // has to wait until a safe point is reached, such as between scanning
    // two objects.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

                + (throwable == null ? null : Throwables.getStackTraceAsString(throwable)),
            throwableFromOtherThread.get());
      }
    
      /**
       * Test for a bug where threads weren't getting signaled when shutdown was called, only when tasks
       * completed.
       */
      public void testDirectExecutorService_awaitTermination_missedSignal() {
        ExecutorService service = newDirectExecutorService();
        Thread waiter =
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 28K bytes
    - Viewed (0)
  4. cmd/signals.go

    			exit(stopProcess())
    		case osSignal := <-globalOSSignalCh:
    			logger.Info("Exiting on signal: %s", strings.ToUpper(osSignal.String()))
    			daemon.SdNotify(false, daemon.SdNotifyStopping)
    			exit(stopProcess())
    		case signal := <-globalServiceSignalCh:
    			switch signal {
    			case serviceRestart:
    				logger.Info("Restarting on service signal")
    				daemon.SdNotify(false, daemon.SdNotifyReloading)
    				stop := stopProcess()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Sep 04 17:02:39 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/Monitor.java

       * the monitor without signalling. If it timed out without being signalled, it does not need to
       * "pass on" the signal to another thread. If it *was* signalled, then its guard must have been
       * satisfied at the time of signal, and has since been modified by some other thread to be
       * non-satisfied before reacquiring the lock, and that other thread takes over the responsibility
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 42.8K bytes
    - Viewed (0)
  6. cmd/service.go

    package cmd
    
    import (
    	"context"
    	"os"
    	"os/exec"
    	"runtime"
    	"syscall"
    
    	xioutil "github.com/minio/minio/internal/ioutil"
    )
    
    // Type of service signals currently supported.
    type serviceSignal int
    
    const (
    	serviceRestart       serviceSignal = iota // Restarts the server.
    	serviceStop                               // Stops the server.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Feb 28 07:02:14 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  7. cmd/auth-handler_test.go

    		{
    			authT: authTypePresigned,
    			pass:  true,
    		},
    		// Test 3 - supported s3 type signed.
    		{
    			authT: authTypeSigned,
    			pass:  true,
    		},
    		// Test 4 - supported s3 type with post policy.
    		{
    			authT: authTypePostPolicy,
    			pass:  true,
    		},
    		// Test 5 - supported s3 type with streaming signed.
    		{
    			authT: authTypeStreamingSigned,
    			pass:  true,
    		},
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 15.4K bytes
    - Viewed (0)
  8. cmd/signature-v4-parser.go

    		return "", ErrMissingSignTag
    	}
    	if signFields[1] == "" {
    		return "", ErrMissingFields
    	}
    	signature := signFields[1]
    	return signature, ErrNone
    }
    
    // Parse slice of signed headers from signed headers tag.
    func parseSignedHeader(signedHdrElement string) ([]string, APIErrorCode) {
    	signedHdrFields := strings.Split(strings.TrimSpace(signedHdrElement), "=")
    	if len(signedHdrFields) != 2 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  9. okhttp-tls/src/main/kotlin/okhttp3/tls/HeldCertificate.kt

     *    they've confirmed that the owner of the private key is also the owner of the certificate's
     *    other properties.
     *
     * Certificates are signed by other certificates and a sequence of them is called a certificate
     * chain. The chain terminates in a self-signed "root" certificate. Signing certificates in the
     * middle of the chain are called "intermediates". Organizations that offer certificate signing are
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/tls/BasicCertificateChainCleaner.kt

          val toVerify = result[result.size - 1] as X509Certificate
    
          // If this cert has been signed by a trusted cert, use that. Add the trusted certificate to
          // the end of the chain unless it's already present. (That would happen if the first
          // certificate in the chain is itself a self-signed and trusted CA certificate.)
          val trustedCert = trustRootIndex.findByIssuerAndSignature(toVerify)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 4.8K bytes
    - Viewed (0)
Back to top