Home
last modified time | relevance | path

Searched refs:sink (Results 1 – 25 of 42) sorted by relevance

12

/libcore/dom/src/test/java/org/w3c/domts/level1/core/
Dalltests.java49 public void build(DOMTestSink sink) { in build() argument
50 sink.addTest(attrcreatedocumentfragment.class); in build()
51 sink.addTest(attrcreatetextnode.class); in build()
52 sink.addTest(attrcreatetextnode2.class); in build()
54 sink.addTest(attreffectivevalue.class); in build()
56 sink.addTest(attrname.class); in build()
57 sink.addTest(attrnextsiblingnull.class); in build()
59 sink.addTest(attrparentnodenull.class); in build()
60 sink.addTest(attrprevioussiblingnull.class); in build()
63 sink.addTest(attrspecifiedvalue.class); in build()
[all …]
/libcore/dom/src/test/java/org/w3c/domts/level2/core/
Dalltests.java49 public void build(DOMTestSink sink) { in build() argument
51 sink.addTest(attrgetownerelement02.class); in build()
52 sink.addTest(attrgetownerelement03.class); in build()
53 sink.addTest(attrgetownerelement04.class); in build()
54 sink.addTest(attrgetownerelement05.class); in build()
55 sink.addTest(createAttributeNS01.class); in build()
56 sink.addTest(createAttributeNS02.class); in build()
57 sink.addTest(createAttributeNS03.class); in build()
58 sink.addTest(createAttributeNS04.class); in build()
59 sink.addTest(createAttributeNS05.class); in build()
[all …]
/libcore/ojluni/src/main/java/java/io/
DPipedWriter.java42 private PipedReader sink; field in PipedWriter
94 } else if (sink != null || snk.connected) { in connect()
100 sink = snk; in connect()
121 if (sink == null) { in write()
124 sink.receive(c); in write()
145 if (sink == null) { in write()
150 sink.receive(cbuf, off, len); in write()
161 if (sink != null) { in flush()
162 if (sink.closedByReader || closed) { in flush()
165 synchronized (sink) { in flush()
[all …]
DPipedOutputStream.java53 private PipedInputStream sink; field in PipedOutputStream
99 } else if (sink != null || snk.connected) { in connect()
102 sink = snk; in connect()
119 if (sink == null) { in write()
122 sink.receive(b); in write()
139 if (sink == null) { in write()
149 sink.receive(b, off, len); in write()
160 if (sink != null) { in flush()
161 synchronized (sink) { in flush()
162 sink.notifyAll(); in flush()
[all …]
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/nio/channels/
DSinkChannelTest.java42 private Pipe.SinkChannel sink; field in SinkChannelTest
53 sink = pipe.sink(); in setUp()
64 assertEquals(SelectionKey.OP_WRITE, sink.validOps()); in test_validOps()
77 sink.configureBlocking(sinkBlockingMode[i]); in test_write_LByteBuffer()
85 sink.write(buf); in test_write_LByteBuffer()
114 sink.write(ByteBuffer.wrap(strbytes)); in test_write_LByteBuffer_mutliThread()
153 sink.write(nullBuf); in test_write_LByteBuffer_Exception()
163 int written = sink.write(buffer); in test_write_LByteBuffer_SourceClosed()
170 sink.close(); in test_write_LByteBuffer_SinkClosed()
172 sink.write(buffer); in test_write_LByteBuffer_SinkClosed()
[all …]
DSourceChannelTest.java38 private Pipe.SinkChannel sink; field in SourceChannelTest
49 sink = pipe.sink(); in setUp()
68 sink.write(ByteBuffer.allocate(1)); in test_read_LByteBuffer_DataAvailable()
91 sink.write(buffer); in test_read_LByteBuffer_SinkClosed()
92 sink.close(); in test_read_LByteBuffer_SinkClosed()
160 sink = pipe.sink(); in test_read_$LByteBuffer()
162 sink.configureBlocking(sinkBlockingMode[i]); in test_read_$LByteBuffer()
167 long writeCount = sink.write(bufArray); in test_read_$LByteBuffer()
170 sink.close(); in test_read_$LByteBuffer()
195 sink.close(); in test_read_$LByteBuffer()
[all …]
DPipeTest.java46 SinkChannel sink = pipe.sink(); in test_sink() local
47 assertTrue(sink.isBlocking()); in test_sink()
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
DStatelessTestOp.java37 public Sink opWrapSink(int flags, Sink<T> sink) { in chain()
38 return op.opWrapSink(flags, isParallel(), sink); in chain()
43 public Sink opWrapSink(int flags, Sink sink) { in chain()
44 return op.opWrapSink(flags, isParallel(), sink); in chain()
50 public Sink opWrapSink(int flags, Sink sink) { in chain()
51 return op.opWrapSink(flags, isParallel(), sink); in chain()
57 public Sink opWrapSink(int flags, Sink sink) { in chain()
58 return op.opWrapSink(flags, isParallel(), sink); in chain()
71 Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_OUT> sink);
DStatefulTestOp.java40 public Sink opWrapSink(int flags, Sink sink) { in chain()
41 return op.opWrapSink(flags, isParallel(), sink); in chain()
60 public Sink opWrapSink(int flags, Sink sink) { in chain()
61 return op.opWrapSink(flags, isParallel(), sink); in chain()
80 public Sink opWrapSink(int flags, Sink sink) { in chain()
81 return op.opWrapSink(flags, isParallel(), sink); in chain()
100 public Sink opWrapSink(int flags, Sink sink) { in chain()
101 return op.opWrapSink(flags, isParallel(), sink); in chain()
127 Sink<E> opWrapSink(int flags, boolean parallel, Sink<E> sink);
DFlagDeclaringOp.java58 public Sink<T> opWrapSink(int flags, boolean parallel, Sink sink) { in opWrapSink() argument
59 return sink; in opWrapSink()
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
DStatelessTestOp.java46 public Sink opWrapSink(int flags, Sink<T> sink) { in chain()
47 return op.opWrapSink(flags, isParallel(), sink); in chain()
53 public Sink opWrapSink(int flags, Sink sink) { in chain()
54 return op.opWrapSink(flags, isParallel(), sink); in chain()
60 public Sink opWrapSink(int flags, Sink sink) { in chain()
61 return op.opWrapSink(flags, isParallel(), sink); in chain()
67 public Sink opWrapSink(int flags, Sink sink) { in chain()
68 return op.opWrapSink(flags, isParallel(), sink); in chain()
81 Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_OUT> sink);
DStatefulTestOp.java41 public Sink opWrapSink(int flags, Sink sink) { in chain()
42 return op.opWrapSink(flags, isParallel(), sink); in chain()
61 public Sink opWrapSink(int flags, Sink sink) { in chain()
62 return op.opWrapSink(flags, isParallel(), sink); in chain()
81 public Sink opWrapSink(int flags, Sink sink) { in chain()
82 return op.opWrapSink(flags, isParallel(), sink); in chain()
101 public Sink opWrapSink(int flags, Sink sink) { in chain()
102 return op.opWrapSink(flags, isParallel(), sink); in chain()
128 Sink<E> opWrapSink(int flags, boolean parallel, Sink<E> sink);
DFlagDeclaringOp.java61 public Sink<T> opWrapSink(int flags, boolean parallel, Sink sink) { in opWrapSink() argument
62 return sink; in opWrapSink()
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/
DNullArgsTestCase.java42 public final Consumer<Object[]> sink; field in NullArgsTestCase
45 protected NullArgsTestCase(String name, Consumer<Object[]> sink, Object[] args) { in NullArgsTestCase() argument
47 this.sink = sink; in NullArgsTestCase()
53 sink.accept(args); in goodNonNull()
62 sink.accept(temp); in throwWithNull()
/libcore/ojluni/src/main/java/java/util/stream/
DSortedOps.java133 public Sink<T> opWrapSink(int flags, Sink<T> sink) { in opWrapSink() argument
134 Objects.requireNonNull(sink); in opWrapSink()
139 return sink; in opWrapSink()
141 return new SizedRefSortingSink<>(sink, comparator); in opWrapSink()
143 return new RefSortingSink<>(sink, comparator); in opWrapSink()
174 public Sink<Integer> opWrapSink(int flags, Sink<Integer> sink) { in opWrapSink() argument
175 Objects.requireNonNull(sink); in opWrapSink()
178 return sink; in opWrapSink()
180 return new SizedIntSortingSink(sink); in opWrapSink()
182 return new IntSortingSink(sink); in opWrapSink()
[all …]
DIntPipeline.java100 private static IntConsumer adapt(Sink<Integer> sink) { in adapt() argument
101 if (sink instanceof IntConsumer) { in adapt()
102 return (IntConsumer) sink; in adapt()
108 return sink::accept; in adapt()
166 public final void forEachWithCancel(Spliterator<Integer> spliterator, Sink<Integer> sink) { in forEachWithCancel() argument
168 IntConsumer adaptedSink = adapt(sink); in forEachWithCancel()
169 do { } while (!sink.cancellationRequested() && spl.tryAdvance(adaptedSink)); in forEachWithCancel()
199 public Sink<Integer> opWrapSink(int flags, Sink<Long> sink) { in asLongStream()
200 return new Sink.ChainedInt<Long>(sink) { in asLongStream()
216 public Sink<Integer> opWrapSink(int flags, Sink<Double> sink) {
[all …]
DLongPipeline.java100 private static LongConsumer adapt(Sink<Long> sink) { in adapt() argument
101 if (sink instanceof LongConsumer) { in adapt()
102 return (LongConsumer) sink; in adapt()
107 return sink::accept; in adapt()
164 public final void forEachWithCancel(Spliterator<Long> spliterator, Sink<Long> sink) { in forEachWithCancel() argument
166 LongConsumer adaptedSink = adapt(sink); in forEachWithCancel()
167 do { } while (!sink.cancellationRequested() && spl.tryAdvance(adaptedSink)); in forEachWithCancel()
197 public Sink<Long> opWrapSink(int flags, Sink<Double> sink) { in asDoubleStream()
198 return new Sink.ChainedLong<Double>(sink) { in asDoubleStream()
220 public Sink<Long> opWrapSink(int flags, Sink<Long> sink) {
[all …]
DDoublePipeline.java99 private static DoubleConsumer adapt(Sink<Double> sink) { in adapt() argument
100 if (sink instanceof DoubleConsumer) { in adapt()
101 return (DoubleConsumer) sink; in adapt()
106 return sink::accept; in adapt()
163 public final void forEachWithCancel(Spliterator<Double> spliterator, Sink<Double> sink) { in forEachWithCancel() argument
165 DoubleConsumer adaptedSink = adapt(sink); in forEachWithCancel()
166 do { } while (!sink.cancellationRequested() && spl.tryAdvance(adaptedSink)); in forEachWithCancel()
202 public Sink<Double> opWrapSink(int flags, Sink<Double> sink) { in map()
203 return new Sink.ChainedDouble<Double>(sink) { in map()
220 public Sink<Double> opWrapSink(int flags, Sink<U> sink) {
[all …]
DReferencePipeline.java132 public final void forEachWithCancel(Spliterator<P_OUT> spliterator, Sink<P_OUT> sink) { in forEachWithCancel() argument
133 do { } while (!sink.cancellationRequested() && spliterator.tryAdvance(sink)); in forEachWithCancel()
162 public Sink<P_OUT> opWrapSink(int flags, Sink<P_OUT> sink) { in unordered()
163 return sink; in unordered()
175 public Sink<P_OUT> opWrapSink(int flags, Sink<P_OUT> sink) {
176 return new Sink.ChainedReference<P_OUT, P_OUT>(sink) {
199 public Sink<P_OUT> opWrapSink(int flags, Sink<R> sink) {
200 return new Sink.ChainedReference<P_OUT, R>(sink) {
217 public Sink<P_OUT> opWrapSink(int flags, Sink<Integer> sink) {
218 return new Sink.ChainedReference<P_OUT, Integer>(sink) {
[all …]
DAbstractPipeline.java474 final <P_IN, S extends Sink<E_OUT>> S wrapAndCopyInto(S sink, Spliterator<P_IN> spliterator) { in wrapAndCopyInto() argument
475 copyInto(wrapSink(Objects.requireNonNull(sink)), spliterator); in wrapAndCopyInto()
476 return sink; in wrapAndCopyInto()
519 public final <P_IN> Sink<P_IN> wrapSink(Sink<E_OUT> sink) { in wrapSink() argument
520 Objects.requireNonNull(sink); in wrapSink()
523 sink = p.opWrapSink(p.previousStage.combinedFlags, sink); in wrapSink()
525 return (Sink<P_IN>) sink; in wrapSink()
617 public abstract void forEachWithCancel(Spliterator<E_OUT> spliterator, Sink<E_OUT> sink); in forEachWithCancel() argument
673 public abstract Sink<E_IN> opWrapSink(int flags, Sink<E_OUT> sink); in opWrapSink() argument
DDistinctOps.java122 public Sink<T> opWrapSink(int flags, Sink<T> sink) { in makeRef() argument
123 Objects.requireNonNull(sink); in makeRef()
126 return sink; in makeRef()
128 return new Sink.ChainedReference<T, T>(sink) { in makeRef()
159 return new Sink.ChainedReference<T, T>(sink) { in makeRef()
DForEachOps.java256 private final Sink<S> sink; field in ForEachOps.ForEachTask
262 Sink<S> sink) { in ForEachTask() argument
264 this.sink = sink; in ForEachTask()
273 this.sink = parent.sink; in ForEachTask()
286 Sink<S> taskSink = sink; in compute()
/libcore/ojluni/src/main/java/sun/nio/ch/
DPipeImpl.java39 private final SinkChannel sink; field in PipeImpl
50 sink = new SinkChannelImpl(sp, sinkfd); in PipeImpl()
57 public SinkChannel sink() { in sink() method in PipeImpl
58 return sink; in sink()
/libcore/ojluni/src/main/java/java/lang/ref/
DReference.java289 SinkHolder.sink = ref; in reachabilityFence()
295 SinkHolder.sink = null; in reachabilityFence()
300 static volatile Object sink; field in Reference.SinkHolder
307 if (sink == null && finalize_count > 0) {
/libcore/luni/src/test/java/libcore/xml/
DNodeTest.java81 private void traverse(Node node, List<Node> sink) { in traverse() argument
82 sink.add(node); in traverse()
86 traverse(children.item(i), sink); in traverse() local

12