- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 150 for accept (0.45 sec)
-
internal/config/errors.go
"Please check the passed value", "MINIO_DOMAIN only accepts non-overlapping domain values", ) ErrInvalidDomainValue = newErrFn( "Invalid domain value", "Please check the passed value", "Domain can only accept DNS compatible values", ) ErrInvalidErasureSetSize = newErrFn( "Invalid erasure set size", "Please check the passed value",
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Mar 18 22:25:32 GMT 2024 - 9.1K bytes - Viewed (0) -
cmd/streaming-signature-v4_test.go
{"000000000000bogus", 0, "invalid byte in chunk length"}, {"00000000000000000", 0, "http chunk length too large"}, // could accept if we wanted {"10000000000000000", 0, "http chunk length too large"}, {"00000000000000001", 0, "http chunk length too large"}, // could accept if we wanted } for i := uint64(0); i <= 1234; i++ { tests = append(tests, testCase{in: fmt.Sprintf("%x", i), want: i}) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 5.7K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn_test.go
t.Fatalf("failed to assert to net.TCPListener") } var wg sync.WaitGroup wg.Add(1) go func() { defer wg.Done() tcpConn, terr := tcpListener.AcceptTCP() if terr != nil { t.Errorf("failed to accept new connection. %v", terr) return } deadlineconn := New(tcpConn) deadlineconn.WithReadDeadline(time.Second) deadlineconn.WithWriteDeadline(time.Second) defer deadlineconn.Close() // Read a line
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 3K bytes - Viewed (0) -
internal/http/listener.go
for idx, tcpListener := range listener.tcpListeners { go handleListener(idx, tcpListener) } } // Accept - reads from httpListener.acceptCh for one of previously accepted TCP connection and returns the same. func (listener *httpListener) Accept() (conn net.Conn, err error) { select { case result, ok := <-listener.acceptCh: if ok { return deadlineconn.New(result.conn). WithReadDeadline(listener.opts.ClientReadTimeout).
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Mar 01 16:00:42 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/warm-backend-gcs.go
// GCS storage decompresses a gzipped object by default and returns the data. // Refer to https://cloud.google.com/storage/docs/transcoding#decompressive_transcoding // Need to set `Accept-Encoding` header to `gzip` when issuing a GetObject call, to be able // to download the object in compressed state. // Calling ReadCompressed with true accomplishes that.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 5.9K bytes - Viewed (0) -
internal/http/lambda-headers.go
AmzFwdStatus = "x-amz-fwd-status" AmzFwdErrorCode = "x-amz-fwd-error-code" AmzFwdErrorMessage = "x-amz-fwd-error-message" AmzFwdHeaderAcceptRanges = "x-amz-fwd-header-accept-ranges" AmzFwdHeaderCacheControl = "x-amz-fwd-header-Cache-Control" AmzFwdHeaderContentDisposition = "x-amz-fwd-header-Content-Disposition" AmzFwdHeaderContentEncoding = "x-amz-fwd-header-Content-Encoding"
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 3.1K bytes - Viewed (0) -
cmd/sftp-server.go
logger.Info(msg) } func (s *sftpLogger) Error(tag xsftp.LogType, err error) { switch tag { case xsftp.AcceptNetworkError: sftpLogOnceIf(context.Background(), err, "accept-limit-sftp") case xsftp.AcceptChannelError: sftpLogOnceIf(context.Background(), err, "accept-channel-sftp") case xsftp.SSHKeyExchangeError: sftpLogOnceIf(context.Background(), err, "key-exchange-sftp") default:
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.6K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
// CLI: -A ISTIO_PRERT -p tcp -m conntrack --ctstate RELATED,ESTABLISHED -j ACCEPT // // DESC: Anything that's already in conntrack as an established connection, accept iptablesBuilder.AppendRule( iptableslog.UndefinedCommand, ChainInpodPrerouting, iptablesconstants.MANGLE, "-p", "tcp", "-m", "conntrack", "--ctstate", "RELATED,ESTABLISHED", "-j", "ACCEPT", )
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 19.6K bytes - Viewed (0) -
internal/etag/etag.go
// - strict // - non-strict // // In strict mode, parse only accepts ETags that // are AWS S3 compatible. In particular, an AWS // S3 ETag always consists of a 128 bit checksum // value and an optional -<part-number> suffix. // Therefore, s must have the following form in // strict mode: <32-hex-characters>[-<integer>] // // In non-strict mode, parse also accepts ETags // that are not AWS S3 compatible - e.g. encrypted // ETags.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 13.3K bytes - Viewed (0) -
cmd/post-policy_test.go
// Add the bucket condition, only accept buckets equal to the one passed. bucketConditionStr := fmt.Sprintf(`["eq", "$bucket", "%s"]`, bucketName) // Add the key condition, only accept keys equal to the one passed. keyConditionStr := fmt.Sprintf(`["eq", "$key", "%s/upload.txt"]`, objectKey) // Add content length condition, only accept content sizes of a given length.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 29.6K bytes - Viewed (0)