Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 115 for signal (0.04 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt

      }
    
      /** Used by [Call.execute] to signal it is in-flight. */
      @Synchronized
      internal fun executed(call: RealCall) = runningSyncCalls.add(call)
    
      /** Used by [AsyncCall.run] to signal completion. */
      internal fun finished(call: AsyncCall) {
        call.callsPerHost.decrementAndGet()
        finished(runningAsyncCalls, call)
      }
    
      /** Used by [Call.execute] to signal completion. */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 8.7K 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. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

     */
    @NullUnmarked
    public class UninterruptiblesTest extends TestCase {
      private static final String EXPECTED_TAKE = "expectedTake";
    
      /** Timeout to use when we don't expect the timeout to expire. */
      private static final long LONG_DELAY_MS = 2500;
    
      private static final long SLEEP_SLACK = 2;
    
      private final TearDownStack tearDownStack = new TearDownStack();
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 31.7K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt

                labelIndex,
              )
            if (rule != null) {
              exception = rule
              break
            }
          }
        }
    
        if (exception != null) {
          // Signal we've identified an exception rule.
          exception = "!$exception"
          return exception.split('.')
        } else if (exactMatch == null && wildcardMatch == null) {
          return PREVAILING_RULE
        }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 28 07:33:49 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/ExchangeCodec.kt

      fun writeRequestHeaders(request: Request)
    
      /** Flush the request to the underlying socket. */
      @Throws(IOException::class)
      fun flushRequest()
    
      /** Flush the request to the underlying socket and signal no more bytes will be transmitted. */
      @Throws(IOException::class)
      fun finishRequest()
    
      /**
       * Parses bytes of a response header from an HTTP transport.
       *
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jul 29 21:11:09 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  6. cmd/leak-detect_test.go

    	"created by runtime.gc",
    	// ignore the snapshot function.
    	// since the snapshot is taken here the entry will have the current function too.
    	"pickRelevantGoroutines",
    	"runtime.MHeap_Scavenger",
    	"signal.signal_recv",
    	"sigterm.handler",
    	"runtime_mcall",
    	"goroutine in C code",
    }
    
    // Identify whether the stack trace entry is part of ignoredStackFn .
    func isIgnoredStackFn(stack string) (ok bool) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  7. cmd/admin-handlers.go

    		}
    	}
    
    	prs, ok := peerResults[local]
    	if ok {
    		prs.WaitingDrives = waitingDrivesNode()
    		peerResults[local] = prs
    	}
    
    	if globalIsDistErasure {
    		// Notify all other MinIO peers signal service.
    		startTime := time.Now().Add(restartUpdateDelay)
    		ng := WithNPeers(len(globalNotificationSys.peerClients))
    		for idx, client := range globalNotificationSys.peerClients {
    			if failedClients[idx] {
    				continue
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  8. cmd/admin-handlers_test.go

    	case stopCmd:
    		return madmin.ServiceActionStop
    	}
    	return madmin.ServiceActionRestart
    }
    
    // testServiceSignalReceiver - Helper function that simulates a
    // go-routine waiting on service signal.
    func testServiceSignalReceiver(cmd cmdType, t *testing.T) {
    	expectedCmd := cmd.toServiceSignal()
    	serviceCmd := <-globalServiceSignalCh
    	if serviceCmd != expectedCmd {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (1)
  9. cmd/data-scanner_test.go

    		Validity:    12 * time.Hour,
    		LockEnabled: true,
    	}
    
    	expiryWorker := func(wg *sync.WaitGroup, readyCh chan<- struct{}, taskCh <-chan expiryOp, gotExpired *[]ObjectToDelete) {
    		defer wg.Done()
    		// signal the calling goroutine that the worker is ready tor receive tasks
    		close(readyCh)
    		var expired []ObjectToDelete
    		for t := range taskCh {
    			switch v := t.(type) {
    			case noncurrentVersionsTask:
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  10. src/archive/tar/strconv.go

    		return strconv.FormatInt(secs, 10)
    	}
    
    	// If seconds is negative, then perform correction.
    	sign := ""
    	if secs < 0 {
    		sign = "-"             // Remember sign
    		secs = -(secs + 1)     // Add a second to secs
    		nsecs = -(nsecs - 1e9) // Take that second away from nsecs
    	}
    	return strings.TrimRight(fmt.Sprintf("%s%d.%09d", sign, secs, nsecs), "0")
    }
    
    // parsePAXRecord parses the input PAX record string into a key-value pair.
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon Sep 08 17:08:20 UTC 2025
    - 9.1K bytes
    - Viewed (0)
Back to top