cOm - Code Search

android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
 * License for the specific language governing permissions and limitations under
 * the License.
 */

package com.google.common.util.concurrent;

import static com.google.common.truth.Truth.assertThat;
import static java.util.concurrent.Executors.callable;
import static java.util.concurrent.TimeUnit.MINUTES;
import static java.util.concurrent.TimeUnit.SECONDS;

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Mon Jul 14 14:44:08 GMT 2025

- 7.4K bytes

- Click Count (0)

github.com/minio/minio

internal/config/scanner/scanner.go

// along with this program.  If not, see <http://www.gnu.org/licenses/>.

package scanner

import (
	"fmt"
	"strconv"
	"time"

	"github.com/minio/minio/internal/config"
	"github.com/minio/pkg/v3/env"
)

// Compression environment variables
const (
	Speed    = "speed"
	EnvSpeed = "MINIO_SCANNER_SPEED"

	IdleSpeed    = "idle_speed"

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri May 24 23:05:23 GMT 2024

- 5.5K bytes

- Click Count (0)

github.com/minio/minio

cmd/erasure-object-conditional_test.go

package cmd

import (
	"bytes"
	"context"
	"testing"

	xhttp "github.com/minio/minio/internal/http"
)

// TestPutObjectConditionalWithReadQuorumFailure tests that conditional
// PutObject operations (with if-match/if-none-match) behave correctly when read quorum
// cannot be reached.
//
// Related to: https://github.com/minio/minio/issues/21603
//
// Should return an error when read quorum cannot

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri Oct 24 04:05:31 GMT 2025

- 4.9K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/orig/view/search.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%><!DOCTYPE html>
${fe:html(true)}
<head profile="http://a9.com/-/spec/opensearch/1.1/">
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<meta name="referrer" content="no-referrer">
<title>${f:h(displayQuery)}-<la:message
		key="labels.search_title" /></title>
<c:if test="${osddLink}">

Created: Sat Dec 20 09:19:18 GMT 2025

- Last Modified: Sat Jan 18 11:38:54 GMT 2025

- 6.8K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs/de/docs/tutorial/index.md

Wenn Sie mit `pip install "fastapi[standard]"` installieren, werden einige optionale Standard-Abhängigkeiten mit installiert, einschließlich `fastapi-cloud-cli`, welches Ihnen das Deployment in der <a href="https://fastapicloud.com" class="external-link" target="_blank">FastAPI Cloud</a> ermöglicht.

Wenn Sie diese optionalen Abhängigkeiten nicht haben möchten, können Sie stattdessen `pip install fastapi` installieren.

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Sat Sep 20 15:10:09 GMT 2025

- 5.5K bytes

- Click Count (0)

github.com/minio/minio

cmd/metacache-manager.go

// along with this program.  If not, see <http://www.gnu.org/licenses/>.

package cmd

import (
	"context"
	"fmt"
	"runtime/debug"
	"sync"
	"time"

	"github.com/minio/minio/internal/logger"
)

// localMetacacheMgr is the *local* manager for this peer.
// It should never be used directly since buckets are
// distributed deterministically.
// Therefore no cluster locks are required.

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Tue Oct 25 00:44:15 GMT 2022

- 5.2K bytes

- Click Count (0)

github.com/minio/minio

docs/compression/README.md

MinIO server allows streaming compression to ensure efficient disk space usage.
Compression happens inflight, i.e objects are compressed before being written to disk(s).
MinIO uses [`klauspost/compress/s2`](https://github.com/klauspost/compress/tree/master/s2)
streaming compression due to its stability and performance.

This algorithm is specifically optimized for machine generated content.
Write throughput is typically at least 500MB/s per CPU core,

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Tue Aug 12 18:20:36 GMT 2025

- 5.2K bytes

- Click Count (0)

github.com/minio/minio

docs/debugging/inspect/main.go

package main

import (
	"bufio"
	crand "crypto/rand"
	"crypto/rsa"
	"crypto/x509"
	"encoding/json"
	"encoding/pem"
	"errors"
	"flag"
	"fmt"
	"io"
	"os"
	"strings"
	"time"

	"github.com/klauspost/filepathx"
)

var (
	keyHex      = flag.String("key", "", "decryption key")
	privKeyPath = flag.String("private-key", "support_private.pem", "private key")

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Mon Feb 17 17:09:42 GMT 2025

- 5.7K bytes

- Click Count (0)

github.com/minio/minio

cmd/storage-interface.go

// You should have received a copy of the GNU Affero General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.

package cmd

import (
	"context"
	"io"
	"time"

	"github.com/minio/madmin-go/v3"
)

// StorageAPI interface.
type StorageAPI interface {
	// Stringified version of disk.
	String() string

	// Storage operations.

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri Apr 25 05:41:04 GMT 2025

- 5.3K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/resources/fess_indices/fess/lt/stopwords.txt

# https://github.com/apache/lucene-solr/blob/master/lucene/analysis/common/src/resources/org/apache/lucene/analysis/lt/stopwords.txt
ant
apie
ar
arba
aš
be
bei
bet
bus
būti
būtų
buvo
dėl
gali
į
iki
ir
iš
ja
ją
jai
jais
jam
jame
jas
jei
ji
jį
jie
jiedu
jiedvi
jiedviem
jiedviese
jiems
jis
jo
jodviem
jog
joje
jomis
joms
jos
jose

Created: Sat Dec 20 09:19:18 GMT 2025

- Last Modified: Thu Jul 19 06:31:02 GMT 2018

- 786 bytes

- Click Count (0)

Search Options