Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 379 for SELECT (0.09 sec)

  1. internal/store/batch.go

    		store:  config.Store,
    		quitCh: quitCh,
    	}
    	if batch.store != nil {
    		go func() {
    			commitTicker := time.NewTicker(config.CommitTimeout)
    			defer commitTicker.Stop()
    			for {
    				select {
    				case <-commitTicker.C:
    				case <-batch.quitCh:
    					return
    				}
    				batch.Lock()
    				err := batch.commit()
    				batch.Unlock()
    				if err != nil {
    					config.Log(context.Background(), err, "")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  2. .teamcity/src/main/kotlin/util/AdHocPerformanceScenario.kt

            )
            text("testJavaVersion", "17", display = ParameterDisplay.PROMPT, allowEmpty = false, description = "The java version to run the performance tests, e.g. 8/11/17")
            select(
                "testJavaVendor",
                JvmVendor.openjdk.name,
                display = ParameterDisplay.PROMPT,
                description = "The java vendor to run the performance tests",
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Oct 03 06:45:18 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    		for {
    			c.connChange.Wait()
    			newState := c.State()
    			select {
    			case changed <- newState:
    				if newState == StateConnected || newState == StateShutdown {
    					c.connChange.L.Unlock()
    					return
    				}
    			case <-ctx.Done():
    				c.connChange.L.Unlock()
    				return
    			}
    		}
    	}()
    
    	for {
    		select {
    		case <-ctx.Done():
    			return context.Cause(ctx)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  4. src/main/webapp/js/admin/jquery-3.7.1.min.js

    nd.CLASS=function(e,t){if("undefined"!=typeof t.getElementsByClassName&&C)return t.getElementsByClassName(e)},d=[],$(function(e){var t;r.appendChild(e).innerHTML="<a id='"+S+"' href='' disabled='disabled'></a><select id='"+S+"-\r\\' disabled='disabled'><option selected=''></option></select>",e.querySelectorAll("[selected]").length||d.push("\\["+ge+"*(?:value|"+f+")"),e.querySelectorAll("[id~="+S+"-]").length||d.push("~="),e.querySelectorAll("a#"+S+"+*").length||d.push(".#.+[+~]"),e.querySelector...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 85.5K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/es/config/bsbhv/BsFileAuthenticationBhv.java

            return result;
        }
    
        // ===================================================================================
        //                                                                              Select
        //                                                                              ======
        public int selectCount(CBCall<FileAuthenticationCB> cbLambda) {
            return facadeSelectCount(createCB(cbLambda));
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  6. cmd/bucket-replication.go

    				}
    				traceFn(sz, err)
    				select {
    				case <-ctx.Done():
    					return
    				case <-s.resyncCancelCh:
    					return
    				case resultCh <- st:
    				}
    			}
    		}(ctx, i)
    	}
    	for res := range objInfoCh {
    		if res.Err != nil {
    			resyncStatus = ResyncFailed
    			replLogIf(ctx, res.Err)
    			return
    		}
    		select {
    		case <-s.resyncCancelCh:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  7. cmd/metacache-set.go

    				// Do not return io.EOF
    				if resCh != nil {
    					resErr = nil
    					select {
    					case resCh <- results:
    					case <-ctx.Done():
    					}
    					resCh = nil
    					returned = true
    				}
    				continue
    			}
    			results.o = append(results.o, entry)
    		}
    		if resCh != nil {
    			resErr = io.EOF
    			select {
    			case <-ctx.Done():
    				// Nobody wants it.
    			case resCh <- results:
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  8. cmd/bucket-targets.go

    }
    
    // heartBeat performs liveness check on remote endpoints.
    func (sys *BucketTargetSys) heartBeat(ctx context.Context) {
    	hcTimer := time.NewTimer(defaultHealthCheckDuration)
    	defer hcTimer.Stop()
    	for {
    		select {
    		case <-hcTimer.C:
    			sys.hMutex.RLock()
    			eps := make([]madmin.ServerProperties, 0, len(sys.hc))
    			for _, ep := range sys.hc {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  9. CONTRIBUTING.md

        git config user.email ******@****.***
    
    #### Import Gradle into IntelliJ
    
    To import Gradle into IntelliJ:
    - Open the `build.gradle.kts` file in root of the project with IntelliJ and choose "Open as Project"
    - Select a Adoptium Java 17 VM as "Gradle JVM"
    - Revert the Git changes to files in the `.idea` folder
    
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Nov 05 15:15:33 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  10. tests/distinct_test.go

    	r := dryDB.Distinct("u.id, u.*").Table("user_speaks as s").Joins("inner join users as u on u.id = s.user_id").Where("s.language_code ='US' or s.language_code ='ES'").Find(&User{})
    	if !regexp.MustCompile(`SELECT DISTINCT u\.id, u\.\* FROM user_speaks as s inner join users as u`).MatchString(r.Statement.SQL.String()) {
    		t.Fatalf("Build Distinct with u.*, but got %v", r.Statement.SQL.String())
    	}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jan 06 07:02:53 UTC 2022
    - 2.5K bytes
    - Viewed (0)
Back to top