Home
last modified time | relevance | path

Searched refs:op (Results 1 – 24 of 24) sorted by relevance

/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
DStatefulTestOp.java35 StatefulTestOp op) { in chain() argument
36 switch (op.outputShape()) { in chain()
38 … return new ReferencePipeline.StatefulOp<Object, T>(upstream, op.inputShape(), op.opGetFlags()) { in chain()
41 return op.opWrapSink(flags, isParallel(), sink); in chain()
47 return op.opEvaluateParallelLazy(helper, spliterator); in chain()
54 return op.opEvaluateParallel(helper, spliterator, generator); in chain()
58 … return new IntPipeline.StatefulOp<Object>(upstream, op.inputShape(), op.opGetFlags()) { in chain()
61 return op.opWrapSink(flags, isParallel(), sink); in chain()
67 return op.opEvaluateParallelLazy(helper, spliterator); in chain()
74 … return (Node<Integer>) op.opEvaluateParallel(helper, spliterator, generator); in chain()
[all …]
DStatelessTestOp.java32 StatelessTestOp<?, T> op) { in chain() argument
33 int flags = op.opGetFlags(); in chain()
34 switch (op.outputShape()) { in chain()
36 … return new ReferencePipeline.StatelessOp<Object, T>(upstream, op.inputShape(), flags) { in chain()
38 return op.opWrapSink(flags, isParallel(), sink); in chain()
42 return new IntPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { in chain()
44 return op.opWrapSink(flags, isParallel(), sink); in chain()
48 return new LongPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { in chain()
51 return op.opWrapSink(flags, isParallel(), sink); in chain()
55 return new DoublePipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { in chain()
[all …]
DIntermediateTestOp.java32 IntermediateTestOp<?, T> op) { in chain() argument
33 if (op instanceof StatelessTestOp) in chain()
34 return StatelessTestOp.chain(upstream, (StatelessTestOp) op); in chain()
36 if (op instanceof StatefulTestOp) in chain()
37 return StatefulTestOp.chain(upstream, (StatefulTestOp) op); in chain()
39 throw new IllegalStateException("Unknown test op type: " + op.getClass().getName()); in chain()
DOpTestCase.java617 …tatic <T> AbstractPipeline<?, T, ?> chain(AbstractPipeline upstream, IntermediateTestOp<?, T> op) { in chain() argument
618 return (AbstractPipeline<?, T, ?>) IntermediateTestOp.chain(upstream, op); in chain()
623 for (IntermediateTestOp op : ops) in chain()
624 pipe = chain(pipe, op); in chain()
629 … private static <T> AbstractPipeline<?, T, ?> chain(BaseStream pipe, IntermediateTestOp<?, T> op) { in chain() argument
630 return chain((AbstractPipeline) pipe, op); in chain()
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
DStatefulTestOp.java36 StatefulTestOp op) { in chain() argument
37 switch (op.outputShape()) { in chain()
39 … return new ReferencePipeline.StatefulOp<Object, T>(upstream, op.inputShape(), op.opGetFlags()) { in chain()
42 return op.opWrapSink(flags, isParallel(), sink); in chain()
48 return op.opEvaluateParallelLazy(helper, spliterator); in chain()
55 return op.opEvaluateParallel(helper, spliterator, generator); in chain()
59 … return new IntPipeline.StatefulOp<Object>(upstream, op.inputShape(), op.opGetFlags()) { in chain()
62 return op.opWrapSink(flags, isParallel(), sink); in chain()
68 return op.opEvaluateParallelLazy(helper, spliterator); in chain()
75 … return (Node<Integer>) op.opEvaluateParallel(helper, spliterator, generator); in chain()
[all …]
DStatelessTestOp.java40 StatelessTestOp<?, T> op) { in chain() argument
41 int flags = op.opGetFlags(); in chain()
42 switch (op.outputShape()) { in chain()
44 … return new ReferencePipeline.StatelessOp<Object, T>(upstream, op.inputShape(), flags) { in chain()
47 return op.opWrapSink(flags, isParallel(), sink); in chain()
51 return new IntPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { in chain()
54 return op.opWrapSink(flags, isParallel(), sink); in chain()
58 return new LongPipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { in chain()
61 return op.opWrapSink(flags, isParallel(), sink); in chain()
65 return new DoublePipeline.StatelessOp<Object>(upstream, op.inputShape(), flags) { in chain()
[all …]
DIntermediateTestOp.java34 IntermediateTestOp<?, T> op) { in chain() argument
35 if (op instanceof StatelessTestOp) in chain()
36 return StatelessTestOp.chain(upstream, (StatelessTestOp) op); in chain()
38 if (op instanceof StatefulTestOp) in chain()
39 return StatefulTestOp.chain(upstream, (StatefulTestOp) op); in chain()
41 throw new IllegalStateException("Unknown test op type: " + op.getClass().getName()); in chain()
DOpTestCase.java618 …tatic <T> AbstractPipeline<?, T, ?> chain(AbstractPipeline upstream, IntermediateTestOp<?, T> op) { in chain() argument
619 return (AbstractPipeline<?, T, ?>) IntermediateTestOp.chain(upstream, op); in chain()
624 for (IntermediateTestOp op : ops) in chain()
625 pipe = chain(pipe, op); in chain()
630 … private static <T> AbstractPipeline<?, T, ?> chain(BaseStream pipe, IntermediateTestOp<?, T> op) { in chain() argument
631 return chain((AbstractPipeline) pipe, op); in chain()
/libcore/ojluni/src/main/java/java/util/stream/
DFindOps.java252 private final FindOp<P_OUT, O> op; field in FindOps.FindTask
254 FindTask(FindOp<P_OUT, O> op, in FindTask() argument
258 this.op = op; in FindTask()
263 this.op = parent.op; in FindTask()
273 return op.emptyValue; in getEmptyResult()
285 O result = helper.wrapAndCopyInto(op.sinkSupplier.get(), spliterator).get(); in doLeaf()
286 if (!op.mustFindFirst) { in doLeaf()
303 if (op.mustFindFirst) { in onCompletion()
307 if (result != null && op.presentPredicate.test(result)) { in onCompletion()
DMatchOps.java280 private final MatchOp<P_OUT> op; field in MatchOps.MatchTask
285 MatchTask(MatchOp<P_OUT> op, PipelineHelper<P_OUT> helper, in MatchTask() argument
288 this.op = op; in MatchTask()
296 this.op = parent.op; in MatchTask()
306 … boolean b = helper.wrapAndCopyInto(op.sinkSupplier.get(), spliterator).getAndClearState(); in doLeaf()
307 if (b == op.matchKind.shortCircuitResult) in doLeaf()
314 return !op.matchKind.shortCircuitResult; in getEmptyResult()
DSliceOps.java561 private final AbstractPipeline<P_OUT, P_OUT, ?> op;
568 SliceTask(AbstractPipeline<P_OUT, P_OUT, ?> op,
574 this.op = op;
582 this.op = parent.op;
595 return Nodes.emptyNode(op.getOutputShape());
601 long sizeIfKnown = StreamOpFlag.SIZED.isPreserved(op.sourceOrOpFlags)
602 ? op.exactOutputSizeIfKnown(spliterator)
604 final Node.Builder<P_OUT> nb = op.makeNodeBuilder(sizeIfKnown, generator);
605 Sink<P_OUT> opSink = op.opWrapSink(helper.getStreamAndOpFlags(), nb);
635 result = Nodes.conc(op.getOutputShape(),
DCollectors.java657 reducing(T identity, BinaryOperator<T> op) {
660 (a, t) -> { a[0] = op.apply(a[0], t); },
661 (a, b) -> { a[0] = op.apply(a[0], b[0]); return a; },
698 reducing(BinaryOperator<T> op) {
706 value = op.apply(value, t);
758 BinaryOperator<U> op) {
761 (a, t) -> { a[0] = op.apply(a[0], mapper.apply(t)); },
762 (a, b) -> { a[0] = op.apply(a[0], b[0]); return a; },
1140 BinaryOperator<A> op = downstream.combiner();
1142 new Partition<>(op.apply(left.forTrue, right.forTrue),
[all …]
DReduceOps.java725 private final ReduceOp<P_OUT, R, S> op;
727 ReduceTask(ReduceOp<P_OUT, R, S> op,
731 this.op = op;
737 this.op = parent.op;
747 return helper.wrapAndCopyInto(op.makeSink(), spliterator);
DDoubleStream.java375 double reduce(double identity, DoubleBinaryOperator op); in reduce() argument
412 OptionalDouble reduce(DoubleBinaryOperator op); in reduce() argument
DIntStream.java370 int reduce(int identity, IntBinaryOperator op); in reduce() argument
407 OptionalInt reduce(IntBinaryOperator op); in reduce() argument
DDoublePipeline.java460 public final double reduce(double identity, DoubleBinaryOperator op) {
461 return evaluate(ReduceOps.makeDouble(identity, op));
465 public final OptionalDouble reduce(DoubleBinaryOperator op) {
466 return evaluate(ReduceOps.makeDouble(op));
DLongPipeline.java438 public final long reduce(long identity, LongBinaryOperator op) {
439 return evaluate(ReduceOps.makeLong(identity, op));
443 public final OptionalLong reduce(LongBinaryOperator op) {
444 return evaluate(ReduceOps.makeLong(op));
DIntPipeline.java456 public final int reduce(int identity, IntBinaryOperator op) {
457 return evaluate(ReduceOps.makeInt(identity, op));
461 public final OptionalInt reduce(IntBinaryOperator op) {
462 return evaluate(ReduceOps.makeInt(op));
DLongStream.java374 long reduce(long identity, LongBinaryOperator op); in reduce() argument
411 OptionalLong reduce(LongBinaryOperator op); in reduce() argument
/libcore/ojluni/src/main/java/java/util/
DArrays.java1620 public static <T> void parallelPrefix(T[] array, BinaryOperator<T> op) { in parallelPrefix() argument
1621 Objects.requireNonNull(op); in parallelPrefix()
1624 (null, op, array, 0, array.length).invoke(); in parallelPrefix()
1644 int toIndex, BinaryOperator<T> op) { in parallelPrefix() argument
1645 Objects.requireNonNull(op); in parallelPrefix()
1649 (null, op, array, fromIndex, toIndex).invoke(); in parallelPrefix()
1666 public static void parallelPrefix(long[] array, LongBinaryOperator op) { in parallelPrefix() argument
1667 Objects.requireNonNull(op); in parallelPrefix()
1670 (null, op, array, 0, array.length).invoke(); in parallelPrefix()
1689 int toIndex, LongBinaryOperator op) { in parallelPrefix() argument
[all …]
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
DTabulatorsTest.java406 for (BinaryOperator<Integer> op : Arrays.asList((u, v) -> u,
411 new ToMapAssertion<>(keyFn, valueFn, op, HashMap.class));
420 exerciseMapTabulation(data, toMap(keyFn, valueFn, op),
421 new ToMapAssertion<>(keyFn, valueFn, op, HashMap.class));
423 exerciseMapTabulation(data, toMap(keyFn, valueFn, op, TreeMap::new),
424 new ToMapAssertion<>(keyFn, valueFn, op, TreeMap.class));
/libcore/luni/src/main/java/libcore/io/
DIoBridge.java393 int op = (option == JAVA_MCAST_JOIN_GROUP) ? MCAST_JOIN_GROUP : MCAST_LEAVE_GROUP; in setSocketOptionErrno() local
394 Libcore.os.setsockoptGroupReq(fd, level, op, groupReq); in setSocketOptionErrno()
405 int op = getGroupSourceReqOp(option); in setSocketOptionErrno() local
406 Libcore.os.setsockoptGroupSourceReq(fd, level, op, groupSourceReq); in setSocketOptionErrno()
/libcore/ojluni/src/main/java/java/net/
DDatagramSocket.java398 void checkAddress (InetAddress addr, String op) { in checkAddress() argument
403 throw new IllegalArgumentException(op + ": invalid address type"); in checkAddress()
DSocket.java638 private void checkAddress (InetAddress addr, String op) { in checkAddress() argument
643 throw new IllegalArgumentException(op + ": invalid address type"); in checkAddress()