meat - Code Search

cmd/tier.go

	return valid
}

// isTierNameInUse returns tier type and true if there exists a remote tier by
// name tierName, otherwise returns madmin.Unsupported and false. N B this
// function is meant for internal use, where the caller is expected to take
// appropriate locks.
func (config *TierConfigMgr) isTierNameInUse(tierName string) (madmin.TierType, bool) {
	if t, ok := config.Tiers[tierName]; ok {

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

- Last Modified: Thu Sep 12 20:44:05 UTC 2024

- 15.7K bytes

- Viewed (0)

github.com/google/guava

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

      // but work beyond that must take at least one second
      assertTrue(afterBurst >= 1000);
    }
  }

  /**
   * This neat test shows that no matter what weights we use in our requests, if we push X amount of
   * permits in a cool state, where X = rate * timeToCoolDown, and we have specified a

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

- Last Modified: Mon Oct 21 14:28:19 UTC 2024

- 21.8K bytes

- Viewed (0)

github.com/google/guava

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

      // but work beyond that must take at least one second
      assertTrue(afterBurst >= 1000);
    }
  }

  /**
   * This neat test shows that no matter what weights we use in our requests, if we push X amount of
   * permits in a cool state, where X = rate * timeToCoolDown, and we have specified a

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

- Last Modified: Mon Oct 21 14:28:19 UTC 2024

- 21.8K bytes

- Viewed (0)

github.com/apache/maven

apache-maven/src/main/appended-resources/licenses/EPL-1.0.txt

conjunction with the Program under their own license agreement, and (ii) are
not derivative works of the Program.

   "Contributor" means any person or entity that distributes the Program.

"Licensed Patents" mean patent claims licensable by a Contributor which are
necessarily infringed by the use or sale of its Contribution alone or when
combined with the Program.

Registered: Sun Nov 03 03:35:11 UTC 2024

- Last Modified: Mon Sep 17 05:50:12 UTC 2018

- 11.1K bytes

- Viewed (0)

github.com/minio/minio

internal/config/identity/ldap/ldap.go

		if baseDN.Parsed.AncestorOf(gdn) {
			return true
		}
	}
	return false
}

// GetNonEligibleUserDistNames - find user accounts (DNs) that are no longer
// present in the LDAP server or do not meet filter criteria anymore
func (l *Config) GetNonEligibleUserDistNames(userDistNames []string) ([]string, error) {
	conn, err := l.LDAP.Connect()
	if err != nil {
		return nil, err
	}
	defer conn.Close()

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

- Last Modified: Fri Jul 12 01:04:53 UTC 2024

- 12.4K bytes

- Viewed (0)

github.com/minio/minio

cmd/endpoint-ellipses.go

		return nil, config.ErrInvalidNumberOfErasureEndpoints(nil).Msg(msg)
	}

	var setSize uint64
	// Custom set drive count allows to override automatic distribution.
	// only meant if you want to further optimize drive distribution.
	if setDriveCount > 0 {
		msg := fmt.Sprintf("Invalid set drive count. Acceptable values for %d number drives are %d", commonSize, setCounts)
		var found bool

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

- Last Modified: Wed Aug 14 17:11:51 UTC 2024

- 14.7K bytes

- Viewed (0)

github.com/minio/minio

cmd/server-main.go

	for {
		select {
		case <-ctx.Done():
			// Retry was canceled successfully.
			return fmt.Errorf("Initializing sub-systems stopped gracefully %w", ctx.Err())
		default:
		}

		// These messages only meant primarily for distributed setup, so only log during distributed setup.
		if globalIsDistErasure {
			logger.Info("Waiting for all MinIO sub-systems to be initialize...")
		}

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

- Last Modified: Tue Sep 24 21:50:11 UTC 2024

- 35.2K bytes

- Viewed (1)

github.com/tensorflow/tensorflow

RELEASE.md

        mean, var = tf.nn.moments(self.kernel, axes=[0, 1, 2], keepdims=True)
        return self.convolution_op(inputs, (self.kernel - mean) / tf.sqrt(var +
        1e-10))` Alternatively, you can override `convolution_op`: `python class
        StandardizedConv2D(tf.keras.Layer): def convolution_op(self, inputs,
        kernel): mean, var = tf.nn.moments(kernel, axes=[0, 1, 2],

Registered: Tue Nov 05 12:39:12 UTC 2024

- Last Modified: Tue Oct 22 14:33:53 UTC 2024

- 735.3K bytes

- Viewed (0)

github.com/minio/minio

cmd/xl-storage-disk-id-check.go

		return p.storage.ReadFileStream(ctx, volume, path, offset, length)
	})
}

func (p *xlStorageDiskIDCheck) RenamePart(ctx context.Context, srcVolume, srcPath, dstVolume, dstPath string, meta []byte) (err error) {
	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricRenamePart, srcVolume, srcPath, dstVolume, dstPath)
	if err != nil {
		return err
	}
	defer done(0, &err)

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

- Last Modified: Sat Oct 26 09:56:26 UTC 2024

- 34.5K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/http/NetworkExplorer.java

        out.println( "<!DOCTYPE HTML PUBLIC \"-//W3C//DTD HTML 4.01 Transitional//EN\">" );
        out.println( "<html><head><title>Network Explorer</title>" );
        out.println( "<meta HTTP-EQUIV=\"Pragma\" CONTENT=\"no-cache\">" );
        out.println( "<style TYPE=\"text/css\">" );

        out.println( style );

        if( dirents.length < 200 ) {
            out.println( "    a:hover {" );

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

- Last Modified: Wed Jan 22 03:57:31 UTC 2020

- 19.7K bytes

- Viewed (0)

Search Options