- Sort Score
- Result 10 results
- Languages All
Results 341 - 350 of 391 for ctx_ (0.04 sec)
-
tensorflow/c/eager/gradient_checker.h
* * `numerical_grad` is the pointer to the AbstractTensorHandle* which will * hold the numerical gradient data at the end of the function. */ absl::Status CalcNumericalGrad(AbstractContext* ctx, Model forward, absl::Span<AbstractTensorHandle* const> inputs, int input_index, bool use_function, AbstractTensorHandle** numerical_grad);
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Sat Oct 12 05:11:17 UTC 2024 - 1.8K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer.go
// A goroutine will be started and run until the provided context is canceled. func (r *RingBuffer) WithCancel(ctx context.Context) *RingBuffer { go func() { select { case <-ctx.Done(): r.CloseWithError(ctx.Err()) } }() return r } func (r *RingBuffer) setErr(err error, locked bool) error { if !locked { r.mu.Lock() defer r.mu.Unlock() }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/metrics-v3-logger-webhook.go
"Total number of messages sent to this target", allWebhookLabels...) ) // loadLoggerWebhookMetrics - `MetricsLoaderFn` for logger webhook // such as failed messages and total messages. func loadLoggerWebhookMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { tgts := append(logger.SystemTargets(), logger.AuditTargets()...) for _, t := range tgts { labels := []string{nameL, t.String(), endpointL, t.Endpoint()}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 14 07:27:33 UTC 2024 - 2K bytes - Viewed (0) -
cmd/metrics-v3-cluster-erasure-set.go
) func b2f(v bool) float64 { if v { return 1 } return 0 } // loadClusterErasureSetMetrics - `MetricsLoaderFn` for cluster storage erasure // set metrics. func loadClusterErasureSetMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { result, _ := c.esetHealthResult.Get() m.Set(erasureSetOverallWriteQuorum, float64(result.WriteQuorum)) m.Set(erasureSetOverallHealth, b2f(result.Healthy))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 14 07:25:56 UTC 2024 - 4.4K bytes - Viewed (0) -
cmd/erasure-utils.go
size += len(block) } return size } // Writes all the data blocks from encoded blocks until requested // outSize length. Provides a way to skip bytes until the offset. func writeDataBlocks(ctx context.Context, dst io.Writer, enBlocks [][]byte, dataBlocks int, offset int64, length int64) (int64, error) { // Offset and out size cannot be negative. if offset < 0 || length < 0 { return 0, errUnexpected }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jan 31 02:11:45 UTC 2024 - 3.1K bytes - Viewed (0) -
cmd/bucket-replication_test.go
}, rcfg: replicationConfig{Config: &configs[0]}, expectedSync: false, }, } func TestReplicationResync(t *testing.T) { ctx := context.Background() for i, test := range replicationConfigTests { if sync := test.rcfg.Resync(ctx, test.info, test.dsc, test.tgtStatuses); sync.mustResync() != test.expectedSync {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Sep 16 09:28:06 UTC 2023 - 12.2K bytes - Viewed (0) -
docs/sts/web-identity.go
fmt.Println(err) return } scopes := ddoc.ScopesSupported if clientScopes != "" { scopes = strings.Split(clientScopes, ",") } ctx := context.Background() config := oauth2.Config{ ClientID: clientID, ClientSecret: clientSec, Endpoint: oauth2.Endpoint{ AuthURL: ddoc.AuthEndpoint, TokenURL: ddoc.TokenEndpoint, },
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 19 09:13:33 UTC 2023 - 7.8K bytes - Viewed (0) -
cmd/metrics-v3-replication.go
) // loadClusterReplicationMetrics - `MetricsLoaderFn` for cluster replication metrics // such as transfer rate and objects queued. func loadClusterReplicationMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { st := globalReplicationStats.Load() if st == nil { return nil } qs := st.getNodeQueueStatsSummary() qt := qs.QStats
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 4.6K bytes - Viewed (0) -
cmd/storage-rest-server.go
bodyDoneCh := make(chan struct{}) doneCh := make(chan error) ctx := r.Context() go func() { canWrite := true write := func(b []byte) { if canWrite { n, err := w.Write(b) if err != nil || n != len(b) { canWrite = false } } } // Wait for body to be read. select { case <-ctx.Done(): case <-bodyDoneCh: case err := <-doneCh: if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 45.7K bytes - Viewed (0) -
internal/config/storageclass/storage-class.go
} else { cfg.inlineBlock = 128 * humanize.KiByte } cfg.initialized = true return cfg, nil } func configLogOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) { logger.LogOnceIf(ctx, "config", err, id, errKind...)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 12:24:04 UTC 2024 - 12.3K bytes - Viewed (0)