- Sort Score
- Result 10 results
- Languages All
Results 971 - 980 of 1,667 for byte1 (0.03 sec)
-
internal/disk/type_bsd.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 19 01:35:22 UTC 2021 - 1.1K bytes - Viewed (0) -
cmd/server-main.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 ( "bytes" "context" "encoding/hex" "errors" "fmt" "io" "log" "math/rand" "net" "os" "os/signal" "path/filepath" "runtime" "strings" "syscall" "time"
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 21:50:11 UTC 2024 - 35.2K bytes - Viewed (4) -
cmd/metrics.go
"Total number of internode bytes received by current MinIO server instance", nil, nil), prometheus.CounterValue, float64(connStats.internodeInputBytes), ) // Network Sent/Received Bytes (Outbound) ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName(s3Namespace, "tx", "bytes_total"), "Total number of s3 bytes sent by current MinIO server instance", nil, nil),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 16.6K bytes - Viewed (0) -
internal/auth/credentials.go
func (cred Credentials) Equal(ccred Credentials) bool { if !ccred.IsValid() { return false } return (cred.AccessKey == ccred.AccessKey && subtle.ConstantTimeCompare([]byte(cred.SecretKey), []byte(ccred.SecretKey)) == 1 && subtle.ConstantTimeCompare([]byte(cred.SessionToken), []byte(ccred.SessionToken)) == 1) } var timeSentinel = time.Unix(0, 0).UTC() // ErrInvalidDuration invalid token expiry
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 28 17:14:16 UTC 2024 - 12K bytes - Viewed (0) -
internal/s3select/jstream/errors.go
) type errPos [2]int // line number, byte offset where error occurred // DecoderError contains a detailed decoding error. type DecoderError struct { msg string // description of error context string // additional error context pos errPos atChar byte readerErr error // underlying reader error, if any } // ReaderErr returns the underlying error.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 1.3K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/Transport.java
/** * GETs the source URI content as byte array. The source MUST BE relative from the {@link RemoteRepository#getUrl()} * root. * * @return the byte array if operation succeeded, {@code null} if source does not exist. * @throws RuntimeException If failed (and not due source not exists). */ @Nonnull Optional<byte[]> getBytes(@Nonnull URI relativeSource); /**
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Thu Mar 23 05:29:39 UTC 2023 - 4.4K bytes - Viewed (0) -
manifests/addons/dashboards/istio-performance-dashboard.json
"mode": "markdown" }, "pluginVersion": "10.1.5", "title": "Performance Dashboard README", "transparent": true,
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Mar 27 03:47:04 UTC 2024 - 39.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/lock/Smb2Lock.java
*/ @Override public int size () { return 24; } /** * {@inheritDoc} * * @see jcifs.Encodable#encode(byte[], int) */ @Override public int encode ( byte[] dst, int dstIndex ) { int start = dstIndex; SMBUtil.writeInt8(this.offset, dst, dstIndex); dstIndex += 8; SMBUtil.writeInt8(this.length, dst, dstIndex);
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 2.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheReferencesTest.java
// observe a size of 1 long initialSize = cache.size(); assertTrue(initialSize == 1 || initialSize == 2); // wait up to 5s byte[] filler = new byte[1024]; for (int i = 0; i < 500; i++) { System.gc(); CacheTesting.drainReferenceQueues(cache); if (cache.size() == 1) { break; } try {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 14:28:19 UTC 2024 - 6.2K bytes - Viewed (0) -
cmd/config.go
historyFile := pathJoin(minioConfigHistoryPrefix, uuidKV+kvPrefix) data, err := readConfig(ctx, objAPI, historyFile) if err != nil { return nil, err } return decryptData(data, historyFile) } func saveServerConfigHistory(ctx context.Context, objAPI ObjectLayer, kv []byte) error { uuidKV := mustGetUUID() + kvPrefix
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 23 10:07:06 UTC 2023 - 6K bytes - Viewed (0)