- Sort Score
- Result 10 results
- Languages All
Results 221 - 230 of 265 for stat (0.04 sec)
-
internal/s3select/simdj/reader.go
if r.readCloser != nil { r.readCloser.Close() } if r.exitReader != nil { close(r.exitReader) r.readerWg.Wait() r.exitReader = nil r.input = nil } return nil } // startReader will start a reader that accepts input from r.input. // Input should be root -> object input. Each root indicates a record. // If r.input is closed, it is assumed that no more input will come.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue May 30 17:02:22 UTC 2023 - 4.9K bytes - Viewed (0) -
src/cmd/asm/internal/asm/operand_test.go
} }() parse() return nil } func testBadOperandParser(t *testing.T, parser *Parser, tests []badOperandTest) { for _, test := range tests { err := tryParse(t, func() { parser.start(lex.Tokenize(test.input)) addr := obj.Addr{} parser.operand(&addr) }) switch { case err == nil: t.Errorf("fail at %s: got no errors; expected %s\n", test.input, test.error)
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Tue Aug 29 18:31:05 UTC 2023 - 23.9K bytes - Viewed (0) -
src/bufio/bufio_test.go
_, _, err = r.ReadRune() // reset state if err != nil { t.Error("unexpected error on ReadRune (2):", err) } _, err = r.Read(buf) if err != nil { t.Error("unexpected error on Read (2):", err) } if r.UnreadRune() == nil { t.Error("expected error after Read (2)") } // Test error after ReadByte. _, _, err = r.ReadRune() // reset state if err != nil {
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Mon Oct 28 21:04:51 UTC 2024 - 51.6K bytes - Viewed (0) -
cmd/warm-backend-gcs.go
// 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. object := gcs.client.Bucket(gcs.Bucket).Object(gcs.getDest(key)).ReadCompressed(true) r, err = object.NewRangeReader(ctx, opts.startOffset, opts.length)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Jun 22 05:26:45 UTC 2024 - 5.8K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
// in 'pool.bin', this is eventually used for decommissioning the pool. func (z *erasureServerPools) Init(ctx context.Context) error { // Load rebalance metadata if present if err := z.loadRebalanceMeta(ctx); err == nil { // Start rebalance routine if we can reload rebalance metadata. z.StartRebalance() } meta := poolMeta{} if err := meta.load(ctx, z.serverPools[0], z.serverPools); err != nil { return err }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 13:20:19 UTC 2024 - 42.2K bytes - Viewed (1) -
src/main/resources/fess_label_de.properties
labels.purgeByBots=Bereinige Aufrufe von Bots labels.purgeSearchLogDay=Bereinige Suchprotokoll labels.query=Anfrage labels.queryId=Anfrage-ID labels.rt=rt labels.searchLog=Protokoll durchsuchen labels.sort=Sortieren labels.start=Start-Pos. labels.loginRequired=Anmeldung erforderlich labels.loginLink=Login-Link labels.threadName=Thread-Name labels.url=URL labels.userFavorite=Lieblingsprotokoll labels.userInfo=Benutzerinfo
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Mar 22 11:58:34 UTC 2024 - 42.8K bytes - Viewed (0) -
docs/bucket/replication/setup_2site_existing_replication.sh
./mc replicate add sitea/bucket/ \ --remote-bucket http://minio:minio123@127.0.0.1:9004/bucket remote_arn=$(./mc replicate ls sitea/bucket --json | jq -r .rule.Destination.Bucket) sleep 1 ./mc replicate resync start sitea/bucket/ --remote-bucket "${remote_arn}" sleep 30s ## sleep for 30s idea is that we give 300ms per object. ./mc ls -r --versions sitea/bucket >/tmp/sitea.txt ./mc ls -r --versions siteb/bucket >/tmp/siteb.txt
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 09:42:21 UTC 2024 - 5.6K bytes - Viewed (0) -
docs/distributed/decom.sh
exit 1 fi ./mc mirror cmd myminio/versioned/ --quiet >/dev/null ./mc ls -r myminio/versioned/ >expanded_ns.txt ./mc ls -r --versions myminio/versioned/ >expanded_ns_versions.txt ./mc admin decom start myminio/ http://localhost:9000/tmp/xl/{1...10}/disk{0...1} count=0 until $(./mc admin decom status myminio/ | grep -q Complete); do echo "waiting for decom to finish..." count=$((count + 1))
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon May 27 19:17:46 UTC 2024 - 6.4K bytes - Viewed (0) -
doc/asm.html
(The prototype will also let <code>go</code> <code>vet</code> check the argument references.) At the start of the function, the arguments are assumed to be initialized but the results are assumed uninitialized. If the results will hold live pointers during a call instruction, the function should start by zeroing the results and then executing the pseudo-instruction <code>GO_RESULTS_INITIALIZED</code>.
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Tue Nov 28 19:15:27 UTC 2023 - 36.3K bytes - Viewed (1) -
internal/logger/console.go
// of splitting error text and always pretty printing the // red banner along with the error message. Since the error // message itself contains some colored text, we needed // to use some ANSI control escapes to cursor color state // and freely move in the screen. for _, line := range strings.Split(errMsg, "\n") { if len(line) == 0 { // No more text to print, just quit. break } for {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 7.5K bytes - Viewed (0)