Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 41 for immediate (0.07 sec)

  1. impl/maven-core/src/main/java/org/apache/maven/execution/ProjectDependencyGraph.java

         *
         * @param project The project whose downstream projects should be retrieved, must not be {@code null}.
         * @param transitive A flag whether to retrieve all direct and indirect downstream projects or just the immediate
         *            downstream projects.
         * @return The downstream projects in the build order, never {@code null}.
         */
        List<MavenProject> getDownstreamProjects(MavenProject project, boolean transitive);
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  2. fess-crawler-opensearch/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: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  3. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

                                    bulkBuilder.add(c.prepareDelete().setIndex(index).setId(uq.getId()));
                                }
    
                                return bulkBuilder.setRefreshPolicy(RefreshPolicy.IMMEDIATE).execute();
                            });
                            if (response.hasFailures()) {
                                logger.warn(response.buildFailureMessage());
                            }
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  4. cmd/xl-storage.go

    			err = removeAll(filePath)
    		} else {
    			err = Remove(filePath)
    		}
    		return err // Avoid the immediate purge since not needed
    	}
    
    	if err != nil {
    		return err
    	}
    
    	if !immediatePurge && s.diskAlmostFilled() {
    		immediatePurge = true
    	}
    
    	// immediately purge the target
    	if immediatePurge {
    		for _, target := range []string{
    			targetPath,
    			targetPath2,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  5. CONTRIBUTING.md

    There is a somewhat non-obvious filter present on the page that allows you to control which type of messages are displayed.
    The filter is a dropdown box that appears when you click the `Severity ⬇️ ` label in the black header bar to the immediate right of the Gradle version.
    
    If you have a large number of messages of different types, filtering by severity to see only `Error`s can be helpful when processing the report.
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Nov 05 15:15:33 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  6. cmd/background-newdisks-heal-ops.go

    func (h *healingTracker) delete(ctx context.Context) error {
    	return h.disk.Delete(ctx, minioMetaBucket,
    		pathJoin(bucketMetaPrefix, healingTrackerFilename),
    		DeleteOptions{
    			Recursive: false,
    			Immediate: false,
    		},
    	)
    }
    
    func (h *healingTracker) isHealed(bucket string) bool {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    	for _, v := range h.HealedBuckets {
    		if v == bucket {
    			return true
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  7. src/cmd/asm/internal/asm/testdata/riscv64.s

    	JMP	4(X5)					// 67804200
    
    	// CALL and JMP to symbol are encoded as JAL (using LR or ZERO
    	// respectively), with a R_RISCV_JAL relocation. The linker resolves
    	// the real address and updates the immediate, using a trampoline in
    	// the case where the address is not directly reachable.
    	CALL	asmtest(SB)				// ef000000
    	JMP	asmtest(SB)				// 6f000000
    
    	// Branch pseudo-instructions
    	BEQZ	X5, 2(PC)				// 63840200
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Oct 25 12:05:29 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  8. src/bytes/buffer.go

    // The slice aliases the buffer content at least until the next buffer modification,
    // so immediate changes to the slice will affect the result of future reads.
    func (b *Buffer) Bytes() []byte { return b.buf[b.off:] }
    
    // AvailableBuffer returns an empty buffer with b.Available() capacity.
    // This buffer is intended to be appended to and
    // passed to an immediately succeeding [Buffer.Write] call.
    // The buffer is only valid until the next write operation on b.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Oct 29 16:47:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  9. cmd/xl-storage-disk-id-check.go

    		if err != nil || len(b) != len(toWrite) {
    			continue
    		}
    
    		err = p.storage.Delete(context.Background(), minioMetaTmpBucket, fn, DeleteOptions{
    			Recursive: false,
    			Immediate: false,
    		})
    
    		if err == nil {
    			logger.Event(context.Background(), "healthcheck",
    				"node(%s): Read/Write/Delete successful, bringing drive %s online", globalLocalNodeName, p.storage.String())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  10. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
Back to top