- Sort Score
- Result 10 results
- Languages All
Results 11 - 19 of 19 for IMMEDIATE (0.25 sec)
-
pilot/pkg/networking/core/listener.go
plaintextHTTPALPNs = func() []string { if features.HTTP10 { // If HTTP 1.0 is enabled, we will match it return []string{"http/1.0", "http/1.1", "h2c"} } // Otherwise, matching would just lead to immediate rejection. By not matching, we can let it pass // through as raw TCP at least. // NOTE: mtlsHTTPALPNs can always include 1.0, for simplicity, as it will only be sent if a client return []string{"http/1.1", "h2c"} }()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 55.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
} c.watcherIdx++ }() if !addedWatcher { // Watcher isn't really started at this point, so it's safe to just drop it. // // We're simulating the immediate watch termination, which boils down to simply // closing the watcher. return newImmediateCloseWatcher(), nil } go watcher.processInterval(ctx, cacheInterval, requiredResourceVersion) return watcher, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
pkg/apis/storage/validation/validation_test.go
shouldSucceed bool } func TestValidateVolumeBindingMode(t *testing.T) { cases := map[string]bindingTest{ "no mode": { class: makeClass(nil, nil), shouldSucceed: false, }, "immediate mode": { class: makeClass(&immediateMode1, nil), shouldSucceed: true, }, "waiting mode": { class: makeClass(&waitingMode, nil), shouldSucceed: true, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 69.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractFuture.java
checkNotNull(executor, "Executor was null."); // Checking isDone and listeners != TOMBSTONE may seem redundant, but our contract for // addListener says that listeners execute 'immediate' if the future isDone(). However, our // protocol for completing a future is to assign the value field (which sets isDone to true) and
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 62.8K bytes - Viewed (1) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
checkNotNull(executor, "Executor was null."); // Checking isDone and listeners != TOMBSTONE may seem redundant, but our contract for // addListener says that listeners execute 'immediate' if the future isDone(). However, our // protocol for completing a future is to assign the value field (which sets isDone to true) and
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 63.1K bytes - Viewed (1) -
src/internal/trace/order.go
} // makeSeq creates a new seqCounter. func makeSeq(gen, seq uint64) seqCounter { return seqCounter{gen: gen, seq: seq} } // succeeds returns true if a is the immediate successor of b. func (a seqCounter) succeeds(b seqCounter) bool { return a.gen == b.gen && a.seq == b.seq+1 } // String returns a debug string representation of the seqCounter.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 52.4K bytes - Viewed (0) -
cmd/erasure-object.go
index := index g.Go(func() error { if disks[index] == nil { return nil } return disks[index].Delete(ctx, bucket, prefix, DeleteOptions{ Recursive: true, Immediate: true, }) }, index) } // return errors if any during deletion return reduceWriteQuorumErrs(ctx, g.Wait(), objectOpIgnoredErrs, writeQuorum) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 78.6K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
// Delay the Job sync when no generation change to batch Job status updates, // typically triggered by pod events. jm.enqueueSyncJobBatched(logger, curJob) } else { // Trigger immediate sync when spec is changed. jm.enqueueSyncJobImmediately(logger, curJob) } // The job shouldn't be marked as finished until all pod finalizers are removed. // This is a backup operation in this case.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
src/cmd/link/internal/ld/lib.go
argv = append(argv, "-shared") } } var altLinker string if ctxt.IsELF && (ctxt.DynlinkingGo() || *flagBindNow) { // For ELF targets, when producing dynamically linked Go code // or when immediate binding is explicitly requested, // we force all symbol resolution to be done at program startup // because lazy PLT resolution can use large amounts of stack at // times we cannot allow it to do so.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 18:45:27 UTC 2024 - 88.6K bytes - Viewed (0)