Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 453 for ctx_ (0.03 sec)

  1. internal/logger/logger.go

    	logIf(ctx, subsystem, err)
    }
    
    func errToEntry(ctx context.Context, subsystem string, err error, errKind ...interface{}) log.Entry {
    	var l string
    	if anonFlag {
    		l = reflect.TypeOf(err).String()
    	} else {
    		l = fmt.Sprintf("%v (%T)", err, err)
    	}
    	return buildLogEntry(ctx, subsystem, l, getTrace(3), errKind...)
    }
    
    func logToEntry(ctx context.Context, subsystem, message string, errKind ...interface{}) log.Entry {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 09:43:48 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/cni-watcher.go

    	handlers              K8sHandlers
    	dataplane             MeshDataplane
    
    	sockAddress string
    	ctx         context.Context
    }
    
    func startCniPluginServer(ctx context.Context, pluginSocket string,
    	handlers K8sHandlers,
    	dataplane MeshDataplane,
    ) *CniPluginServer {
    	ctx, cancel := context.WithCancel(ctx)
    	mux := http.NewServeMux()
    	s := &CniPluginServer{
    		handlers:  handlers,
    		dataplane: dataplane,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  3. internal/dsync/drwmutex.go

    func (dm *DRWMutex) lockBlocking(ctx context.Context, lockLossCallback func(), id, source string, isReadLock bool, opts Options) (locked bool) {
    	restClnts, _ := dm.clnt.GetLockers()
    
    	// Create lock array to capture the successful lockers
    	locks := make([]string, len(restClnts))
    
    	// Add total timeout
    	ctx, cancel := context.WithTimeout(ctx, opts.Timeout)
    	defer cancel()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  4. interfaces.go

    }
    
    type ParamsFilter interface {
    	ParamsFilter(ctx context.Context, sql string, params ...interface{}) (string, []interface{})
    }
    
    // ConnPool db conns pool interface
    type ConnPool interface {
    	PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
    	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
    	QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Aug 19 13:33:31 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  5. cmd/bucket-object-lock.go

    		return mode, retainDate, legalHold, ErrNone
    	}
    
    	opts, err := getOpts(ctx, rq, bucket, object)
    	if err != nil {
    		return mode, retainDate, legalHold, toAPIErrorCode(ctx, err)
    	}
    
    	replica := rq.Header.Get(xhttp.AmzBucketReplicationStatus) == replication.Replica.String()
    
    	if opts.VersionID != "" && !replica {
    		if objInfo, err := getObjectInfoFn(ctx, bucket, object, opts); err == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  6. cmd/bucket-metadata.go

    func readBucketMetadata(ctx context.Context, api ObjectLayer, name string) (BucketMetadata, error) {
    	if name == "" {
    		internalLogIf(ctx, errors.New("bucket name cannot be empty"), logger.WarningKind)
    		return BucketMetadata{}, errInvalidArgument
    	}
    	b := newBucketMetadata(name)
    	configFile := path.Join(bucketMetaPrefix, name, bucketMetadataFile)
    	data, err := readConfig(ctx, api, configFile)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  7. cmd/warm-backend.go

    type WarmBackend interface {
    	Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error)
    	PutWithMeta(ctx context.Context, object string, r io.Reader, length int64, meta map[string]string) (remoteVersionID, error)
    	Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (io.ReadCloser, error)
    	Remove(ctx context.Context, object string, rv remoteVersionID) error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 4K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/SmbTreeConnection.java

        private static final Random RAND = new Random();
    
    
        protected SmbTreeConnection ( CIFSContext ctx ) {
            this.ctx = ctx;
            this.delegate = null;
        }
    
    
        protected SmbTreeConnection ( SmbTreeConnection treeConnection ) {
            this.ctx = treeConnection.ctx;
            this.delegate = treeConnection;
        }
    
    
        static SmbTreeConnection create ( CIFSContext c ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Tue Jul 07 10:50:16 UTC 2020
    - 31K bytes
    - Viewed (0)
  9. tensorflow/c/eager/c_api_debug_test.cc

      TFE_DeleteContext(ctx);
      TF_DeleteStatus(status);
    }
    
    TEST(CApiDebug, 2DCPU) {
      TF_Status* status = TF_NewStatus();
      TFE_ContextOptions* opts = TFE_NewContextOptions();
      TFE_Context* ctx = TFE_NewContext(opts, status);
      CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      TFE_DeleteContextOptions(opts);
    
      TFE_TensorHandle* h = TestMatrixTensorHandle3X2(ctx);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Apr 06 22:10:09 UTC 2020
    - 2.3K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/ztunnelserver.go

    )
    
    var ztunnelConnected = monitoring.NewGauge("ztunnel_connected",
    	"number of connections to ztunnel")
    
    type ZtunnelServer interface {
    	Run(ctx context.Context)
    	PodDeleted(ctx context.Context, uid string) error
    	PodAdded(ctx context.Context, pod *v1.Pod, netns Netns) error
    	Close() error
    }
    
    /*
    To clean up stale ztunnels
    
    	we may need to ztunnel to send its (uid, bootid / boot time) to us
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
Back to top