| /dports/devel/caf/actor-framework-0.18.5/libcaf_core/test/ |
| H A D | pipeline_streaming.cpp | 234 auto snk = sys.spawn(sum_up); in CAF_TEST_FIXTURE_SCOPE() local
253 auto snk = sys.spawn(sum_up); in CAF_TEST() local
281 self->send(snk, ok_atom_v); in CAF_TEST()
298 auto snk = sys.spawn(sum_up); in CAF_TEST() local
313 allow((timeout_msg), from(snk).to(snk)); in CAF_TEST()
344 auto snk = sys.spawn(sum_up); in CAF_TEST() local
365 auto snk = sys.spawn(sum_up); in CAF_TEST() local
372 hard_kill(snk); in CAF_TEST()
382 auto snk = sys.spawn(sum_up); in CAF_TEST() local
407 auto snk = sys.spawn(sum_up); in CAF_TEST() local
[all …]
|
| /dports/comms/gnuradio/gnuradio-3.8.4.0/gnuradio-runtime/python/gnuradio/ctrlport/ |
| H A D | GrDataPlotter.py | 75 self.snk = self.get_qtsink()
100 self.snk.close()
158 self.snk.reset()
209 snk.enable_autoscale(True)
210 return snk
241 return snk
269 return snk
308 return snk
341 return snk
371 return snk
[all …]
|
| /dports/comms/gnuradio/gnuradio-3.8.4.0/gr-blocks/python/blocks/ |
| H A D | qa_file_source.py | 54 snk = blocks.vector_sink_f()
55 self.tb.connect(src, snk)
58 result_data = snk.data()
78 self.tb.connect(src, snk)
81 result_data = snk.data()
90 self.tb.connect(src, snk)
93 result_data = snk.data()
124 self.tb.connect(src, snk)
127 result_data = snk.data()
141 result_data = snk.data()
[all …]
|
| /dports/devel/boost-docs/boost_1_72_0/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
209 copy( Source& src, const Sink& snk, in copy() argument
224 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/devel/hyperscan/boost_1_75_0/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
209 copy( Source& src, const Sink& snk, in copy() argument
224 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/devel/boost-python-libs/boost_1_72_0/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
209 copy( Source& src, const Sink& snk, in copy() argument
224 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/math/pdal/PDAL-2.3.0/vendor/pdalboost/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
211 copy( Source& src, const Sink& snk, in copy() argument
226 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/devel/R-cran-BH/BH/inst/include/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
209 copy( Source& src, const Sink& snk, in copy() argument
224 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/games/frogatto/frogatto-1.3.1/MacOSJet/boost/include/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
211 copy( Source& src, const Sink& snk, in copy() argument
226 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/databases/percona57-pam-for-mysql/boost_1_59_0/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
211 copy( Source& src, const Sink& snk, in copy() argument
226 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/science/py-scipy/scipy-1.7.1/scipy/_lib/boost/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
209 copy( Source& src, const Sink& snk, in copy() argument
224 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/databases/xtrabackup/boost_1_59_0/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
211 copy( Source& src, const Sink& snk, in copy() argument
226 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/databases/percona57-server/boost_1_59_0/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
211 copy( Source& src, const Sink& snk, in copy() argument
226 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/math/deal.ii/dealii-803d21ff957e349b3799cd3ef2c840bc78734305/bundled/boost-1.70.0/include/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
209 copy( Source& src, const Sink& snk, in copy() argument
224 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/databases/percona57-client/boost_1_59_0/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
211 copy( Source& src, const Sink& snk, in copy() argument
226 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/security/keybase/client-v5.7.1/shared/ios/Pods/boost-for-react-native/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
209 copy( Source& src, const Sink& snk, in copy() argument
224 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/devel/boost-libs/boost_1_72_0/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
209 copy( Source& src, const Sink& snk, in copy() argument
224 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/databases/mysqlwsrep57-server/boost_1_59_0/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
211 copy( Source& src, const Sink& snk, in copy() argument
226 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/math/stanmath/math-4.2.0/lib/boost_1.75.0/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
209 copy( Source& src, const Sink& snk, in copy() argument
224 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/math/py-pystan/pystan-2.19.0.0/pystan/stan/lib/stan_math/lib/boost_1.69.0/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
209 copy( Source& src, const Sink& snk, in copy() argument
224 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/databases/mysql57-client/mysql-5.7.36/boost/boost_1_59_0/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
211 copy( Source& src, const Sink& snk, in copy() argument
226 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/third_party/boost-1.60.0/boost/iostreams/ |
| H A D | copy.hpp | 54 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
62 pair_type p2 = iostreams::output_sequence(snk); in copy_impl()
73 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
94 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
123 std::streamsize copy_impl( Source& src, Sink& snk, in copy_impl() argument
129 non_blocking_adapter<Sink> nb(snk); in copy_impl()
182 detail::call_close_all(snk) in copy_impl()
194 copy( const Source& src, const Sink& snk, in copy() argument
211 copy( Source& src, const Sink& snk, in copy() argument
226 copy( const Source& src, Sink& snk, in copy() argument
[all …]
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/java.base/share/classes/java/io/ |
| H A D | PipedWriter.java | 58 public PipedWriter(PipedReader snk) throws IOException { in PipedWriter() argument
59 connect(snk); in PipedWriter()
91 public synchronized void connect(PipedReader snk) throws IOException { in connect() argument
92 if (snk == null) { in connect()
94 } else if (sink != null || snk.connected) { in connect()
96 } else if (snk.closedByReader || closed) { in connect()
100 sink = snk; in connect()
101 snk.in = -1; in connect()
102 snk.out = 0; in connect()
103 snk.connected = true; in connect()
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/java/io/ |
| H A D | PipedWriter.java | 58 public PipedWriter(PipedReader snk) throws IOException { in PipedWriter() argument
59 connect(snk); in PipedWriter()
91 public synchronized void connect(PipedReader snk) throws IOException { in connect() argument
92 if (snk == null) { in connect()
94 } else if (sink != null || snk.connected) { in connect()
96 } else if (snk.closedByReader || closed) { in connect()
100 sink = snk; in connect()
101 snk.in = -1; in connect()
102 snk.out = 0; in connect()
103 snk.connected = true; in connect()
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/java.base/share/classes/java/io/ |
| H A D | PipedWriter.java | 58 public PipedWriter(PipedReader snk) throws IOException { in PipedWriter() argument
59 connect(snk); in PipedWriter()
91 public synchronized void connect(PipedReader snk) throws IOException { in connect() argument
92 if (snk == null) { in connect()
94 } else if (sink != null || snk.connected) { in connect()
96 } else if (snk.closedByReader || closed) { in connect()
100 sink = snk; in connect()
101 snk.in = -1; in connect()
102 snk.out = 0; in connect()
103 snk.connected = true; in connect()
|