- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 3,704 for jailed (0.18 sec)
-
src/runtime/netpoll_solaris.go
} var portfd int32 = -1 func netpollinit() { portfd = port_create() if portfd >= 0 { closeonexec(portfd) return } print("runtime: port_create failed (errno=", errno(), ")\n") throw("runtime: netpollinit failed") } func netpollIsPollDescriptor(fd uintptr) bool { return fd == uintptr(portfd) } func netpollopen(fd uintptr, pd *pollDesc) int32 { lock(&pd.lock)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 11.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go
key := computePodKey(input) if err := store.Create(ctx, key, input, out, 1); err != nil { t.Fatalf("Create failed: %v", err) } w, err := store.Watch(ctx, key, storage.ListOptions{ResourceVersion: out.ResourceVersion, Predicate: storage.Everything}) if err != nil { t.Fatalf("Watch failed: %v", err) } testCheckEventType(t, w, watch.Deleted) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 91.4K bytes - Viewed (0) -
pilot/test/xds/fake.go
if err != nil { t.Fatalf("failed parsing KubernetesObjectString: %v", err) } objects[opts.DefaultClusterName] = append(objects[opts.DefaultClusterName], parsed...) } for k8sCluster, objectStr := range opts.KubernetesObjectStringByCluster { parsed, err := kubernetesObjectsFromString(objectStr) if err != nil { t.Fatalf("failed parsing KubernetesObjectStringByCluster for %s: %v", k8sCluster, err)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
if openNetns == nil { log.Warn("failed to find pod netns during removal") return fmt.Errorf("failed to find pod netns during removal") } // pod is removed from the mesh, but is still running. remove iptables rules log.Debugf("calling DeleteInpodRules.") if err := s.netnsRunner(openNetns, func() error { return s.iptablesConfigurator.DeleteInpodRules() }); err != nil { log.Errorf("failed to delete inpod rules %v", err)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 13.4K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
klog.Error(log("registrationHandler.RegisterPlugin failed to unregister plugin due to previous error: %v", unregErr)) } return err } err = nim.InstallCSIDriver(pluginName, driverNodeID, maxVolumePerNode, accessibleTopology) if err != nil { if unregErr := unregisterDriver(pluginName); unregErr != nil { klog.Error(log("registrationHandler.RegisterPlugin failed to unregister plugin due to previous error: %v", unregErr))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/cmd/server/testing/testserver.go
if ok && err != nil { klog.Errorf("Failed to shutdown test server clearly: %v", err) } } if len(result.TmpDir) != 0 { os.RemoveAll(result.TmpDir) } } defer func() { if result.TearDownFn == nil { tearDown() } }() result.TmpDir, err = os.MkdirTemp("", "apiextensions-apiserver") if err != nil { return result, fmt.Errorf("failed to create temp dir: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 9K bytes - Viewed (1) -
pkg/proxy/iptables/proxier.go
proxier.Sync() } } // OnServiceDelete is called whenever deletion of an existing service // object is observed. func (proxier *Proxier) OnServiceDelete(service *v1.Service) { proxier.OnServiceUpdate(service, nil) } // OnServiceSynced is called once all the initial event handlers were // called and the state is fully propagated to local cache. func (proxier *Proxier) OnServiceSynced() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
src/testing/testing.go
} // Fail marks the function as having failed but continues execution. func (c *common) Fail() { if c.parent != nil { c.parent.Fail() } c.mu.Lock() defer c.mu.Unlock() // c.done needs to be locked to synchronize checks to c.done in parent tests. if c.done { panic("Fail in goroutine after " + c.name + " has completed") } c.failed = true } // Failed reports whether the function has failed.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 76.1K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/ForwardingWrapperTester.java
throw new RuntimeException(e); } catch (InvocationTargetException e) { throw Throwables.propagate(e.getCause()); } assertEquals("Failed to forward to " + method, 1, called.get()); } @Override public String toString() { return "dummy " + interfaceType.getSimpleName(); } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 08 17:31:55 UTC 2024 - 9.1K bytes - Viewed (0) -
pkg/serviceaccount/jwt.go
} // Validator is called by the JWT token authenticator to apply domain specific // validation to a token and extract user information. type Validator interface { // Validate validates a token and returns user information or an error. // Validator can assume that the issuer and signature of a token are already // verified when this function is called.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 22:16:08 UTC 2024 - 10.7K bytes - Viewed (0)