Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 350 for indices (0.09 sec)

  1. cmd/erasure-server-pool-decom.go

    	if len(indices) == 0 {
    		return errInvalidArgument
    	}
    
    	if z.SinglePool() {
    		return errInvalidArgument
    	}
    
    	// Make pool unwritable before decommissioning.
    	if err := z.StartDecommission(ctx, indices...); err != nil {
    		return err
    	}
    
    	go func() {
    		for _, idx := range indices {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  2. guava-tests/benchmark/com/google/common/collect/ImmutableSetHashFloodingDetectionBenchmark.java

          boolean hashFloodingDetected(Object[] hashTable) {
            int maxRunBeforeFallback = maxRunBeforeFallback(hashTable.length);
            int mask = hashTable.length - 1;
    
            // Invariant: all elements at indices in [knownRunStart, knownRunEnd) are nonnull.
            // If knownRunStart == knownRunEnd, this is vacuously true.
            // When knownRunEnd exceeds hashTable.length, it "wraps", detecting runs around the end
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Jun 03 20:16:35 UTC 2021
    - 6.8K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http2/Huffman.kt

          24, 26, 23, 26, 27, 26, 26, 27, 27, 27, 27, 27, 28, 27, 27, 27, 27, 27, 26,
        )
    
      private val root = Node()
    
      init {
        for (i in CODE_BIT_COUNTS.indices) {
          addCode(i, CODES[i], CODE_BIT_COUNTS[i].toInt())
        }
      }
    
      @Throws(IOException::class)
      fun encode(
        source: ByteString,
        sink: BufferedSink,
      ) {
        var accumulator = 0L
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2.kt

            FLAGS[prefixFlag or frameFlag or FLAG_PADDED] =
              FLAGS[prefixFlag] + '|'.toString() + FLAGS[frameFlag] + "|PADDED"
          }
        }
    
        for (i in FLAGS.indices) { // Fill in holes with binary representation.
          if (FLAGS[i] == null) FLAGS[i] = BINARY[i]
        }
      }
    
      /**
       * Returns a human-readable representation of HTTP/2 frame headers.
       *
       * The format is:
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/es/user/allcommon/EsAbstractBehavior.java

    import org.dbflute.exception.IllegalBehaviorStateException;
    import org.dbflute.util.DfTypeUtil;
    import org.opensearch.action.DocWriteResponse.Result;
    import org.opensearch.action.admin.indices.refresh.RefreshResponse;
    import org.opensearch.action.bulk.BulkItemResponse;
    import org.opensearch.action.bulk.BulkRequestBuilder;
    import org.opensearch.action.bulk.BulkResponse;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

                    exitCode.set(1);
                }
            }
    
            logger.info("Replacing new suggest index.");
            suggestHelper.suggester().switchIndex();
    
            logger.info("Removing old indices.");
            suggestHelper.suggester().removeDisableIndices();
    
            return exitCode.get();
        }
    
        private int purge(final LocalDateTime time) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 10K bytes
    - Viewed (0)
  7. okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/SimpleIdnaMappingTable.kt

              it.sourceCodePoint1 < codePoint -> -1
              it.sourceCodePoint0 > codePoint -> 1
              else -> 0
            }
          }
    
        // Code points must be in 0..0x10ffff.
        require(index in mappings.indices) { "unexpected code point: $codePoint" }
    
        val mapping = mappings[index]
        var result = true
    
        when (mapping.type) {
          TYPE_IGNORED -> Unit
          TYPE_MAPPED, TYPE_DISALLOWED_STD3_MAPPED -> {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/helper/DataIndexHelper.java

                    final SearchEngineClient searchEngineClient = ComponentUtil.getSearchEngineClient();
                    final String index = fessConfig.getIndexDocumentUpdateIndex();
                    searchEngineClient.admin().indices().prepareRefresh(index).execute().actionGet();
                    final long numOfDeleted = searchEngineClient.deleteByQuery(index, queryBuilder);
                    logger.info("Deleted {} old docs.", numOfDeleted);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 12K bytes
    - Viewed (0)
  9. docs/es/README.md

    * [fess_message_en.properties](https://github.com/codelibs/fess/blob/master/src/main/resources/fess_message_en.properties)
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 07:19:47 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/es/log/allcommon/EsAbstractBehavior.java

    import org.dbflute.exception.IllegalBehaviorStateException;
    import org.dbflute.util.DfTypeUtil;
    import org.opensearch.action.DocWriteResponse.Result;
    import org.opensearch.action.admin.indices.refresh.RefreshResponse;
    import org.opensearch.action.bulk.BulkItemResponse;
    import org.opensearch.action.bulk.BulkRequestBuilder;
    import org.opensearch.action.bulk.BulkResponse;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
Back to top