Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 1,703 for pselect (0.13 sec)

  1. tests/connpool_test.go

    			"SELECT * FROM `users` WHERE name = ? AND `users`.`deleted_at` IS NULL ORDER BY `users`.`id` LIMIT ?",
    			"SELECT * FROM `users` WHERE name = ? AND `users`.`deleted_at` IS NULL ORDER BY `users`.`id` LIMIT ?",
    			"INSERT INTO `users` (`created_at`,`updated_at`,`deleted_at`,`name`,`age`,`birthday`,`company_id`,`manager_id`,`active`) VALUES (?,?,?,?,?,?,?,?,?)",
    Registered: Wed Jun 12 16:27:09 UTC 2024
    - Last Modified: Tue Feb 06 02:54:40 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  2. platforms/core-runtime/daemon-services/src/test/groovy/org/gradle/api/internal/tasks/userinput/DefaultUserInputHandlerTest.groovy

            input == true
        }
    
        def "can ask select question"() {
            when:
            def input = ask { it.selectOption("select option", [11, 12, 13], 12) }
    
            then:
            1 * outputEventBroadcaster.onOutput(_ as UserInputRequestEvent)
            1 * outputEventBroadcaster.onOutput(_) >> { SelectOptionPromptEvent event ->
                assert event.question == "select option"
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 09 04:50:46 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  3. pilot/pkg/xds/adstest.go

    				log.Warnf("ads received error: %v", err)
    			}
    			select {
    			case a.error <- err:
    			case <-a.context.Done():
    			}
    			return
    		}
    		select {
    		case a.responses <- resp:
    		case <-a.context.Done():
    			return
    		}
    	}
    }
    
    // DrainResponses reads all responses, but does nothing to them
    func (a *AdsTest) DrainResponses() {
    	for {
    		select {
    		case <-a.context.Done():
    			return
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Feb 04 03:39:42 UTC 2024
    - 6K bytes
    - Viewed (0)
  4. src/runtime/chan.go

    //  At least one of c.sendq and c.recvq is empty,
    //  except for the case of an unbuffered channel with a single goroutine
    //  blocked on it for both sending and receiving using a select statement,
    //  in which case the length of c.sendq and c.recvq is limited only by the
    //  size of the select statement.
    //
    // For buffered channels, also:
    //  c.qcount > 0 implies that c.recvq is empty.
    //  c.qcount < c.dataqsiz implies that c.sendq is empty.
    
    import (
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:50 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  5. src/cmd/vendor/golang.org/x/sys/unix/syscall_linux_mips64x.go

    //sys	Seek(fd int, offset int64, whence int) (off int64, err error) = SYS_LSEEK
    
    func Select(nfd int, r *FdSet, w *FdSet, e *FdSet, timeout *Timeval) (n int, err error) {
    	var ts *Timespec
    	if timeout != nil {
    		ts = &Timespec{Sec: timeout.Sec, Nsec: timeout.Usec * 1000}
    	}
    	return pselect6(nfd, r, w, e, ts, nil)
    }
    
    //sys	sendfile(outfd int, infd int, offset *int64, count int) (written int, err error)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:33 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  6. internal/s3select/sql/statement.go

    	var selectAST Select
    	err = SQLParser.ParseString(s, &selectAST)
    	if err != nil {
    		err = errQueryParseFailure(err)
    		return
    	}
    
    	// Check if select is "SELECT s.* from S3Object s"
    	if !selectAST.Expression.All &&
    		len(selectAST.Expression.Expressions) == 1 &&
    		len(selectAST.Expression.Expressions[0].Expression.And) == 1 &&
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jan 09 17:19:11 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  7. src/internal/types/testdata/check/labels.go

    		}
    	}
    
    L9:
    	switch {
    	case true:
    		break L9
    	defalt /* ERROR "label defalt declared and not used" */ :
    	}
    
    L10:
    	select {
    	default:
    		break L10
    		break L9 /* ERROR "invalid break label L9" */
    	}
    
    	goto L10a
    L10a: L10b:
    	select {
    	default:
    		break L10a /* ERROR "invalid break label L10a" */
    		break L10b
    		continue L10b /* ERROR "invalid continue label L10b" */
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  8. pkg/ctrlz/ctrlz_test.go

    	"testing"
    	"time"
    )
    
    func TestStartStopEnabled(t *testing.T) {
    	server := startAndWaitForServer(t)
    	done := make(chan struct{}, 1)
    	go func() {
    		server.Close()
    		done <- struct{}{}
    	}()
    	select {
    	case <-done:
    	case <-time.After(5 * time.Second):
    		t.Fatal("Timed out waiting for listeningTestProbe to be called")
    	}
    }
    
    func TestSignals(t *testing.T) {
    	c := make(chan os.Signal, 1)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 15 18:23:41 UTC 2024
    - 2K bytes
    - Viewed (0)
  9. tests/benchmark_test.go

    	b.ResetTimer()
    	for x := 0; x < b.N; x++ {
    		DB.Raw("select * from users where id = ?", user.ID).Scan(&u)
    	}
    }
    
    func BenchmarkScanSlice(b *testing.B) {
    	DB.Exec("delete from users")
    	for i := 0; i < 10_000; i++ {
    		user := *GetUser(fmt.Sprintf("scan-%d", i), Config{})
    		DB.Create(&user)
    	}
    
    	var u []User
    	b.ResetTimer()
    	for x := 0; x < b.N; x++ {
    		DB.Raw("select * from users").Scan(&u)
    	}
    }
    
    Registered: Wed Jun 12 16:27:09 UTC 2024
    - Last Modified: Wed Jun 01 03:50:57 UTC 2022
    - 1.5K bytes
    - Viewed (0)
  10. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/ModuleConflictResolver.java

    package org.gradle.api.internal.artifacts.ivyservice.resolveengine;
    
    public interface ModuleConflictResolver<T> {
        /**
         * Selects matching candidate. Returns null if this implementation of the resolver is not able to select a candidate.
         *
         * @param details the conflict resolution details
         */
        void select(ConflictResolverDetails<T> details);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Oct 10 21:10:11 UTC 2023
    - 984 bytes
    - Viewed (0)
Back to top