Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for interrupt (0.23 sec)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

      fun interruptCoordinatorThread() {
        taskRunner.assertThreadDoesntHoldLock()
        require(currentTask == TestThreadSerialTask)
    
        // Queue a task to interrupt the waiting coordinator.
        serialTaskQueue +=
          object : SerialTask {
            override fun start() {
              taskRunner.assertThreadHoldsLock()
              waitingCoordinatorInterrupted = true
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 12.6K bytes
    - Viewed (0)
  2. cni/pkg/cmd/root.go

    		if err = installer.Run(ctx); err != nil {
    			if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) {
    				log.Infof("installer complete: %v", err)
    				// Error was caused by interrupt/termination signal
    				err = nil
    			} else {
    				log.Errorf("installer failed: %v", err)
    			}
    		}
    
    		if cleanErr := installer.Cleanup(); cleanErr != nil {
    			if err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.5K bytes
    - Viewed (0)
  3. cmd/server-main.go

    	}
    	logger.EnableJSON()
    	return output, nil
    }
    
    // serverMain handler called for 'minio server' command.
    func serverMain(ctx *cli.Context) {
    	var warnings []string
    
    	signal.Notify(globalOSSignalCh, os.Interrupt, syscall.SIGTERM, syscall.SIGQUIT)
    
    	go handleSignals()
    
    	setDefaultProfilerRates()
    
    	// Initialize globalConsoleSys system
    	bootstrapTrace("newConsoleLogger", func() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 34.9K bytes
    - Viewed (1)
  4. cni/pkg/plugin/plugin_test.go

        },
        "log_level": "debug",
        "cni_event_address": "%s",
        "ambient_enabled": %t,
        "kubernetes": {
            "k8s_api_root": "APIRoot",
            "kubeconfig": "testK8sConfig",
    		"intercept_type": "%s",
            "node_name": "testNodeName",
            "exclude_namespaces": ["testExcludeNS"],
            "cni_bin_dir": "/testDirectory"
        }
    }`
    
    type mockInterceptRuleMgr struct {
    	lastRedirect []*Redirect
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 15:58:51 GMT 2024
    - 17.5K bytes
    - Viewed (0)
  5. cni/pkg/iptables/iptables.go

    	iptablesBuilder.AppendRule(
    		iptableslog.UndefinedCommand, ChainInpodOutput, iptablesconstants.NAT,
    		"-d", hostProbeSNAT.String(),
    		"-p", "tcp",
    		"-m", "tcp",
    		"-j", "ACCEPT",
    	)
    
    	// prevent intercept traffic from app ==> app by pod ip
    	iptablesBuilder.AppendVersionedRule("127.0.0.1/32", "::1/128",
    		iptableslog.UndefinedCommand, ChainInpodPrerouting, iptablesconstants.MANGLE,
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue May 07 19:54:50 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  6. doc/go_spec.html

    SimpleStmt = EmptyStmt | ExpressionStmt | SendStmt | IncDecStmt | Assignment | ShortVarDecl .
    </pre>
    
    <h3 id="Terminating_statements">Terminating statements</h3>
    
    <p>
    A <i>terminating statement</i> interrupts the regular flow of control in
    a <a href="#Blocks">block</a>. The following statements are terminating:
    </p>
    
    <ol>
    <li>
    	A <a href="#Return_statements">"return"</a> or
    HTML
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Thu May 02 22:43:51 GMT 2024
    - 279.6K bytes
    - Viewed (0)
Back to top