- Sort Score
- Result 10 results
- Languages All
Results 191 - 200 of 1,339 for contextos (0.07 sec)
-
internal/logger/target/testlogger/testlogger.go
return types.TargetStats{} } func (t *testLogger) Init(ctx context.Context) error { return nil } func (t *testLogger) IsOnline(ctx context.Context) bool { return t.current.Load() != nil } func (t *testLogger) Cancel() { t.current.Store(nil) } func (t *testLogger) Send(ctx context.Context, entry interface{}) error { tb := t.current.Load()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4K bytes - Viewed (0) -
internal/s3select/jstream/scratch.go
package jstream import ( "unicode/utf8" ) type scratch struct { data []byte fill int } // reset scratch buffer func (s *scratch) reset() { s.fill = 0 } // bytes returns the written contents of scratch buffer func (s *scratch) bytes() []byte { return s.data[0:s.fill] } // grow scratch buffer func (s *scratch) grow() { ndata := make([]byte, cap(s.data)*2) copy(ndata, s.data) s.data = ndata }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 758 bytes - Viewed (0) -
cmd/perf-tests.go
} // Read a single byte. n, err = f.r.Read(p[:1]) if n > 0 { t := time.Now() f.t = &t } return n, err } // Runs the speedtest on local MinIO process. func selfSpeedTest(ctx context.Context, opts speedTestOpts) (res SpeedTestResult, err error) { objAPI := newObjectLayerFn() if objAPI == nil { return SpeedTestResult{}, errServerNotInitialized } var wg sync.WaitGroup var errOnce sync.Once
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.8K bytes - Viewed (0) -
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 Nov 05 12:39:12 UTC 2024 - Last Modified: Tue Aug 06 23:56:17 UTC 2024 - 29.4K bytes - Viewed (0) -
cmd/local-locker.go
for _, resource := range resources { _, lockTaken := l.lockMap[resource] if lockTaken { return false } } return true } func (l *localLocker) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { if len(args.Resources) > maxDeleteList { return false, fmt.Errorf("internal error: localLocker.Lock called with more than %d resources", maxDeleteList) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 10.7K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
} } } return nil } func (z *erasureServerPools) doDecommissionInRoutine(ctx context.Context, idx int) { z.poolMetaMutex.Lock() var dctx context.Context dctx, z.decommissionCancelers[idx] = context.WithCancel(GlobalContext) z.poolMetaMutex.Unlock() // Generate an empty request info so it can be directly modified later by audit
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 13:20:19 UTC 2024 - 42.2K bytes - Viewed (0) -
compat/maven-model-builder/src/test/java/org/apache/maven/model/building/BuildModelSourceTransformerTest.java
.groupId("GROUPID") .artifactId("ARTIFACTID") .version("1.0-SNAPSHOT") .build()); Mockito.when(context.getRawModel(pomFile, root.resolve("pom.xml"))).thenReturn(parent); Mockito.when(context.locate(root)).thenReturn(root.resolve("pom.xml")); Model initial = new Model(org.apache.maven.api.model.Model.newBuilder()
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 6.1K bytes - Viewed (0) -
cmd/metrics-v3-system-process.go
processVirtualMemoryMaxBytesMD = NewGaugeMD(processVirtualMemoryMaxBytes, "Maximum virtual memory size in bytes") ) func loadProcStatMetrics(ctx context.Context, stat procfs.ProcStat, m MetricValues) { if stat.CPUTime() > 0 { m.Set(processCPUTotalSeconds, float64(stat.CPUTime())) } if stat.ResidentMemory() > 0 {
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/iam-store.go
getUsersSysType() UsersSysType loadPolicyDoc(ctx context.Context, policy string, m map[string]PolicyDoc) error loadPolicyDocWithRetry(ctx context.Context, policy string, m map[string]PolicyDoc, retries int) error loadPolicyDocs(ctx context.Context, m map[string]PolicyDoc) error loadUser(ctx context.Context, user string, userType IAMUserType, m map[string]UserIdentity) error loadSecretKey(ctx context.Context, user string, userType IAMUserType) (string, error)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Oct 14 16:35:37 UTC 2024 - 83.2K bytes - Viewed (0) -
src/test/java/org/codelibs/core/xml/DomUtilTest.java
/** * @throws Exception */ public void testGetContentsAsStream() throws Exception { final String contents = "<?xml version=\"1.0\" encoding=\"UTF-8\"?><foo/>"; assertNotNull("1", DomUtil.getContentsAsStream(contents, "UTF-8")); } /** * @throws Exception */ public void testToString() throws Exception {
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 1.6K bytes - Viewed (0)