Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 710 for jconst (0.04 sec)

  1. cmd/metrics-v3-cluster-usage.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"
    	"time"
    )
    
    const (
    	usageSinceLastUpdateSeconds   = "since_last_update_seconds"
    	usageTotalBytes               = "total_bytes"
    	usageObjectsCount             = "count"
    	usageVersionsCount            = "versions_count"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jul 14 18:11:42 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. internal/crypto/sse.go

    	"context"
    	"errors"
    	"fmt"
    	"io"
    	"net/http"
    
    	"github.com/minio/minio/internal/fips"
    	"github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/sio"
    )
    
    const (
    	// SealAlgorithm is the encryption/sealing algorithm used to derive & seal
    	// the key-encryption-key and to en/decrypt the object data.
    	SealAlgorithm = "DAREv2-HMAC-SHA256"
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  3. internal/disk/directio_darwin.go

    package disk
    
    import (
    	"os"
    
    	"github.com/ncw/directio"
    	"golang.org/x/sys/unix"
    )
    
    // ODirectPlatform indicates if the platform supports O_DIRECT
    const ODirectPlatform = true
    
    // OpenFileDirectIO - bypass kernel cache.
    func OpenFileDirectIO(filePath string, flag int, perm os.FileMode) (*os.File, error) {
    	return directio.OpenFile(filePath, flag, perm)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 17 14:31:36 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  4. tensorflow/c/eager/gradients_test.cc

    namespace gradients {
    namespace internal {
    namespace {
    using std::vector;
    using tensorflow::TF_StatusPtr;
    using tracing::TracingOperation;
    
    class CppGradients
        : public ::testing::TestWithParam<std::tuple<const char*, bool, bool>> {
     protected:
      void SetUp() override {
        TF_StatusPtr status(TF_NewStatus());
        TF_SetTracingImplementation(std::get<0>(GetParam()), status.get());
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 7K bytes
    - Viewed (0)
  5. internal/config/lambda/config.go

    // Config - lambda target configuration structure, holds
    // information about various lambda targets.
    type Config struct {
    	Webhook map[string]target.WebhookArgs `json:"webhook"`
    }
    
    const (
    	defaultTarget = "1"
    )
    
    // NewConfig - initialize lambda config.
    func NewConfig() Config {
    	// Make sure to initialize lambda targets
    	cfg := Config{
    		Webhook: make(map[string]target.WebhookArgs),
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  6. cmd/mrf.go

    	"io"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	"github.com/google/uuid"
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/pkg/v3/wildcard"
    	"github.com/tinylib/msgp/msgp"
    )
    
    const (
    	mrfOpsQueueSize = 100000
    )
    
    const (
    	healDir              = ".heal"
    	healMRFDir           = bucketMetaPrefix + SlashSeparator + healDir + SlashSeparator + "mrf"
    	healMRFMetaFormat    = 1
    	healMRFMetaVersionV1 = 1
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  7. internal/etag/etag.go

    // an ETag entry or when the ETag is malformed.
    //
    // Get only accepts AWS S3 compatible ETags - i.e. no
    // encrypted ETags - and therefore is stricter than Parse.
    func Get(h http.Header) (ETag, error) {
    	const strict = true
    	if v := h.Get("Etag"); v != "" {
    		return parse(v, strict)
    	}
    	v, ok := h["ETag"]
    	if !ok || len(v) == 0 {
    		return nil, errors.New("etag: HTTP header does not contain an ETag")
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 21:09:36 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/internal/RecordingAuthenticator.kt

            "protocol=$requestingProtocol scheme=$requestingScheme",
        )
        return authentication
      }
    
      companion object {
        /** base64("username:password")  */
        const val BASE_64_CREDENTIALS = "dXNlcm5hbWU6cGFzc3dvcmQ="
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  9. internal/grid/handlers_string.go

    	_ = x[HandlerRenameData2-73]
    	_ = x[HandlerCheckParts2-74]
    	_ = x[HandlerRenamePart-75]
    	_ = x[HandlerClearUploadID-76]
    	_ = x[handlerTest-77]
    	_ = x[handlerTest2-78]
    	_ = x[handlerLast-79]
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/ws/MessageInflater.kt

     * limitations under the License.
     */
    package okhttp3.internal.ws
    
    import java.io.Closeable
    import java.io.IOException
    import java.util.zip.Inflater
    import okio.Buffer
    import okio.InflaterSource
    
    private const val OCTETS_TO_ADD_BEFORE_INFLATION = 0x0000ffff
    
    class MessageInflater(
      private val noContextTakeover: Boolean,
    ) : Closeable {
      private val deflatedBytes = Buffer()
    
      private val inflater =
        Inflater(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.8K bytes
    - Viewed (0)
Back to top