- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 201 for IMMEDIATE (0.3 sec)
-
pkg/envoy/proxy_test.go
} got := test.args("test.json", "testdata/bootstrap.json") want := []string{ "-c", "test.json", "--drain-time-s", "45", "--drain-strategy", "immediate", "--local-address-ip-version", "v4", "--file-flush-interval-msec", "1000", "--disable-hot-restart", "--allow-unknown-static-fields", "-l", "trace", "--component-log-level", "misc:error",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 11:45:51 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/kubelet/prober/prober_manager.go
} else { // The check whether there is a probe which hasn't run yet. w, exists := m.getWorker(pod.UID, c.Name, readiness) ready = !exists // no readinessProbe -> always ready if exists { // Trigger an immediate run of the readinessProbe to update ready state select { case w.manualTriggerCh <- struct{}{}: default: // Non-blocking. klog.InfoS("Failed to trigger a manual run", "probe", w.probeType.String()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 11K bytes - Viewed (0) -
pkg/test/loadbalancersim/timer/queue.go
q.mutex.Unlock() q.timer.Stop() } func (q *Queue) resetTimer() { // Below is a separate function to limit the scope of the lock. // We don't want to lock when we modify the timer in case it causes // an immediate callback, which would reacquire the lock. needReset, resetDuration := func() (bool, time.Duration) { q.mutex.Lock() defer q.mutex.Unlock() if q.stopping {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 19:13:32 UTC 2023 - 3.6K bytes - Viewed (0) -
cmd/xl-storage_windows_test.go
if err != nil && test.pass { t.Error(err) } else if err == nil && !test.pass { t.Error(err) } fs.Delete(context.Background(), "voldir", test.objName, DeleteOptions{ Recursive: false, Immediate: false, }) }) } } // Test to validate xlStorage behavior on windows when a non-final path component is a file. func TestUNCPathENOTDIR(t *testing.T) { // Instantiate posix object to manage a disk
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Nov 29 06:35:16 UTC 2023 - 2.8K bytes - Viewed (0) -
fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
final IndexResponse response = getClient().get(c -> c.prepareIndex().setIndex(index).setId(id).setSource(source) .setOpType(opType).setRefreshPolicy(RefreshPolicy.IMMEDIATE).execute()); setId(target, id); return response; } catch (final OpenSearchStatusException e) { if (e.status() == RestStatus.CONFLICT) {
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Apr 04 09:58:36 UTC 2024 - 23.3K bytes - Viewed (0) -
src/cmd/internal/obj/arm64/asm7.go
// pre/post-indexed store. // and the 12-bit and 9-bit are distinguished in olsr12u and oslr9s. func (c *ctxt7) opstr(p *obj.Prog, a obj.As) uint32 { enc := c.opldr(p, a) switch p.As { case AFMOVQ: enc = enc &^ (1 << 22) default: enc = LD2STR(enc) } return enc } // load(immediate) // scaled 12-bit unsigned immediate offset.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 15:44:14 UTC 2024 - 201.1K bytes - Viewed (0) -
src/net/http/cgi/cgi_main.go
func childCGIProcess() { if os.Getenv("REQUEST_METHOD") == "" { // Not in a CGI environment; skipping test. return } switch os.Getenv("REQUEST_URI") { case "/immediate-disconnect": os.Exit(0) case "/no-content-type": fmt.Printf("Content-Length: 6\n\nHello\n") os.Exit(0) case "/empty-headers": fmt.Printf("\nHello") os.Exit(0) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 3.1K bytes - Viewed (0) -
src/cmd/internal/obj/ppc64/doc.go
Example: ADD R3, R4, R5 <=> add r5, r4, r3 2. Constant operands In Go asm, an operand that starts with '$' indicates a constant value. If the instruction using the constant has an immediate version of the opcode, then an immediate value is used with the opcode if possible. Example: ADD $1, R3, R4 <=> addi r4, r3, 1 3. Opcodes setting condition codes
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 21 16:47:45 UTC 2023 - 11.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder.go
return podVolumeClaims, err } // Prebound PVCs are treated as unbound immediate binding if delayBindingMode && pvc.Spec.VolumeName == "" { // Scheduler path podVolumeClaims.unboundClaimsDelayBinding = append(podVolumeClaims.unboundClaimsDelayBinding, pvc) } else { // !delayBindingMode || pvc.Spec.VolumeName != "" // Immediate binding should have already been bound
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 14:55:34 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/queue/instance_test.go
select { case <-time.After(200 * time.Millisecond): t.Error("close stop, method exit timeout.") case <-signal: t.Log("queue return.") } } func TestClosed(t *testing.T) { t.Run("immediate close", func(t *testing.T) { stop := make(chan struct{}) q := NewQueue(0) go q.Run(stop) close(stop) if err := WaitForClose(q, 10*time.Second); err != nil { t.Error(err) } })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jul 21 16:30:36 UTC 2023 - 3.4K bytes - Viewed (0)