Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 1,339 for contextos (0.07 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top