- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 214 for IMMEDIATE (0.27 sec)
-
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) -
guava-tests/test/com/google/common/eventbus/DispatcherTest.java
assertThat(dispatchedSubscribers).containsExactly(i1, i2, i3, s1, s1, s1, s1, s2, s2, s2, s2); } public void testImmediateDispatcher() { dispatcher = Dispatcher.immediate(); dispatcher.dispatch(1, integerSubscribers.iterator()); assertThat(dispatchedSubscribers) .containsExactly(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 27 15:41:25 UTC 2022 - 5.6K 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) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/FileWatcherUpdater.java
* * <dt>watched directories</dt> * <dd>On OSs with non-hierarchical file system events (currently Linux only) we don't watch whole * hierarchies, but need to individually watch each directory and its immediate children. * See {@link org.gradle.internal.watch.registry.impl.NonHierarchicalFileWatcherUpdater}.</dd> * * <dt>probed hierarchies</dt>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 5.1K bytes - Viewed (0) -
src/cmd/link/doc.go
-asan Link with C/C++ address sanitizer support. -aslr Enable ASLR for buildmode=c-shared on windows (default true). -bindnow Mark a dynamically linked ELF object for immediate function binding (default false). -buildid id Record id as Go toolchain build id. -buildmode mode Set build mode (default exe). -c Dump call graphs. -compressdwarf
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 15 16:11:52 UTC 2024 - 4K bytes - Viewed (0) -
src/internal/chacha8rand/chacha8.go
func (s *State) Init64(seed [4]uint64) { s.seed = seed block(&s.seed, &s.buf, 0) s.c = 0 s.i = 0 s.n = chunk } // Refill refills the state with more random values. // After a call to Refill, an immediate call to Next will succeed // (unless multiple goroutines are incorrectly sharing a state). func (s *State) Refill() { s.c += ctrInc if s.c == ctrMax { // Reseed with generated uint64s for forward secrecy.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 21:47:29 UTC 2024 - 4.4K bytes - Viewed (0)