- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 453 for ctx_ (0.06 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)