Search Options

Results per page
Sort
Preferred Languages
Advance

Results 341 - 350 of 391 for ctx_ (0.1 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top