- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for interrupt (0.23 sec)
-
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) -
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) -
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) -
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) -
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) -
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)