Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 37 for setIndex (0.4 sec)

  1. src/main/java/org/codelibs/fess/helper/SearchHelper.java

            try {
                final FessConfig fessConfig = ComponentUtil.getFessConfig();
                final UpdateRequestBuilder builder =
                        ComponentUtil.getSearchEngineClient().prepareUpdate().setIndex(fessConfig.getIndexDocumentUpdateIndex()).setId(id);
                builderLambda.accept(builder);
                final UpdateResponse response = builder.execute().actionGet(fessConfig.getIndexIndexTimeout());
    Java
    - Registered: Mon Apr 29 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 16.8K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    	if !opts.Speedtest && len(versions) > 0 {
    		globalMRFState.addPartialOp(partialOperation{
    			bucket:    bucket,
    			object:    object,
    			queued:    time.Now(),
    			versions:  versions,
    			setIndex:  er.setIndex,
    			poolIndex: er.poolIndex,
    		})
    	}
    
    	if !opts.Speedtest && len(versions) == 0 {
    		// Check if there is any offline disk and add it to the MRF list
    		for _, disk := range onlineDisks {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  3. cmd/admin-handlers.go

    		poolInfo, ok := poolsInfo[d.PoolIndex]
    		if !ok {
    			poolInfo = make(map[int]madmin.ErasureSetInfo)
    		}
    		erasureSet, ok := poolInfo[d.SetIndex]
    		if !ok {
    			erasureSet.ID = d.SetIndex
    			cache := dataUsageCache{}
    			if err := cache.load(ctx, z.serverPools[d.PoolIndex].sets[d.SetIndex], dataUsageCacheName); err == nil {
    				dataUsageInfo := cache.dui(dataUsageRoot, nil)
    				erasureSet.ObjectsCount = dataUsageInfo.ObjectsTotalCount
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 97.3K bytes
    - Viewed (2)
  4. cmd/erasure-server-pool.go

    			if skip {
    				continue
    			}
    		}
    
    		if disk.PoolIndex > -1 && disk.SetIndex > -1 {
    			if disk.State == madmin.DriveStateOk {
    				si := erasureSetUpCount[disk.PoolIndex][disk.SetIndex]
    				si.online++
    				if disk.Healing {
    					si.healing++
    					drivesHealing++
    				}
    				erasureSetUpCount[disk.PoolIndex][disk.SetIndex] = si
    			}
    		}
    	}
    
    	b := z.BackendInfo()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 80.1K bytes
    - Viewed (0)
  5. cmd/notification.go

    				offlineDisks = append(offlineDisks, madmin.Disk{
    					Endpoint:  ep.String(),
    					State:     string(madmin.ItemOffline),
    					PoolIndex: ep.PoolIdx,
    					SetIndex:  ep.SetIdx,
    					DiskIndex: ep.DiskIdx,
    				})
    			}
    		}
    	}
    	return offlineDisks
    }
    
    // StorageInfo returns disk information across all peers
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/core/collection/IndexedIteratorTest.java

            assertThat(indexed1.getIndex(), is(0));
            assertThat(indexed1.getElement(), is("aaa"));
    
            final Indexed<String> indexed2 = it.next();
            assertThat(indexed2.getIndex(), is(1));
            assertThat(indexed2.getElement(), is("bbb"));
    
            final Indexed<String> indexed3 = it.next();
            assertThat(indexed3.getIndex(), is(2));
            assertThat(indexed3.getElement(), is("ccc"));
    
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  7. cmd/httprange.go

    	// Check if range string contains delimiter '-', else return error. eg. "bytes=8"
    	sepIndex := strings.Index(byteRangeString, "-")
    	if sepIndex == -1 {
    		return nil, fmt.Errorf("'%s' does not have a valid range value", rangeString)
    	}
    
    	offsetBeginString := byteRangeString[:sepIndex]
    	offsetBegin := int64(-1)
    	// Convert offsetBeginString only if its not empty.
    	if len(offsetBeginString) > 0 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Jul 24 14:56:28 GMT 2023
    - 5.9K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/core/collection/IndexedIterator.java

     *     System.out.println(indexed.getIndex());
     *     System.out.println(indexed.getElement());
     * }
     * </pre>
     *
     * <pre>
     * import static org.codelibs.core.collection.IndexedIterator.*;
     * import static org.codelibs.core.io.LineIterator.*;
     *
     * BufferedReader reader = ...;
     * for (Indexed&lt;String%gt; indexed : indexed(iterable(reader))) {
     *     System.out.println(indexed.getIndex());
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 3.7K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/fess/helper/IndexingHelperTest.java

            final DocList docList = new DocList();
            indexingHelper.sendDocuments(client, docList);
            assertEquals(0, docList.size());
            assertEquals(0, sentDocList.size());
            assertNull(sentIndex.get());
    
            sentIndex.set(null);
            sentDocList.clear();
            docList.add(new HashMap<>(Map.of(//
                    "_id", "001", //
                    "config_id", "W01", //
    Java
    - Registered: Mon Apr 29 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 23.3K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/core/collection/Indexed.java

         * 要素を返します。
         *
         * @return 要素
         */
        public T getElement() {
            return element;
        }
    
        /**
         * インデックスを返します。
         *
         * @return インデックス
         */
        public int getIndex() {
            return index;
        }
    
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 1.5K bytes
    - Viewed (0)
Back to top