- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 175 for Cur (0.02 sec)
-
android/guava/src/com/google/common/collect/ImmutableSortedSet.java
checkElementsNotNull(contents, n); Arrays.sort(contents, 0, n, comparator); int uniques = 1; for (int i = 1; i < n; i++) { E cur = contents[i]; E prev = contents[uniques - 1]; if (comparator.compare(cur, prev) != 0) { contents[uniques++] = cur; } } Arrays.fill(contents, uniques, n, null); if (uniques < contents.length / 2) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sun Jun 02 13:36:19 UTC 2024 - 36.8K bytes - Viewed (0) -
src/syscall/syscall_linux_test.go
origLimit := syscall.OrigRlimitNofile() origRlimitNofile := syscall.GetInternalOrigRlimitNofile() if origLimit == nil { defer origRlimitNofile.Store(origLimit) origRlimitNofile.Store(&syscall.Rlimit{ Cur: 1024, Max: 65536, }) } // Get current process's nofile limit var lim syscall.Rlimit if err := syscall.Prlimit(0, syscall.RLIMIT_NOFILE, nil, &lim); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 23K bytes - Viewed (0) -
src/syscall/ztypes_linux_amd64.go
Minflt int64 Majflt int64 Nswap int64 Inblock int64 Oublock int64 Msgsnd int64 Msgrcv int64 Nsignals int64 Nvcsw int64 Nivcsw int64 } type Rlimit struct { Cur uint64 Max uint64 } type _Gid_t uint32 type Stat_t struct { Dev uint64 Ino uint64 Nlink uint64 Mode uint32 Uid uint32 Gid uint32
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 08 17:55:49 UTC 2023 - 12K bytes - Viewed (0) -
pkg/controller/daemon/update_test.go
} func currentDSHash(dsc *daemonSetsController, ds *apps.DaemonSet) (string, error) { // Construct histories of the DaemonSet, and get the hash of current history cur, _, err := dsc.constructHistory(context.TODO(), ds) if err != nil { return "", err } return cur.Labels[apps.DefaultDaemonSetUniqueLabelKey], nil } func TestDaemonSetUpdatesNoTemplateChanged(t *testing.T) { _, ctx := ktesting.NewTestContext(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 10 21:10:35 UTC 2024 - 28.9K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFile.java
cr.setShareAccess(shareAccess); ServerMessageBlock2Request<?> cur = cr; if ( first != null ) { cr.chain(first); cur = first; for ( ServerMessageBlock2Request<?> req : others ) { cur.chain(req); cur = req; } }
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Thu May 23 01:50:13 UTC 2024 - 82.3K bytes - Viewed (1) -
src/context/context.go
// not set the cause. func WithDeadlineCause(parent Context, d time.Time, cause error) (Context, CancelFunc) { if parent == nil { panic("cannot create context from nil parent") } if cur, ok := parent.Deadline(); ok && cur.Before(d) { // The current deadline is already sooner than the new one. return WithCancel(parent) } c := &timerCtx{ deadline: d, } c.cancelCtx.propagateCancel(parent, c)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 23.7K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbSessionImpl.java
catch ( CIFSException e ) { throw SmbException.wrap(e); } } boolean isSignatureSetupRequired () throws SmbException { SMBSigningDigest cur = getDigest(); if ( cur != null ) { return false; } else if ( this.transport.isSigningEnforced() ) { return true; }
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Nov 14 17:41:04 UTC 2021 - 49K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
// When a pod is updated, figure out what job/s manage it and wake them up. // If the labels of the pod have changed we need to awaken both the old // and new job. old and cur must be *v1.Pod types. func (jm *Controller) updatePod(logger klog.Logger, old, cur interface{}) { curPod := cur.(*v1.Pod) oldPod := old.(*v1.Pod) recordFinishedPodWithTrackingFinalizer(oldPod, curPod) if curPod.ResourceVersion == oldPod.ResourceVersion {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/kube/inject/inject.go
} targetPort := strconv.Itoa(int(req.meshConfig.GetDefaultConfig().GetStatusPort())) if cur, f := getPrometheusPort(pod); f { // We have already set the port, assume user is controlling this or, more likely, re-injected // the pod. if cur == targetPort { clearPrometheusAnnotations(pod) } } delete(pod.Annotations, annotation.SidecarStatus.Name) return pod }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 20:35:11 UTC 2024 - 28.8K bytes - Viewed (1) -
pilot/pkg/networking/core/listener.go
// resolution type, since we collapse all HTTP listeners into a // single 0.0.0.0:port listener and use vhosts to distinguish // individual http services in that port if cur, exists := listenerMap[listenerMapKey]; exists { currentListenerEntry = cur // NOTE: This is not a conflict. This is simply filtering the // services for a given listener explicitly. // When the user declares their own ports in Sidecar.egress
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 55.1K bytes - Viewed (0)