- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 129 for strnames (0.66 sec)
-
guava/src/com/google/common/collect/Streams.java
*/ public static IntStream concat(IntStream... streams) { boolean isParallel = false; int characteristics = Spliterator.ORDERED | Spliterator.SIZED | Spliterator.NONNULL; long estimatedSize = 0L; ImmutableList.Builder<Spliterator.OfInt> splitrsBuilder = new ImmutableList.Builder<>(streams.length); for (IntStream stream : streams) { isParallel |= stream.isParallel();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 36.5K bytes - Viewed (0) -
platforms/documentation/docs/src/snippets/native-binaries/cunit/groovy/libs/cunit/2.1-2/include/CUnit/TestDB.h
* - CUE_SUCCESS if no errors occurred. * - CUE_NOREGISTRY if the registry has not been initialized. * - CUE_NO_SUITENAME if strName is NULL. * - CUE_DUP_SUITE if a suite having strName is already registered. * - CUE_NOMEMORY if a memory allocation failed. * * @param strName Name for the new test suite (non-NULL). * @param pInit Initialization function to call before running suite.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 40.4K bytes - Viewed (0) -
src/time/zoneinfo.go
// parse succeeded. func tzset(s string, lastTxSec, sec int64) (name string, offset int, start, end int64, isDST, ok bool) { var ( stdName, dstName string stdOffset, dstOffset int ) stdName, s, ok = tzsetName(s) if ok { stdOffset, s, ok = tzsetOffset(s) } if !ok { return "", 0, 0, 0, false, false }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 04 14:21:30 UTC 2024 - 18.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
internal var errorException: IOException? = null init { if (headers != null) { check(!isLocallyInitiated) { "locally-initiated streams shouldn't have headers yet" } headersQueue += headers } else { check(isLocallyInitiated) { "remotely-initiated streams should have headers" } } } /** * Returns true if this stream is open. A stream is open until either: *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/filters_test.go
if testTopology[srcKey] == nil { testTopology[srcKey] = map[string]int{} } var dstnames []string for _, dst := range dsts { dstnames = append(dstnames, dst.Config().ClusterLocalFQDN()) } dstKey := strings.Join(dstnames, "_") testTopology[srcKey][dstKey]++ }) }, expect: map[string]map[string]int{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 13.1K bytes - Viewed (0) -
internal/grid/handlers.go
if err != nil { return err } return next(resp) }) } // Streamer creates a stream. type Streamer interface { NewStream(ctx context.Context, h HandlerID, payload []byte) (st *Stream, err error) } // Call the remove with the request and func (h *StreamTypeHandler[Payload, Req, Resp]) Call(ctx context.Context, c Streamer, payload Payload) (st *TypedStream[Req, Resp], err error) { if c == nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator_test.go
// streams STDIN and STDOUT. Create test server from StreamTranslatorHandler. spdyLocation, err := url.Parse(spdyServer.URL) if err != nil { t.Fatalf("Unable to parse spdy server URL: %s", spdyServer.URL) } spdyTransport, err := fakeTransport() if err != nil { t.Fatalf("Unexpected error creating transport: %v", err) } streams := Options{Stdin: true, Stdout: true}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 36.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network_test.go
t.Helper() if c.networkFromSystemNamespace().String() != network { return fmt.Errorf("no network system notify") } podNames := sets.New[string]("pod1", "pod2") svcNames := sets.New[string]("svc1") addresses := c.ambientIndex.All() for _, addr := range addresses { wl := addr.GetWorkload() if wl != nil { if !podNames.Contains(wl.Name) { continue }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 10.7K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/decompose.go
toDelete = append(toDelete, namedVal{i, j}) } case t.IsString(): ptrName, lenName := f.SplitString(name) newNames = maybeAppend2(f, newNames, ptrName, lenName) for j, v := range f.NamedValues[*name] { if v.Op != OpStringMake { continue } f.NamedValues[*ptrName] = append(f.NamedValues[*ptrName], v.Args[0]) f.NamedValues[*lenName] = append(f.NamedValues[*lenName], v.Args[1])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 23 21:22:15 UTC 2022 - 13.4K bytes - Viewed (0) -
cmd/kubeadm/app/util/users/users_linux.go
} groupsToCreateSpec = []*entry{ {name: constants.EtcdUserName, userNames: []string{constants.EtcdUserName}}, {name: constants.KubeAPIServerUserName, userNames: []string{constants.KubeAPIServerUserName}}, {name: constants.KubeControllerManagerUserName, userNames: []string{constants.KubeControllerManagerUserName}}, {name: constants.KubeSchedulerUserName, userNames: []string{constants.KubeSchedulerUserName}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 25 16:35:10 UTC 2023 - 20.7K bytes - Viewed (0)