- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 83 for eidx (0.86 sec)
-
cmd/admin-handlers-pools.go
return } } var pool *erasureSets for pidx := range z.serverPools { if pidx == idx { pool = z.serverPools[idx] break } } if pool == nil { // We didn't find any matching pools, invalid input writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errInvalidArgument), r.URL) return } poolIndices = append(poolIndices, idx) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 10.9K bytes - Viewed (0) -
cmd/erasure-server-pool.go
var wg sync.WaitGroup for idx, pool := range z.serverPools { if z.IsSuspended(idx) { continue } wg.Add(1) go func(idx int, pool *erasureSets) { defer wg.Done() result, err := pool.HealObject(ctx, bucket, object, versionID, opts) result.Object = decodeDirObject(result.Object) errs[idx] = err results[idx] = result }(idx, pool) } wg.Wait()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 11:58:12 UTC 2024 - 82.5K bytes - Viewed (0) -
internal/http/listener.go
// Closure to handle TCPListener until done channel is closed. handleListener := func(idx int, listener net.Listener) { for { conn, err := listener.Accept() send(acceptResult{conn, err, idx}) } } // Start separate goroutine for each TCP listener to handle connection. for idx, tcpListener := range listener.listeners { go handleListener(idx, tcpListener) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 5.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/stablehlo/python/integration_test/quantize_model_test_base.py
if c in y_labels: contracting_dims.add(c) x_signature = [ None if c not in contracting_dims else x_shape[cidx] for cidx, c in enumerate(x_labels) ] y_signature = [ None if c not in contracting_dims else y_shape[cidx] for cidx, c in enumerate(y_labels) ] return x_shape, y_shape, bias_shape, x_signature, y_signature def _create_einsum_model(
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue May 14 06:31:57 UTC 2024 - 18.2K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/debug.go
splitOf: split, splitOffset: ls.SplitOffset, } if idx, ok := sc.slmap[k]; ok { return idx, true } rv := SlKeyIdx(len(sc.slkeys)) sc.slkeys = append(sc.slkeys, ls) sc.slmap[k] = rv return rv, false } func (sc *slotCanonicalizer) canonSlot(idx SlKeyIdx) LocalSlot { return sc.slkeys[idx] } // PopulateABIInRegArgOps examines the entry block of the function
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 19:44:43 UTC 2024 - 58.4K bytes - Viewed (0) -
scan.go
if db.Statement.Schema != nil { for idx, name := range columns { if field := db.Statement.Schema.LookUpField(name); field != nil { values[idx] = reflect.New(reflect.PtrTo(field.FieldType)).Interface() continue } values[idx] = new(interface{}) } } else if len(columnTypes) > 0 { for idx, columnType := range columnTypes { if columnType.ScanType() != nil {
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed Jun 12 10:57:36 UTC 2024 - 10K bytes - Viewed (0) -
cmd/metacache-entries.go
if len(dir) == 0 { // Root idx := strings.Index(e.name, separator) return idx == -1 || idx == len(e.name)-len(separator) } ext := strings.TrimPrefix(e.name, dir) if len(ext) != len(e.name) { idx := strings.Index(ext, separator) // If separator is not found or is last entry, ok. return idx == -1 || idx == len(ext)-len(separator) } return false }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 04:34:26 UTC 2024 - 24K bytes - Viewed (0) -
cmd/peer-s3-client.go
for idx, client := range sys.peerClients { idx := idx client := client g.Go(func() error { if client == nil { return errPeerOffline } res, err := client.HealBucket(ctx, bucket, opts) if err != nil { return err } healBucketResults[idx] = res return nil }, idx) } errs = g.Wait()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.3K bytes - Viewed (0) -
cmd/notification.go
states := make([]madmin.BgHealState, len(sys.peerClients)) for idx, client := range sys.peerClients { idx := idx client := client ng.Go(ctx, func() error { if client == nil { return errPeerNotReachable } st, err := client.BackgroundHealStatus(ctx) if err != nil { return err } states[idx] = st return nil }, idx, *client.host) } return states, ng.Wait() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 44.9K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/tensorflow/passes/prepare_lifting.cc
int val2_result = 1; for (auto idx : val1_indices) { if (idx < 0) idx = idx + val1_shape.getRank(); if (idx >= val1_shape.getRank() || val1_shape.isDynamicDim(idx)) { return false; } val1_result *= val1_shape.getDimSize(idx); } for (auto idx : val2_indices) { if (idx < 0) idx = idx + val2_shape.getRank(); if (idx >= val2_shape.getRank() || val2_shape.isDynamicDim(idx)) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 17 17:58:54 UTC 2024 - 13.3K bytes - Viewed (0)