Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 17 of 17 for getWorker (0.43 sec)

  1. internal/config/heal/heal.go

    func (opts Config) Clone() (int, time.Duration, string) {
    	configMutex.RLock()
    	defer configMutex.RUnlock()
    	return opts.IOCount, opts.Sleep, opts.Bitrot
    }
    
    // GetWorkers returns the number of workers, -1 is none configured
    func (opts Config) GetWorkers() int {
    	configMutex.RLock()
    	defer configMutex.RUnlock()
    	return opts.DriveWorkers
    }
    
    // Update updates opts with nopts
    func (opts *Config) Update(nopts Config) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/es/log/bsentity/BsClickLog.java

            return convertEmptyToNull(docId);
        }
    
        public void setDocId(String value) {
            registerModifiedProperty("docId");
            this.docId = value;
        }
    
        public Integer getOrder() {
            checkSpecifiedProperty("order");
            return order;
        }
    
        public void setOrder(Integer value) {
            registerModifiedProperty("order");
            this.order = value;
        }
    
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 7K bytes
    - Viewed (0)
  3. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/verification/writer/PgpEntry.java

                hasSignatureFile.set(hasSig);
                if (!hasSig) {
                    requiresChecksums.set(true);
                }
                return f;
            };
        }
    
        @Override
        int getOrder() {
            return -1;
        }
    
        public Set<String> getTrustedKeys() {
            return trustedKeys;
        }
    
        public PgpEntry addVerifiedKey(String key) {
            trustedKeys.add(key);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Mar 21 14:42:50 UTC 2024
    - 4K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/es/log/bsentity/dbmeta/ClickLogDbm.java

            setupEpg(_epgMap, et -> ((ClickLog) et).getDocId(), (et, vl) -> ((ClickLog) et).setDocId(DfTypeUtil.toString(vl)), "docId");
            setupEpg(_epgMap, et -> ((ClickLog) et).getOrder(), (et, vl) -> ((ClickLog) et).setOrder(DfTypeUtil.toInteger(vl)), "order");
            setupEpg(_epgMap, et -> ((ClickLog) et).getQueryId(), (et, vl) -> ((ClickLog) et).setQueryId(DfTypeUtil.toString(vl)), "queryId");
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  5. cmd/global-heal.go

    		numHealers = numCores / 4
    	} else {
    		numHealers = info.NRRequests / 4
    	}
    	if numHealers < 4 {
    		numHealers = 4
    	}
    	// allow overriding this value as well..
    	if v := globalHealConfig.GetWorkers(); v > 0 {
    		numHealers = uint64(v)
    	}
    
    	healingLogEvent(ctx, fmt.Sprintf("Healing drive '%s' - use %d parallel workers.", tracker.disk.String(), numHealers))
    
    	jt, _ := workers.New(int(numHealers))
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 31 14:48:50 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java

                    appendJson("doc-id", entity.getDocId(), buf).append(',');
                    appendJson("url", entity.getUrl(), buf).append(',');
                    appendJson("order", entity.getOrder(), buf).append(',');
                    appendJson("query-requested-at", entity.getQueryRequestedAt(), buf).append(',');
                    appendJson("requested-at", entity.getRequestedAt(), buf);
                    buf.append('}');
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/app/service/SearchLogService.java

                    params.put("User Session ID", e.getUserSessionId());
                    params.put("URL", e.getUrl());
                    params.put("URL ID", e.getUrlId());
                    params.put("Order", toNumberString(e.getOrder()));
                    params.put("Query Requested Time", FessFunctions.formatDate(e.getQueryRequestedAt()));
                    params.put("Requested Time", FessFunctions.formatDate(e.getRequestedAt()));
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 28.4K bytes
    - Viewed (0)
Back to top