- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 414 for pselect (0.41 sec)
-
tests/integration/README.md
$ go test ./... --istio.test.select -customsetup ``` You can "and" the predicates by separating with commas: ```console $ go test ./... --istio.test.select +customsetup,-postsubmit ``` This will select tests that have ```label.CustomSetup``` only. It will **not** select tests that have both ```label.CustomSetup``` and ```label.Postsubmit```. ### Running Tests on CI Istio's CI/CD system is composed of 2 parts:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 19:04:51 UTC 2024 - 20.9K bytes - Viewed (0) -
cmd/peer-rest-client.go
} st.Results(func(b *grid.Bytes) error { select { case listenCh <- *b: default: // Do not block on slow receivers. b.Recycle() } return nil }) } // Listen - listen on peers. func (client *peerRESTClient) Listen(ctx context.Context, listenCh chan<- []byte, v url.Values) { go func() { for { client.doListen(ctx, listenCh, v) select { case <-ctx.Done(): return
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 26.1K bytes - Viewed (0) -
src/database/sql/fakedb_test.go
closed bool colName []string // used by CREATE, INSERT, SELECT (selected columns) colType []string // used by CREATE colValue []any // used by INSERT (mix of strings and "?" for bound params) placeholders int // used by INSERT/SELECT: number of ? params whereCol []boundCol // used by SELECT (all placeholders) placeholderConverter []driver.ValueConverter // used by INSERT }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 01 12:38:07 UTC 2024 - 30.3K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/internal/component/model/GraphVariantSelector.java
import org.gradle.internal.deprecation.DeprecationLogger; import javax.annotation.Nullable; import java.util.Collection; import java.util.Collections; import java.util.List; /** * Uses attribute matching to select a list of one or more variants for a component in a graph * (in practice, this should be only contain single variant). * * This class is intentionally named similarly to {@link ArtifactVariantSelector}, as it has a
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 22 19:04:04 UTC 2024 - 17.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/utils.go
if err != nil { panic(err) } return token } func testCheckEventType(t *testing.T, w watch.Interface, expectEventType watch.EventType) { select { case res := <-w.ResultChan(): if res.Type != expectEventType { t.Errorf("event type want=%v, get=%v", expectEventType, res.Type) } case <-time.After(wait.ForeverTestTimeout):
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 22 07:26:55 UTC 2024 - 10.3K bytes - Viewed (1) -
docs/bucket/replication/setup_ilm_expiry_replication.sh
flag=$(./mc admin replicate info sitea --json | jq '.sites[] | select (.name=="sitea") | ."replicate-ilm-expiry"') if [ "$flag" != "false" ]; then echo "BUG: ILM expiry replication not disabled for 'sitea'" exit 1 fi flag=$(./mc admin replicate info siteb --json | jq '.sites[] | select (.name=="sitea") | ."replicate-ilm-expiry"') if [ "$flag" != "false" ]; then
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat May 18 18:19:01 UTC 2024 - 12.8K bytes - Viewed (0) -
testing/internal-performance-testing/src/main/groovy/org/gradle/performance/results/BaseCrossBuildResultsStore.java
Set<PerformanceExperiment> testNames = new LinkedHashSet<>(); try (PreparedStatement testIdsStatement = connection.prepareStatement( "select testClass, testId, testProject" + " from testExecutionExperiment" + " where resultType = ?" + " order by testClass, testId, testProject") ) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 12.4K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
resp, err := con.upstream.Recv() if err != nil { upstreamErr(con, err) return } select { case con.responsesChan <- resp: case <-con.stopChan: } } }() go p.handleUpstreamRequest(con) go p.handleUpstreamResponse(con) for { select { case err := <-con.upstreamError: // error from upstream Istiod. return err
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/mkerrors.sh
uname=$(uname) includes_AIX=' #include <net/if.h> #include <net/netopt.h> #include <netinet/ip_mroute.h> #include <sys/protosw.h> #include <sys/stropts.h> #include <sys/mman.h> #include <sys/poll.h> #include <sys/select.h> #include <sys/termio.h> #include <termios.h> #include <fcntl.h> #define AF_LOCAL AF_UNIX ' includes_Darwin=' #define _DARWIN_C_SOURCE #define KERNEL 1 #define _DARWIN_USE_64_BIT_INODE
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 20.2K bytes - Viewed (0) -
pilot/pkg/xds/xds_test.go
PortSpecifier: &core.SocketAddress_PortValue{ PortValue: uint32(27018), }, }, "{.address.socketAddress}"). Select("{.filterChains[0].filters[0]}"). Equals("envoy.mongo_proxy", "{.name}"). Select("{.typedConfig}"). Exists("{.statPrefix}"). CheckOrFail(t) }) } func TestEgressProxy(t *testing.T) { s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ ConfigString: `
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 13.8K bytes - Viewed (0)