- Sort Score
- Result 10 results
- Languages All
Results 191 - 200 of 463 for donde (0.03 sec)
-
cmd/bucket-replication_test.go
ResetID: "xyz", ResetBeforeDate: UTCNow(), }}}, }, }, { // 10. existing object replication enabled, versioning enabled, replication status Complete & reset done name: "reset done on object in Completed Status - ineligbile for re-replication", info: ObjectInfo{ Size: 100, ReplicationStatusInternal: "arn1:COMPLETED;",
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Sep 16 09:28:06 UTC 2023 - 12.2K bytes - Viewed (0) -
cmd/metacache-manager.go
time.Sleep(time.Second) objAPI = newObjectLayerFn() } t := time.NewTicker(time.Minute) defer t.Stop() var exit bool for !exit { select { case <-t.C: case <-GlobalContext.Done(): exit = true } m.mu.RLock() for _, v := range m.buckets { if !exit { v.cleanup() } } m.mu.RUnlock() m.mu.Lock() for k, v := range m.trash {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Oct 25 00:44:15 UTC 2022 - 5.2K bytes - Viewed (0) -
ci/official/containers/linux_arm64/devel.usertools/aarch64_clang.bazelrc
# drops all the bazel dependencies for each py_test; this makes all the tests # use the wheel's TensorFlow installation instead of the one made available # through bazel. This must be done in a different root directory, //bazel_pip/..., # because "import tensorflow" run from the root directory would instead import # the folder instead of the venv package. #
Registered: Tue Oct 29 12:39:09 UTC 2024 - Last Modified: Fri Jul 12 20:16:57 UTC 2024 - 6.2K bytes - Viewed (0) -
docs/distributed/DECOMMISSION.md
- On Kubernetes setups, the statefulset specification needs to be modified by changing the command line input for the MinIO container. Once the relevant changes are done, proceed to execute `kubectl apply -f statefulset.yaml`.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jul 11 14:59:49 UTC 2022 - 8.3K bytes - Viewed (0) -
cmd/untar.go
return err } wg.Add(1) go func(name string, fi fs.FileInfo, b []byte) { rc := disconnectReader{r: bytes.NewReader(b)} defer func() { rc.Close() <-asyncWriters wg.Done() //nolint:staticcheck // SA6002 we are fine with the tiny alloc poolBuf128k.Put(b) }() if err := putObject(&rc, fi, name); err != nil { if o.ignoreErrs { s3LogIf(ctx, err)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 6K bytes - Viewed (0) -
docs/distributed/distributed-from-config-file.sh
- 'http://localhost:9004/tmp/xl/node9004/mnt/disk2/' - 'http://localhost:9004/tmp/xl/node9004/mnt/disk3/' - 'http://localhost:9004/tmp/xl/node9004/mnt/disk4/' EOF done minio server --config /tmp/minio.configfile.1 >/tmp/minio1_1.log 2>&1 & site1_pid=$! minio server --config /tmp/minio.configfile.2 >/tmp/minio2_1.log 2>&1 & site2_pid=$!
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jun 28 09:06:49 UTC 2024 - 3.3K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn_test.go
serverAddr := l.Addr().String() tcpListener, ok := l.(*net.TCPListener) if !ok { 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)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Nov 05 18:09:21 UTC 2022 - 3K bytes - Viewed (0) -
cmd/common-main.go
// Baremetal setups set DNS refresh window up to dnsTTL duration. t := time.NewTicker(dnsTTL) defer t.Stop() for { select { case <-t.C: globalDNSCache.Refresh() case <-GlobalContext.Done(): return } } }() } type envKV struct { Key string Value string Skip bool } func (e envKV) String() string { if e.Skip { return "" }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Sep 24 21:50:11 UTC 2024 - 31.7K bytes - Viewed (0) -
internal/store/batch_test.go
t.Log(err) }, }) defer batch.Close() var wg sync.WaitGroup for i := 0; i < int(limit); i++ { wg.Add(1) go func(key int) { defer wg.Done() if err := batch.Add(testItem); err != nil { t.Errorf("failed to add item %v; %v", key, err) return } }(i) } wg.Wait() batchLen := batch.Len() if batchLen != int(limit) {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 5.6K bytes - Viewed (0) -
ci/official/utilities/setup.sh
# Sources every env, in order, from the comma-separated list "TFCI" # Assumes variables will resolve themselves correctly. set +u for env_file in ${TFCI//,/ }; do source "./ci/official/envs/$env_file" done set -u echo '==TFCI==: Evaluated the following TFCI variables from $TFCI:' export -p | grep TFCI # Load those stored pre-existing TFCI_ vars, if any if [[ -s "$FROM_ENV" ]]; then
Registered: Tue Oct 29 12:39:09 UTC 2024 - Last Modified: Wed Aug 07 23:01:25 UTC 2024 - 6K bytes - Viewed (0)