- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 627 for pselect (0.11 sec)
-
src/internal/trace/testdata/testprog/stacks.go
// It is impossible to ensure that a goroutine has actually blocked // on a channel, in a select or otherwise. So we kick off goroutines // that need to block first in the hope that while we are executing // the rest of the test, they will block. go func() { // func1 select {} }() go func() { // func2 var c chan int c <- 0 }() go func() { // func3 var c chan int <-c }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.4K bytes - Viewed (0) -
platforms/jvm/language-jvm/src/test/groovy/org/gradle/api/plugins/jvm/internal/TestFixturesDependencyModifiersTest.groovy
import org.gradle.util.TestUtil import spock.lang.Specification class TestFixturesDependencyModifiersTest extends Specification { def "copies given external dependency to select test fixtures"() { def modifier = TestUtil.objectFactory().newInstance(TestFixturesDependencyModifiers.TestFixturesDependencyModifier) def dependency = new DefaultExternalModuleDependency("group", "name", "1.0")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Nov 15 16:36:23 UTC 2023 - 4.1K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/transform/AttributeMatchingArtifactVariantSelectorSpec.groovy
when: def result = selector.select(variantSetOf(variants), requestedAttributes, false, factory) then: result == resolvedArtifactSet 1 * attributeMatcher.matches(_, _, _) >> [variant]
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Feb 28 13:08:22 UTC 2024 - 8.3K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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)