Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 453 for ctx_ (0.06 sec)

  1. internal/grid/connection.go

    	"github.com/zeebo/xxh3"
    )
    
    func gridLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogIf(ctx, "grid", err, errKind...)
    }
    
    func gridLogIfNot(ctx context.Context, err error, ignored ...error) {
    	logger.LogIfNot(ctx, "grid", err, ignored...)
    }
    
    func gridLogOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) {
    	logger.LogOnceIf(ctx, "grid", err, id, errKind...)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  2. cmd/background-newdisks-heal-ops.go

    		return err
    	}
    	globalBackgroundHealState.updateHealStatus(h)
    	return h.disk.WriteAll(ctx, minioMetaBucket,
    		pathJoin(bucketMetaPrefix, healingTrackerFilename),
    		htrackerBytes)
    }
    
    // delete the tracker on disk.
    func (h *healingTracker) delete(ctx context.Context) error {
    	return h.disk.Delete(ctx, minioMetaBucket,
    		pathJoin(bucketMetaPrefix, healingTrackerFilename),
    		DeleteOptions{
    			Recursive: false,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  3. src/main/java/jcifs/internal/smb1/com/SmbComNegotiateResponse.java

    
        /**
         * 
         * @param ctx
         */
        public SmbComNegotiateResponse ( CIFSContext ctx ) {
            super(ctx.getConfig());
            this.server = new ServerData();
            this.capabilities = ctx.getConfig().getCapabilities();
            this.negotiatedFlags2 = ctx.getConfig().getFlags2();
            this.maxMpxCount = ctx.getConfig().getMaxMpxCount();
            this.snd_buf_size = ctx.getConfig().getSendBufferSize();
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Tue Jul 07 10:52:42 UTC 2020
    - 15.4K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/cni-watcher_test.go

    	fs.On("AddPodToMesh",
    		ctx,
    		mock.IsType(pod),
    		util.GetPodIPsIfPresent(pod),
    		valid.Netns,
    	).Return(nil)
    
    	dpServer := getFakeDP(fs, client.Kube())
    
    	handlers := setupHandlers(ctx, client, dpServer, "istio-system")
    
    	// We are not going to start the server, so the sockpath is irrelevant
    	pluginServer := startCniPluginServer(ctx, "/tmp/test.sock", handlers, dpServer)
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/net_test.go

    	podIPs := []netip.Addr{podIP}
    
    	err := netServer.AddPodToMesh(ctx, &corev1.Pod{ObjectMeta: podMeta}, podIPs, "fakenetns")
    	assert.NoError(t, err)
    	assert.Equal(t, 1, ztunnelServer.addedPods.Load())
    }
    
    func TestServerRemovePod(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    	setupLogging()
    	fixture := getTestFixure(ctx)
    	netServer := fixture.netServer
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 25 16:13:38 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  6. cmd/erasure.go

    					continue
    				}
    				scannerLogOnceIf(ctx, cache.save(ctx, er, dataUsageCacheName), "nsscanner-cache-update")
    				updates <- cache.clone()
    
    				lastSave = cache.Info.LastUpdate
    			case v, ok := <-bucketResults:
    				if !ok {
    					// Save final state...
    					cache.Info.NextCycle = wantCycle
    					cache.Info.LastUpdate = time.Now()
    					scannerLogOnceIf(ctx, cache.save(ctx, er, dataUsageCacheName), "nsscanner-channel-closed")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  7. cmd/metrics-v3-system-process.go

    	}
    }
    
    func loadProcFSMetrics(ctx context.Context, p procfs.Proc, m MetricValues) {
    	stat, err := p.Stat()
    	if err != nil {
    		metricsLogIf(ctx, err)
    	} else {
    		loadProcStatMetrics(ctx, stat, m)
    	}
    
    	io, err := p.IO()
    	if err != nil {
    		metricsLogIf(ctx, err)
    	} else {
    		loadProcIOMetrics(ctx, io, m)
    	}
    
    	l, err := p.Limits()
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 20 17:55:03 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  8. cmd/bucket-quota.go

    	bucketStorageCache.InitOnce(10*time.Second,
    		cachevalue.Opts{ReturnLastGood: true, NoWait: true},
    		func(ctx context.Context) (DataUsageInfo, error) {
    			if objAPI == nil {
    				return DataUsageInfo{}, errServerNotInitialized
    			}
    			ctx, done := context.WithTimeout(ctx, 2*time.Second)
    			defer done()
    
    			return loadDataUsageFromBackend(ctx, objAPI)
    		},
    	)
    }
    
    // GetBucketUsageInfo return bucket usage info for a given bucket
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  9. internal/kms/kms.go

    // for multiple KMS/KES servers.
    func (k *KMS) Version(ctx context.Context) (string, error) {
    	return k.conn.Version(ctx)
    }
    
    // APIs returns a list of KMS server APIs.
    //
    // TODO(aead): remove this API since it's hardly useful.
    func (k *KMS) APIs(ctx context.Context) ([]madmin.KMSAPI, error) {
    	return k.conn.APIs(ctx)
    }
    
    // Metrics returns a current snapshot of the KMS metrics.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  10. internal/kms/kes.go

    )
    
    type kesConn struct {
    	defaultKeyID string
    	client       *kes.Client
    }
    
    func (c *kesConn) Version(ctx context.Context) (string, error) {
    	return c.client.Version(ctx)
    }
    
    func (c *kesConn) APIs(ctx context.Context) ([]madmin.KMSAPI, error) {
    	APIs, err := c.client.APIs(ctx)
    	if err != nil {
    		if errors.Is(err, kes.ErrNotAllowed) {
    			return nil, ErrPermission
    		}
    		return nil, Error{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 7.3K bytes
    - Viewed (0)
Back to top