Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 862 for Now (0.01 sec)

  1. callbacks/update.go

    					if v, ok := selectColumns[field.DBName]; (ok && v) || !ok {
    						now := stmt.DB.NowFunc()
    						assignValue(field, now)
    
    						if field.AutoUpdateTime == schema.UnixNanosecond {
    							set = append(set, clause.Assignment{Column: clause.Column{Name: field.DBName}, Value: now.UnixNano()})
    						} else if field.AutoUpdateTime == schema.UnixMillisecond {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Mar 18 05:44:55 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  2. cmd/local-locker.go

    	// lock on all resources at once.
    	now := UTCNow()
    	for i, resource := range args.Resources {
    		l.lockMap[resource] = []lockRequesterInfo{
    			{
    				Name:            resource,
    				Writer:          true,
    				Source:          args.Source,
    				Owner:           args.Owner,
    				UID:             args.UID,
    				Timestamp:       now.UnixNano(),
    				TimeLastRefresh: now.UnixNano(),
    				Group:           len(args.Resources) > 1,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  3. cmd/erasure-common.go

    	"math/rand"
    	"sync"
    	"time"
    )
    
    func (er erasureObjects) getOnlineDisks() (newDisks []StorageAPI) {
    	disks := er.getDisks()
    	var wg sync.WaitGroup
    	var mu sync.Mutex
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	for _, i := range r.Perm(len(disks)) {
    		i := i
    		wg.Add(1)
    		go func() {
    			defer wg.Done()
    			if disks[i] == nil {
    				return
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  4. internal/rest/rpc-stats.go

    	var dialStart, dialEnd int64
    	start := time.Now()
    	trace := &httptrace.ClientTrace{
    		GotFirstResponseByte: func() {
    			atomic.AddUint64(&globalStats.tcpTimeForFirstByteTotalDur, uint64(time.Since(start)))
    		},
    		ConnectStart: func(network, addr string) {
    			atomic.StoreInt64(&dialStart, time.Now().UnixNano())
    		},
    		ConnectDone: func(network, addr string, err error) {
    			if err == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 18:21:34 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/ztunnelserver_test.go

    		panic(err)
    	}
    	err = c.SetWriteDeadline(time.Now().Add(time.Second))
    	if err != nil {
    		panic(err)
    	}
    	c.Write(data)
    }
    
    func sendHello(c *net.UnixConn) {
    	ack := &zdsapi.ZdsHello{
    		Version: zdsapi.Version_V1,
    	}
    	data, err := proto.Marshal(ack)
    	if err != nil {
    		panic(err)
    	}
    	err = c.SetWriteDeadline(time.Now().Add(time.Second))
    	if err != nil {
    		panic(err)
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  6. src/cmd/api/testdata/src/pkg/p1/p1.go

    const (
    	foo          = "foo"
    	foo2  string = "foo2"
    	truth        = foo == "foo" || foo2 == "foo2"
    )
    
    func ellipsis(...string) {}
    
    func Now() Time {
    	var now Time
    	return now
    }
    
    var x = &S{
    	Public:     nil,
    	private:    nil,
    	PublicTime: Now(),
    }
    
    var parenExpr = (1 + 5)
    
    var funcLit = func() {}
    
    var m map[string]int
    
    var chanVar chan int
    
    var ifaceVar any = 5
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Dec 02 16:29:41 UTC 2022
    - 3.3K bytes
    - Viewed (0)
  7. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/FaultTolerantClientTest.java

             */
            @Override
            public ResponseData execute(final RequestData request) {
                final long now = SystemUtil.currentTimeMillis();
                if (now - previousTime < interval) {
                    throw new IllegalStateException();
                }
                previousTime = now;
    
                count++;
                if (count <= exceptionCount) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/util/GsaConfigParser.java

                labelType.setPermissions(new String[] { "Rguest" });
                labelType.setCreatedBy(Constants.SYSTEM_USER);
                labelType.setCreatedTime(now);
                labelType.setUpdatedBy(Constants.SYSTEM_USER);
                labelType.setUpdatedTime(now);
            }
            tagQueue.offer(qName);
        }
    
        @Override
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  9. okhttp-tls/src/test/java/okhttp3/tls/HeldCertificateTest.kt

        val deltaMillis = 1000.0
        val durationMillis = TimeUnit.MINUTES.toMillis((60 * 24).toLong())
        assertThat(certificate.notBefore.time.toDouble())
          .isCloseTo(now.toDouble(), deltaMillis)
        assertThat(certificate.notAfter.time.toDouble())
          .isCloseTo(now.toDouble() + durationMillis, deltaMillis)
      }
    
      @Test
      fun customInterval() {
        // 5 seconds starting on 1970-01-01.
        val heldCertificate =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 22.5K bytes
    - Viewed (0)
  10. src/main/webapp/WEB-INF/view/advance.jsp

    						<option value="[now-1d/d TO *]"
    							<c:if test="${as.timestamp.contains('[now-1d/d TO *]')}">selected</c:if>
    						><la:message key="labels.advance_search_timestamp_pastday" /></option>
    						<option value="[now-1w/d TO *]"
    							<c:if test="${as.timestamp.contains('[now-1w/d TO *]')}">selected</c:if>
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 14.9K bytes
    - Viewed (0)
Back to top