Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 62 for getLoc (0.25 sec)

  1. compat/maven-embedder/src/main/java/org/apache/maven/cli/MavenCli.java

            request.setExecutionListener(determineExecutionListener());
    
            if ((request.getPom() != null) && (request.getPom().getParentFile() != null)) {
                request.setBaseDirectory(request.getPom().getParentFile());
            }
    
            request.setResumeFrom(commandLine.getOptionValue(CLIManager.RESUME_FROM));
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 76.8K bytes
    - Viewed (0)
  2. cmd/background-newdisks-heal-ops.go

    			return err
    		}
    	}
    
    	// Prevent parallel erasure set healing
    	locker := z.NewNSLock(minioMetaBucket, fmt.Sprintf("new-drive-healing/%d/%d", poolIdx, setIdx))
    	lkctx, err := locker.GetLock(ctx, newDiskHealingTimeout)
    	if err != nil {
    		return fmt.Errorf("Healing of drive '%v' on %s pool, belonging to %s erasure set already in progress: %w",
    			disk, humanize.Ordinal(poolIdx+1), humanize.Ordinal(setIdx+1), err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-rebalance.go

    	rebalSaveStoppedAt
    )
    
    func (z *erasureServerPools) saveRebalanceStats(ctx context.Context, poolIdx int, opts rebalSaveOpts) error {
    	lock := z.serverPools[0].NewNSLock(minioMetaBucket, rebalMetaName)
    	lkCtx, err := lock.GetLock(ctx, globalOperationTimeout)
    	if err != nil {
    		rebalanceLogIf(ctx, fmt.Errorf("failed to acquire write lock on %s/%s: %w", minioMetaBucket, rebalMetaName, err))
    		return err
    	}
    	defer lock.Unlock(lkCtx)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  4. cmd/bucket-replication.go

    	}
    
    	// Lock the object name before starting replication operation.
    	// Use separate lock that doesn't collide with regular objects.
    	lk := objectAPI.NewNSLock(bucket, "/[replicate]/"+dobj.ObjectName)
    	lkctx, err := lk.GetLock(ctx, globalOperationTimeout)
    	if err != nil {
    		globalReplicationPool.Get().queueMRFSave(dobj.ToMRFEntry())
    		sendEvent(eventArgs{
    			BucketName: bucket,
    			Object: ObjectInfo{
    				Bucket:       bucket,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  5. cmd/data-scanner.go

    // The function will block until the context is canceled.
    // There should only ever be one scanner running per cluster.
    func runDataScanner(ctx context.Context, objAPI ObjectLayer) {
    	ctx, cancel := globalLeaderLock.GetLock(ctx)
    	defer cancel()
    
    	// Load current bloom cycle
    	var cycleInfo currentScannerCycle
    
    	buf, _ := readConfig(ctx, objAPI, dataUsageBloomNamePath)
    	if len(buf) == 8 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  6. compat/maven-model-builder/src/main/java/org/apache/maven/model/validation/DefaultModelValidator.java

            protected Activation.Builder transformActivation_Os(
                    Supplier<? extends Activation.Builder> creator, Activation.Builder builder, Activation target) {
                stk.push(nextFrame("os", Activation::getOs));
                try {
                    return super.transformActivation_Os(creator, builder, target);
                } finally {
                    stk.pop();
                }
            }
    
            @Override
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 77.1K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java

            if (usePipeline) {
                return updateByIdWithScript(index, id, field, value);
            }
            try {
                final Result result = client.prepareUpdate().setIndex(index).setId(id).setDoc(field, value).execute()
                        .actionGet(ComponentUtil.getFessConfig().getIndexIndexTimeout()).getResult();
                return result == Result.CREATED || result == Result.UPDATED;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sun Oct 20 02:08:03 UTC 2024
    - 86.1K bytes
    - Viewed (0)
  8. android/guava/src/com/google/thirdparty/publicsuffix/PublicSuffixPatterns.java

    livnioj?rdnaotnas??f&dj?ed?gg?n&e?i???g&e&l!.&a&b,m,p,?bp,c&a,s,?e&c,p,s,?fd,gm,ip,jr,la,ma,nr,o&g,r,t,?p&a,s,?r&p,r,?s&e,m,r,?tm,??s??l&s?z??n&c?e?o??ol!b?f?v??pp?ro??hvp?i&du?kiw?nana?oretin?r&c?eurab??sp?te?xat??l&at&an?rof??el?im?sq??m&a?da?e&gatnoc?leb??f?ic?oc!.&etiselpmis,topsgolb,???nce?o&ariebir?c&e?narboir?saso??d&o?ranreboas??e&g?t??i&b?dar?ecam?r??rp?t&a?erpoir???p&er?m!e?t??ooc?pa?se??qra?r&af?ga?o&davlas?j??tn?ut??s&a&ixac?mlap?nipmac??ed?u&anam?j?m???t&am?e&d?n?v??nc?o&f?n??ra?sf?...
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 06 02:37:31 UTC 2024
    - 73.6K bytes
    - Viewed (0)
  9. guava/src/com/google/thirdparty/publicsuffix/PublicSuffixPatterns.java

    livnioj?rdnaotnas??f&dj?ed?gg?n&e?i???g&e&l!.&a&b,m,p,?bp,c&a,s,?e&c,p,s,?fd,gm,ip,jr,la,ma,nr,o&g,r,t,?p&a,s,?r&p,r,?s&e,m,r,?tm,??s??l&s?z??n&c?e?o??ol!b?f?v??pp?ro??hvp?i&du?kiw?nana?oretin?r&c?eurab??sp?te?xat??l&at&an?rof??el?im?sq??m&a?da?e&gatnoc?leb??f?ic?oc!.&etiselpmis,topsgolb,???nce?o&ariebir?c&e?narboir?saso??d&o?ranreboas??e&g?t??i&b?dar?ecam?r??rp?t&a?erpoir???p&er?m!e?t??ooc?pa?se??qra?r&af?ga?o&davlas?j??tn?ut??s&a&ixac?mlap?nipmac??ed?u&anam?j?m???t&am?e&d?n?v??nc?o&f?n??ra?sf?...
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 06 02:37:31 UTC 2024
    - 73.6K bytes
    - Viewed (0)
  10. okhttp-android/src/main/baseline-prof.txt

    HSPLkotlinx/coroutines/JobCancellingNode;-><init>()V
    HSPLkotlinx/coroutines/JobImpl;-><init>(Lkotlinx/coroutines/Job;)V
    HSPLkotlinx/coroutines/JobNode;-><init>()V
    HSPLkotlinx/coroutines/JobNode;->dispose()V
    HSPLkotlinx/coroutines/JobNode;->getJob()Lkotlinx/coroutines/JobSupport;
    HSPLkotlinx/coroutines/JobNode;->getList()Lkotlinx/coroutines/NodeList;
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Mar 21 11:22:00 UTC 2022
    - 127.9K bytes
    - Viewed (0)
Back to top