Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 463 for donde (0.09 sec)

  1. buildscripts/race.sh

    #!/usr/bin/env bash
    
    set -e
    
    export GORACE="history_size=7"
    export MINIO_API_REQUESTS_MAX=10000
    
    for d in $(go list ./...); do
    	CGO_ENABLED=1 go test -v -race --timeout 100m "$d"
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jul 02 21:28:55 UTC 2024
    - 184 bytes
    - Viewed (0)
  2. cmd/notification.go

    		wg.Add(1)
    		go func(ctx context.Context, peerChannel <-chan MetricV2, wg *sync.WaitGroup) {
    			defer wg.Done()
    			for {
    				select {
    				case m, ok := <-peerChannel:
    					if !ok {
    						return
    					}
    					select {
    					case ch <- m:
    					case <-ctx.Done():
    						return
    					}
    				case <-ctx.Done():
    					return
    				}
    			}
    		}(ctx, peerChannels[index], &wg)
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  3. docs/site-replication/run-ssec-object-replication-with-compression.sh

    echo "done"
    
    if [ ! -f ./mc ]; then
    	echo -n "Downloading MinIO client ..."
    	wget -O mc https://dl.min.io/client/mc/release/linux-amd64/mc &&
    		chmod +x mc
    	echo "done"
    fi
    
    export MC_HOST_minio1=https://minio:minio123@localhost:9001
    export MC_HOST_minio2=https://minio:minio123@localhost:9002
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 24 08:03:58 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  4. cmd/site-replication-utils.go

    						rs.LastSaved = UTCNow()
    						sm.peerResyncMap[dID] = rs
    						wg.Add(1)
    						go func() {
    							defer wg.Done()
    							saveSiteResyncMetadata(ctx, st, newObjectLayerFn())
    						}()
    					}
    				}
    				wg.Wait()
    				sm.Unlock()
    			}
    			sTimer.Reset(siteResyncSaveInterval)
    		case <-ctx.Done():
    			return
    		}
    	}
    }
    
    // update overall site resync state
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (1)
  5. .teamcity/mvnw

      while [ -h "$PRG" ] ; do
        ls=`ls -ld "$PRG"`
        link=`expr "$ls" : '.*-> \(.*\)$'`
        if expr "$link" : '/.*' > /dev/null; then
          PRG="$link"
        else
          PRG="`dirname "$PRG"`/$link"
        fi
      done
    
      saveddir=`pwd`
    
      M2_HOME=`dirname "$PRG"`/..
    
      # make it fully qualified
      M2_HOME=`cd "$M2_HOME" && pwd`
    
      cd "$saveddir"
      # echo Using m2 at $M2_HOME
    fi
    
    Registered: Wed Oct 30 11:36:09 UTC 2024
    - Last Modified: Wed Feb 26 01:48:39 UTC 2020
    - 9.8K bytes
    - Viewed (0)
  6. cmd/bucket-replication.go

    	for i := 0; i < resyncParallelRoutines; i++ {
    		wg.Add(1)
    		workers[i] = make(chan ReplicateObjectInfo, 100)
    		i := i
    		go func(ctx context.Context, idx int) {
    			defer wg.Done()
    			for roi := range workers[idx] {
    				select {
    				case <-ctx.Done():
    					return
    				case <-s.resyncCancelCh:
    				default:
    				}
    				traceFn := s.trace(tgt.ResetID, fmt.Sprintf("%s/%s (%s)", opts.bucket, roi.Name, roi.VersionID))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  7. tests/prepared_stmt_test.go

    	wg := sync.WaitGroup{}
    	for i := 0; i < 100; i++ {
    		wg.Add(1)
    		go func() {
    			user := User{Name: "jinzhu"}
    			tx.Create(&user)
    
    			var result User
    			tx.First(&result)
    			wg.Done()
    		}()
    	}
    	wg.Wait()
    
    	conn, ok := tx.ConnPool.(*gorm.PreparedStmtDB)
    	AssertEqual(t, ok, true)
    	AssertEqual(t, len(conn.Stmts), 2)
    	for _, stmt := range conn.Stmts {
    		if stmt == nil {
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  8. internal/grid/muxclient.go

    	for !errState {
    		select {
    		case <-m.ctx.Done():
    			if debugPrint {
    				fmt.Println("Client sending disconnect to mux", m.MuxID)
    			}
    			m.addErrorNonBlockingClose(errResp, context.Cause(m.ctx))
    			errState = true
    			continue
    		case <-pingTimer:
    			if !m.doPing(errResp) {
    				errState = true
    				continue
    			}
    		case req, ok := <-requests:
    			if !ok {
    				// Done send EOF
    				if debugPrint {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  9. docs/site-replication/run-sse-kms-object-replication.sh

    echo "done"
    
    if [ ! -f ./mc ]; then
    	echo -n "Downloading MinIO client ..."
    	wget -O mc https://dl.min.io/client/mc/release/linux-amd64/mc &&
    		chmod +x mc
    	echo "done"
    fi
    
    export MC_HOST_minio1=https://minio:minio123@localhost:9001
    export MC_HOST_minio2=https://minio:minio123@localhost:9002
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  10. cmd/admin-handlers_test.go

    	return &adminErasureTestBed{
    		erasureDirs: erasureDirs,
    		objLayer:    objLayer,
    		router:      adminRouter,
    		done:        cancel,
    	}, nil
    }
    
    // TearDown - method that resets the test bed for subsequent unit
    // tests to start afresh.
    func (atb *adminErasureTestBed) TearDown() {
    	atb.done()
    	removeRoots(atb.erasureDirs)
    	resetTestGlobals()
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
Back to top