- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 7,747 for jailed (0.14 sec)
-
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel.go
conn net.Conn // mu guards writes mu sync.Mutex // wrote tracks whether WriteHeader or Write has been called written bool // hijacked tracks whether Hijack has been called hijacked bool } // Hijack returns a delegate "net.Conn". // An error is returned if Write(), WriteHeader(), or Hijack() was previously called. // The returned bufio.ReadWriter is always nil.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.7K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/actual_state_of_world_test.go
if exists { t.Fatalf("AddVolumeNode_Positive_NewVolumeNewNodeWithFalseAttached failed. Actual: <node %q exist> Expect: <node does not exist in the reportedAsAttached map", nodeName) } nodes := asw.GetNodesForAttachedVolume(volumeName) if len(nodes) > 0 { t.Fatalf("AddVolumeNode_Positive_NewVolumeNewNodeWithFalseAttached failed. Expect no nodes returned.") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 07:35:17 UTC 2024 - 66.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/util.go
result := map[string]string{ "name": "stripVersion", } if e != nil { result["encoder"] = string(e.Identifier()) } identifier, err := json.Marshal(result) if err != nil { klog.Fatalf("Failed marshaling identifier for stripVersionEncoder: %v", err) } return runtime.Identifier(identifier) } func (c stripVersionEncoder) Encode(obj runtime.Object, w io.Writer) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 16 11:54:27 UTC 2020 - 3.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source.go
utilruntime.HandleError(fmt.Errorf("failed to remove policy event handler: %w", err)) } }() bindingHandle, err := s.bindingInformer.AddEventHandler(notifyFuncs) if err != nil { return err } defer func() { if err := s.bindingInformer.RemoveEventHandler(bindingHandle); err != nil { utilruntime.HandleError(fmt.Errorf("failed to remove binding event handler: %w", err)) } }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 23:07:34 UTC 2024 - 15.2K bytes - Viewed (0) -
platforms/enterprise/enterprise-logging/src/main/java/org/gradle/internal/logging/progress/ProgressLogger.java
* * @param status The final status message. Can be null or empty. * @param failed Did the task fail? */ void completed(String status, boolean failed);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jul 17 10:17:11 UTC 2023 - 3.4K bytes - Viewed (0) -
pkg/controller/controller_ref_manager.go
// (such as a live GET from the API server) prior to the first adoption. // It will only be called (at most once) if an adoption is actually attempted. // If CanAdopt() returns a non-nil error, all adoptions will fail. // // NOTE: Once CanAdopt() is called, it will not be called again by the same // PodControllerRefManager instance. Create a new instance if it makes
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 12:57:29 UTC 2023 - 21.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceimportcache_test.go
retry.UntilSuccessOrFail(t, func() error { clusterLocalHost := ic.clusterLocalHost() if svc := c.GetService(clusterLocalHost); svc == nil { return fmt.Errorf("failed looking up service for host %s", clusterLocalHost) } var expectedHosts map[host.Name]struct{} if isImported { expectedHosts = map[host.Name]struct{}{ clusterLocalHost: {},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 15.2K bytes - Viewed (0) -
src/runtime/os_openbsd.go
func goenvs() { goenvs_unix() } // Called to initialize a new m (including the bootstrap m). // Called on the parent thread (main thread in case of bootstrap), can allocate memory. func mpreinit(mp *m) { gsignalSize := int32(32 * 1024) if GOARCH == "mips64" { gsignalSize = int32(64 * 1024) } mp.gsignal = malg(gsignalSize) mp.gsignal.m = mp } // Called to initialize a new m (including the bootstrap m).
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 6.2K bytes - Viewed (0) -
pkg/volume/flexvolume/common_test.go
executable := "/plugin/test" if goruntime.GOOS == "windows" { executable = "c:\\plugin\\test" } if cmd != executable { t.Errorf("Wrong executable called: got %v, expected %v", cmd, "/plugin/test") } if args[0] != expectedCommand { t.Errorf("Wrong command called: got %v, expected %v", args[0], expectedCommand) } cmdArgs := args[1:] if !sameArgs(cmdArgs, expectedArgs) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 01 15:56:32 UTC 2022 - 3.5K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/InsecureAndroidTrustManager.kt
@Suppress("unused", "UNCHECKED_CAST") fun checkServerTrusted( chain: Array<out X509Certificate>, authType: String, host: String, ): List<Certificate> { if (host in insecureHosts) return listOf() try { val method = checkServerTrustedMethod ?: throw CertificateException("Failed to call checkServerTrusted")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.4K bytes - Viewed (0)