Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 60 of 913 for ftime (0.03 seconds)

  1. src/test/java/jcifs/smb1/smb1/SmbComQueryInformationResponseTest.java

            byte[] buffer = new byte[20];
            // File Attributes: 0x0010 (Directory)
            buffer[0] = 0x10;
            buffer[1] = 0x00;
            // Last Write Time (UTime): A sample timestamp in milliseconds
            long sampleTimeMillis = 1672531200000L; // Represents a specific date in milliseconds
            ServerMessageBlock.writeUTime(sampleTimeMillis, buffer, 2);
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 5.5K bytes
    - Click Count (0)
  2. cmd/xl-storage-format-v2.go

    // getModTime will return the ModTime of the underlying version.
    func (j xlMetaV2Version) getModTime() time.Time {
    	switch j.Type {
    	case ObjectType:
    		return time.Unix(0, j.ObjectV2.ModTime)
    	case DeleteType:
    		return time.Unix(0, j.DeleteMarker.ModTime)
    	case LegacyType:
    		return j.ObjectV1.Stat.ModTime
    	}
    	return time.Time{}
    }
    
    // getVersionID will return the versionID of the underlying version.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 65.6K bytes
    - Click Count (1)
  3. cmd/bucket-replication.go

    	startTime := time.Now()
    	return func(sz int64, err error) {
    		duration := time.Since(startTime)
    		if globalTrace.NumSubscribers(madmin.TraceReplicationResync) > 0 {
    			globalTrace.Publish(replicationResyncTrace(resyncID, startTime, duration, path, err, sz))
    		}
    	}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
  4. cmd/erasure-sets.go

    func (s *erasureSets) monitorAndConnectEndpoints(ctx context.Context, monitorInterval time.Duration) {
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	time.Sleep(time.Duration(r.Float64() * float64(time.Second)))
    
    	// Pre-emptively connect the disks if possible.
    	s.connectDisks(false)
    
    	monitor := time.NewTimer(monitorInterval)
    	defer monitor.Stop()
    
    	for {
    		select {
    		case <-ctx.Done():
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37K bytes
    - Click Count (1)
  5. internal/cachevalue/cache_test.go

    		func(ctx context.Context) (time.Time, error) {
    			return time.Now(), nil
    		},
    	)
    
    	t1, _ := cache.Get()
    
    	t2, _ := cache.Get()
    
    	if !t1.Equal(t2) {
    		t.Fatalf("expected time to be equal: %s != %s", t1, t2)
    	}
    
    	time.Sleep(3 * time.Second)
    	t3, _ := cache.Get()
    
    	if t1.Equal(t3) {
    		t.Fatalf("expected time to be un-equal: %s == %s", t1, t3)
    	}
    }
    
    func BenchmarkCache(b *testing.B) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  6. internal/deadlineconn/deadlineconn.go

    // A zero value for t means I/O operations will not time out.
    func (c *DeadlineConn) SetDeadline(t time.Time) error {
    	c.mu.Lock()
    	defer c.mu.Unlock()
    
    	c.readSetAt = time.Time{}
    	c.writeSetAt = time.Time{}
    	c.abortReads.Store(!t.IsZero() && time.Until(t) < 0)
    	c.abortWrites.Store(!t.IsZero() && time.Until(t) < 0)
    	c.infReads.Store(t.IsZero())
    	c.infWrites.Store(t.IsZero())
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Dec 02 13:21:17 GMT 2024
    - 5.1K bytes
    - Click Count (0)
  7. internal/http/listener_test.go

    		{[]string{"unknown-host:65432"}, time.Duration(0), time.Duration(0), time.Duration(0), []bool{true}},                            // 4
    		{[]string{"localhost:65432"}, time.Duration(0), time.Duration(0), time.Duration(0), []bool{false}},                              // 5
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  8. cmd/os-instrumented.go

    }
    
    // time an os action.
    func (o *osMetrics) time(s osMetric) func() {
    	startTime := time.Now()
    	return func() {
    		duration := time.Since(startTime)
    
    		atomic.AddUint64(&o.operations[s], 1)
    		o.latency[s].add(duration)
    	}
    }
    
    // incTime will increment time on metric s with a specific duration.
    func (o *osMetrics) incTime(s osMetric, d time.Duration) {
    	atomic.AddUint64(&o.operations[s], 1)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  9. impl/maven-core/src/main/java/org/apache/maven/execution/BuildSummary.java

        /**
         * The total amount of time spent for to run mojos in milliseconds.
         */
        private final Duration execTime;
    
        /**
         * Creates a new build summary for the specified project.
         *
         * @param project The project being summarized, must not be {@code null}.
         * @param time The build time of the project in milliseconds.
         */
        protected BuildSummary(MavenProject project, long time) {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Dec 12 11:02:17 GMT 2024
    - 3K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/helper/IntervalControlHelper.java

            }
        }
    
        /**
         * Parses a time string in HH:MM format.
         *
         * @param time the time string to parse
         * @return an array containing [hour, minute]
         * @throws FessSystemException if the time format is invalid
         */
        protected static int[] parseTime(final String time) {
            final String[] froms = time.split(":");
            if (froms.length != 2) {
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Sun Nov 23 12:34:02 GMT 2025
    - 10K bytes
    - Click Count (0)
Back to Top