Search Options

Results per page
Sort
Preferred Languages
Advance

Results 571 - 580 of 1,556 for times (0.07 sec)

  1. cmd/bootstrap-peer-server.go

    		select {
    		case <-ctx.Done():
    			return ctx.Err()
    		default:
    			// Sleep and stagger to avoid blocked CPU and thundering
    			// herd upon start up sequence.
    			time.Sleep(25*time.Millisecond + time.Duration(rand.Int63n(int64(100*time.Millisecond))))
    			retries++
    			// after 20 retries start logging that servers are not reachable yet
    			if retries >= 20 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. gorm.go

    	}
    
    	if config.Logger == nil {
    		config.Logger = logger.Default
    	}
    
    	if config.NowFunc == nil {
    		config.NowFunc = func() time.Time { return time.Now().Local() }
    	}
    
    	if dialector != nil {
    		config.Dialector = dialector
    	}
    
    	if config.Plugins == nil {
    		config.Plugins = map[string]Plugin{}
    	}
    
    	if config.cacheStore == nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Oct 09 11:29:48 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  3. internal/http/dial_linux.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package http
    
    import (
    	"context"
    	"net"
    	"syscall"
    	"time"
    
    	"github.com/minio/minio/internal/deadlineconn"
    	"golang.org/x/sys/unix"
    )
    
    func setTCPParametersFn(opts TCPOptions) func(network, address string, c syscall.RawConn) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  4. cmd/erasure-common.go

    package cmd
    
    import (
    	"context"
    	"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()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  5. cmd/erasure-metadata.go

    	}
    
    	// objProps represents properties that go beyond a single version
    	type objProps struct {
    		succModTime time.Time
    		numVersions int
    	}
    	// Find the successor mod time and numVersions in quorum, otherwise leave the
    	// candidate as found
    	otherPropsMap := make(counterMap[objProps])
    	var candidate FileInfo
    	var found bool
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  6. tests/update_test.go

    	// update with struct
    	time.Sleep(1 * time.Second)
    	DB.Table("users").Where("name in ?", []string{users[1].Name}).Updates(User{Name: "updates_02_newname"})
    
    	var user3 User
    	if err := DB.First(&user3, "name = ?", "updates_02_newname").Error; err != nil {
    		t.Errorf("User2's name should be updated")
    	}
    
    	if user2.UpdatedAt.Format(time.RFC1123Z) == user3.UpdatedAt.Format(time.RFC1123Z) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Dec 04 03:50:58 UTC 2023
    - 30.3K bytes
    - Viewed (0)
  7. src/main/resources/fess_env.properties

    # special script :: absolute mode: $(2014/07/10), relative mode: addDay(3).addMonth(4)
    # The milliseconds for (relative or absolute) adjust time (set only when test) @LongType *dynamic in development
    time.adjust.time.millis = 0
    
    # ----------------------------------------------------------
    #                                                      Mail
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Aug 07 04:53:24 UTC 2021
    - 2.2K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/FileEntry.java

         */
        int getAttributes ();
    
    
        /**
         * 
         * @return the creation time
         */
        long createTime ();
    
    
        /**
         * 
         * @return the last modified time
         */
        long lastModified ();
    
    
        /**
         * 
         * @return the last access time
         */
        long lastAccess ();
    
    
        /**
         * 
         * @return the file size
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 1.4K bytes
    - Viewed (0)
  9. cmd/version_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"testing"
    	"time"
    )
    
    func TestVersion(t *testing.T) {
    	Version = "2017-05-07T06:37:49Z"
    	_, err := time.Parse(time.RFC3339, Version)
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 956 bytes
    - Viewed (0)
  10. internal/lock/lock_test.go

    		}
    	}()
    
    	select {
    	case <-locked:
    		t.Error("unexpected unblocking")
    	case <-time.After(100 * time.Millisecond):
    	}
    
    	// unlock
    	if err = dupl.Close(); err != nil {
    		t.Fatal(err)
    	}
    
    	// the previously blocked routine should be unblocked
    	select {
    	case <-locked:
    	case <-time.After(1 * time.Second):
    		t.Error("unexpected blocking")
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.6K bytes
    - Viewed (0)
Back to top