minit - Code Search

cmd/erasure-healing_test.go

	"crypto/rand"
	"crypto/sha256"
	"errors"
	"io"
	"os"
	"path"
	"reflect"
	"testing"
	"time"

	"github.com/dustin/go-humanize"
	uuid2 "github.com/google/uuid"
	"github.com/minio/madmin-go/v3"
	"github.com/minio/minio/internal/config/storageclass"
)

// Tests isObjectDangling function
func TestIsObjectDangling(t *testing.T) {
	fi := newFileInfo("test-object", 2, 2)
	fi.Erasure.Index = 1

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Mon Jun 10 15:51:27 UTC 2024

- 49K bytes

- Viewed (0)

github.com/minio/minio

cmd/metacache-stream_test.go

// Copyright (c) 2015-2021 MinIO, Inc.
//
// This file is part of MinIO Object Storage stack
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU Affero General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// This program is distributed in the hope that it will be useful

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Mon Sep 19 18:05:16 UTC 2022

- 15K bytes

- Viewed (0)

github.com/minio/minio

cmd/erasure-decode_test.go

// Copyright (c) 2015-2021 MinIO, Inc.
//
// This file is part of MinIO Object Storage stack
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU Affero General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// This program is distributed in the hope that it will be useful

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Tue Jan 30 20:43:25 UTC 2024

- 21.1K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/helper/ActivityHelper.java

    protected String ecsVersion = "1.2.0";

    protected String ecsServiceName = "fess";

    protected String ecsEventDataset = "app";

    @PostConstruct
    public void init() {
        logger = LogManager.getLogger(loggerName);
        final String logFormat = ComponentUtil.getFessConfig().getAppAuditLogFormat();
        if (StringUtil.isBlank(logFormat)) {

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Thu Feb 22 01:53:18 UTC 2024

- 7.7K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/suggest/admin_suggest.jsp

            key="labels.suggest_word_configuration"/></title>
    <jsp:include page="/WEB-INF/view/common/admin/head.jsp"></jsp:include>
</head>
<body class="hold-transition sidebar-mini">
<div class="wrapper">
    <jsp:include page="/WEB-INF/view/common/admin/header.jsp"></jsp:include>
    <jsp:include page="/WEB-INF/view/common/admin/sidebar.jsp">
        <jsp:param name="menuCategoryType" value="suggest"/>

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Wed Feb 12 20:25:27 UTC 2020

- 18.1K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/ntlmssp/Type3Message.java

/* RC4 was not added to Java until 1.5u7 so let's use our own for a little while longer ...
                        try {
                            Cipher rc4 = Cipher.getInstance("RC4");
                            rc4.init(Cipher.ENCRYPT_MODE, new SecretKeySpec(ntlm2SessionKey, "RC4"));
                            rc4.update(masterKey, 0, 16, exchangedKey, 0);
                        } catch (GeneralSecurityException gse) {

Registered: Sun Nov 03 00:10:13 UTC 2024

- Last Modified: Fri Mar 22 21:10:40 UTC 2019

- 22.9K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/exec/SuggestCreator.java

            SingletonLaContainerFactory.setExternalContextComponentDefRegister(new GenericExternalContextComponentDefRegister());
            SingletonLaContainerFactory.init();

            final Thread shutdownCallback = new Thread("ShutdownHook") {
                @Override
                public void run() {
                    if (logger.isDebugEnabled()) {

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Thu Feb 22 01:53:18 UTC 2024

- 10K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/util/concurrent/AggregateFutureState.java

      // be a definite performance hit to those users.
      thrownReflectionFailure = reflectionFailure;
      helper = new SynchronizedAtomicHelper();
    }
    ATOMIC_HELPER = helper;
    // Log after all static init is finished; if an installed logger uses any Futures methods, it
    // shouldn't break in cases where reflection is missing/broken.
    if (thrownReflectionFailure != null) {

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Tue May 28 20:40:51 UTC 2024

- 8.4K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/io/FilesTest.java

  }

  public void testHash() throws IOException {
    File asciiFile = getTestFile("ascii.txt");
    File i18nFile = getTestFile("i18n.txt");

    String init = "d41d8cd98f00b204e9800998ecf8427e";
    assertEquals(init, Hashing.md5().newHasher().hash().toString());

    String asciiHash = "e5df5a39f2b8cb71b24e1d8038f93131";
    assertEquals(asciiHash, Files.hash(asciiFile, Hashing.md5()).toString());

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Tue Jul 23 14:22:54 UTC 2024

- 22.1K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

      state = STATE_CLOSED
    }
  }

  /** An HTTP body with a fixed length specified in advance. */
  private inner class FixedLengthSource(private var bytesRemaining: Long) :
    AbstractSource() {
    init {
      if (bytesRemaining == 0L) {
        responseBodyComplete()
      }
    }

    override fun read(
      sink: Buffer,
      byteCount: Long,
    ): Long {

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Mon Jan 08 01:13:22 UTC 2024

- 16.2K bytes

- Viewed (0)

Search Options