Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 677 for Contexto (0.31 sec)

  1. internal/grid/handlers.go

    	return val
    }
    
    func setCaller(ctx context.Context, cl *RemoteClient) context.Context {
    	//nolint:staticcheck // SA1029 Staticcheck is drunk.
    	return context.WithValue(ctx, ctxCallerKey{}, cl)
    }
    
    func setSubroute(ctx context.Context, s string) context.Context {
    	//nolint:staticcheck // SA1029 Staticcheck is drunk.
    	return context.WithValue(ctx, ctxSubrouteKey{}, s)
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  2. tensorflow/c/eager/c_api_experimental_test.cc

      TFE_CancelCallback callback2;
      bool callback2_invoked = false;
      callback2.context = &callback2_invoked;
      callback2.callback = [](void* context) {
        *reinterpret_cast<bool*>(context) = true;
      };
      TFE_CancellationToken token2 = TFE_CancellationManagerGetToken(c_mgr);
      EXPECT_TRUE(TFE_CancellationManagerRegisterCallback(c_mgr, token2, &callback2,
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Thu Aug 03 03:14:26 UTC 2023
    - 31.5K bytes
    - Viewed (0)
  3. cmd/storage-interface.go

    	DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error
    	DeleteBulk(ctx context.Context, volume string, paths ...string) error
    	WriteMetadata(ctx context.Context, origvolume, volume, path string, fi FileInfo) error
    	UpdateMetadata(ctx context.Context, volume, path string, fi FileInfo, opts UpdateMetadataOpts) error
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  4. cmd/object-api-interface.go

    	MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error
    	GetBucketInfo(ctx context.Context, bucket string, opts BucketOptions) (bucketInfo BucketInfo, err error)
    	ListBuckets(ctx context.Context, opts BucketOptions) (buckets []BucketInfo, err error)
    	DeleteBucket(ctx context.Context, bucket string, opts DeleteBucketOptions) error
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  5. cmd/shared-lock.go

    	go func() {
    		select {
    		case <-ctx1.Done():
    		case <-ctx2.Done():
    		// The lock acquirer decides to cancel, exit this goroutine
    		case <-ctx.Done():
    		}
    
    		cancel()
    	}()
    	return ctx, cancel
    }
    
    func (ld sharedLock) GetLock(ctx context.Context) (context.Context, context.CancelFunc) {
    	l := <-ld.lockContext
    	return mergeContext(l.Context(), ctx)
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Feb 13 09:26:38 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  6. api/go1.8.txt

    pkg database/sql, method (*DB) BeginTx(context.Context, *TxOptions) (*Tx, error)
    pkg database/sql, method (*DB) ExecContext(context.Context, string, ...interface{}) (Result, error)
    pkg database/sql, method (*DB) PingContext(context.Context) error
    pkg database/sql, method (*DB) PrepareContext(context.Context, string) (*Stmt, error)
    pkg database/sql, method (*DB) QueryContext(context.Context, string, ...interface{}) (*Rows, error)
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Wed Dec 21 05:25:57 UTC 2016
    - 16.3K bytes
    - Viewed (0)
  7. logger/logger.go

    	LogLevel                  LogLevel
    }
    
    // Interface logger interface
    type Interface interface {
    	LogMode(LogLevel) Interface
    	Info(context.Context, string, ...interface{})
    	Warn(context.Context, string, ...interface{})
    	Error(context.Context, string, ...interface{})
    	Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error)
    }
    
    var (
    	// Discard logger will print any log to io.Discard
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Tue Nov 07 02:19:41 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  8. tensorflow/c/eager/parallel_device/parallel_device_test.cc

                                  status.get());
      std::unique_ptr<TFE_Context, decltype(&TFE_DeleteContext)> context(
          TFE_NewContext(opts.get(), status.get()), TFE_DeleteContext);
      ASSERT_EQ(TF_GetCode(status.get()), TF_OK) << TF_Message(status.get());
      BasicTestsForTwoDevices(context.get(),
                              "/job:localhost/replica:0/task:0/device:CPU:0",
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Tue Aug 06 23:56:17 UTC 2024
    - 29.4K bytes
    - Viewed (0)
  9. internal/grid/grid_test.go

    	register := func(manager *Manager) {
    		errFatal(manager.RegisterStreamingHandler(handlerTest, StreamHandler{
    			Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr {
    				<-ctx.Done()
    				serverCanceled <- struct{}{}
    				fmt.Println(GetCaller(ctx).Name, "Server Context canceled")
    				return nil
    			},
    			OutCapacity: 1,
    			InCapacity:  0,
    		}))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  10. cmd/logging.go

    func rebalanceLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogIf(ctx, "rebalance", err, errKind...)
    }
    
    func rebalanceLogEvent(ctx context.Context, msg string, args ...interface{}) {
    	logger.Event(ctx, "rebalance", msg, args...)
    }
    
    func adminLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogIf(ctx, "admin", err, errKind...)
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jul 03 18:49:48 UTC 2024
    - 7.1K bytes
    - Viewed (0)
Back to top