Lines Matching refs:snk
234 auto snk = sys.spawn(sum_up); in CAF_TEST_FIXTURE_SCOPE() local
235 CAF_MESSAGE(CAF_ARG(self) << CAF_ARG(src) << CAF_ARG(snk)); in CAF_TEST_FIXTURE_SCOPE()
237 self->send(snk * src, "numbers.txt"); in CAF_TEST_FIXTURE_SCOPE()
239 expect((open_stream_msg), from(self).to(snk)); in CAF_TEST_FIXTURE_SCOPE()
240 expect((upstream_msg::ack_open), from(snk).to(src)); in CAF_TEST_FIXTURE_SCOPE()
242 expect((downstream_msg::batch), from(src).to(snk)); in CAF_TEST_FIXTURE_SCOPE()
243 expect((upstream_msg::ack_batch), from(snk).to(src)); in CAF_TEST_FIXTURE_SCOPE()
244 expect((downstream_msg::close), from(src).to(snk)); in CAF_TEST_FIXTURE_SCOPE()
245 CAF_CHECK_EQUAL(deref<sum_up_actor>(snk).state.x, 1275); in CAF_TEST_FIXTURE_SCOPE()
247 CAF_CHECK_EQUAL(deref<sum_up_actor>(snk).state.fin_called, 1); in CAF_TEST_FIXTURE_SCOPE()
253 auto snk = sys.spawn(sum_up); in CAF_TEST() local
254 CAF_MESSAGE(CAF_ARG(self) << CAF_ARG(src) << CAF_ARG(snk)); in CAF_TEST()
256 self->send(src, "numbers.txt", snk); in CAF_TEST()
257 expect((string, actor), from(self).to(src).with("numbers.txt", snk)); in CAF_TEST()
258 expect((open_stream_msg), to(snk)); in CAF_TEST()
259 expect((upstream_msg::ack_open), from(snk).to(src)); in CAF_TEST()
261 expect((downstream_msg::batch), from(src).to(snk)); in CAF_TEST()
262 expect((upstream_msg::ack_batch), from(snk).to(src)); in CAF_TEST()
263 expect((downstream_msg::close), from(src).to(snk)); in CAF_TEST()
264 CAF_CHECK_EQUAL(deref<sum_up_actor>(snk).state.x, 1275); in CAF_TEST()
266 CAF_CHECK_EQUAL(deref<sum_up_actor>(snk).state.fin_called, 1); in CAF_TEST()
272 auto snk = sys.spawn(delayed_sum_up); in CAF_TEST() local
273 CAF_MESSAGE(CAF_ARG(self) << CAF_ARG(src) << CAF_ARG(snk)); in CAF_TEST()
275 self->send(snk * src, "numbers.txt"); in CAF_TEST()
277 expect((open_stream_msg), from(self).to(snk)); in CAF_TEST()
278 disallow((upstream_msg::ack_open), from(snk).to(src)); in CAF_TEST()
281 self->send(snk, ok_atom_v); in CAF_TEST()
282 expect((ok_atom), from(self).to(snk)); in CAF_TEST()
283 expect((open_stream_msg), from(self).to(snk)); in CAF_TEST()
284 expect((upstream_msg::ack_open), from(snk).to(src)); in CAF_TEST()
286 expect((downstream_msg::batch), from(src).to(snk)); in CAF_TEST()
287 expect((upstream_msg::ack_batch), from(snk).to(src)); in CAF_TEST()
289 expect((downstream_msg::close), from(src).to(snk)); in CAF_TEST()
290 CAF_CHECK_EQUAL(deref<delayed_sum_up_actor>(snk).state.x, 1275); in CAF_TEST()
292 CAF_CHECK_EQUAL(deref<delayed_sum_up_actor>(snk).state.fin_called, 1); in CAF_TEST()
298 auto snk = sys.spawn(sum_up); in CAF_TEST() local
299 CAF_MESSAGE(CAF_ARG(self) << CAF_ARG(src) << CAF_ARG(snk)); in CAF_TEST()
301 self->send(snk * src, "numbers.txt"); in CAF_TEST()
303 expect((open_stream_msg), from(self).to(snk)); in CAF_TEST()
304 expect((upstream_msg::ack_open), from(snk).to(src)); in CAF_TEST()
308 while (received<downstream_msg::batch>(snk)) { in CAF_TEST()
309 expect((downstream_msg::batch), from(src).to(snk)); in CAF_TEST()
313 allow((timeout_msg), from(snk).to(snk)); in CAF_TEST()
316 expect((upstream_msg::ack_batch), from(snk).to(src)); in CAF_TEST()
317 } while (!received<downstream_msg::close>(snk)); in CAF_TEST()
319 expect((downstream_msg::close), from(src).to(snk)); in CAF_TEST()
320 CAF_CHECK_EQUAL(deref<sum_up_actor>(snk).state.x, 125250); in CAF_TEST()
322 CAF_CHECK_EQUAL(deref<sum_up_actor>(snk).state.fin_called, 1); in CAF_TEST()
329 auto snk = sys.spawn(broken_sink); in CAF_TEST() local
331 self->send(snk * src, "numbers.txt"); in CAF_TEST()
333 expect((open_stream_msg), from(self).to(snk)); in CAF_TEST()
335 expect((error), from(snk).to(self).with(sec::stream_init_failed)); in CAF_TEST()
344 auto snk = sys.spawn(sum_up); in CAF_TEST() local
345 CAF_MESSAGE(CAF_ARG(self) << CAF_ARG(src) << CAF_ARG(snk)); in CAF_TEST()
347 self->send(snk * src, "numbers.txt"); in CAF_TEST()
349 expect((open_stream_msg), from(self).to(snk)); in CAF_TEST()
350 expect((upstream_msg::ack_open), from(snk).to(src)); in CAF_TEST()
353 expect((downstream_msg::batch), from(src).to(snk)); in CAF_TEST()
354 expect((downstream_msg::batch), from(src).to(snk)); in CAF_TEST()
355 expect((downstream_msg::batch), from(src).to(snk)); in CAF_TEST()
356 expect((downstream_msg::batch), from(src).to(snk)); in CAF_TEST()
357 expect((downstream_msg::forced_close), from(_).to(snk)); in CAF_TEST()
359 CAF_CHECK_EQUAL(deref<sum_up_actor>(snk).state.fin_called, 1); in CAF_TEST()
365 auto snk = sys.spawn(sum_up); in CAF_TEST() local
366 CAF_MESSAGE(CAF_ARG(self) << CAF_ARG(src) << CAF_ARG(snk)); in CAF_TEST()
368 self->send(snk * src, "numbers.txt"); in CAF_TEST()
370 expect((open_stream_msg), from(self).to(snk)); in CAF_TEST()
372 hard_kill(snk); in CAF_TEST()
373 expect((upstream_msg::ack_open), from(snk).to(src)); in CAF_TEST()
382 auto snk = sys.spawn(sum_up); in CAF_TEST() local
383 CAF_MESSAGE(CAF_ARG(self) << CAF_ARG(src) << CAF_ARG(stg) << CAF_ARG(snk)); in CAF_TEST()
385 self->send(snk * stg * src, "numbers.txt"); in CAF_TEST()
388 expect((open_stream_msg), from(self).to(snk)); in CAF_TEST()
389 expect((upstream_msg::ack_open), from(snk).to(stg)); in CAF_TEST()
394 disallow((downstream_msg::batch), from(stg).to(snk)); in CAF_TEST()
397 CAF_CHECK_EQUAL(deref<sum_up_actor>(snk).state.x, 625); in CAF_TEST()
400 CAF_CHECK_EQUAL(deref<sum_up_actor>(snk).state.fin_called, 1); in CAF_TEST()
407 auto snk = sys.spawn(sum_up); in CAF_TEST() local
409 << CAF_ARG(snk)); in CAF_TEST()
411 self->send(snk * stg2 * stg1 * src, "numbers.txt"); in CAF_TEST()
415 expect((open_stream_msg), from(self).to(snk)); in CAF_TEST()
416 expect((upstream_msg::ack_open), from(snk).to(stg2)); in CAF_TEST()
422 CAF_CHECK_EQUAL(deref<sum_up_actor>(snk).state.x, 125000); in CAF_TEST()
427 CAF_CHECK_EQUAL(deref<sum_up_actor>(snk).state.fin_called, 1); in CAF_TEST()
433 auto snk = sys.spawn(sum_up); in CAF_TEST() local
434 CAF_MESSAGE(CAF_ARG(self) << CAF_ARG(src) << CAF_ARG(stg) << CAF_ARG(snk)); in CAF_TEST()
436 self->send(snk * stg * src, "numbers.txt"); in CAF_TEST()
439 expect((open_stream_msg), from(self).to(snk)); in CAF_TEST()
440 expect((upstream_msg::ack_open), from(snk).to(stg)); in CAF_TEST()
447 CAF_CHECK_EQUAL(deref<sum_up_actor>(snk).state.x, 625); in CAF_TEST()
451 CAF_CHECK_EQUAL(deref<sum_up_actor>(snk).state.fin_called, 1); in CAF_TEST()
457 auto snk = sys.spawn(sum_up); in CAF_TEST() local
458 CAF_MESSAGE(CAF_ARG(self) << CAF_ARG(src) << CAF_ARG(stg) << CAF_ARG(snk)); in CAF_TEST()
460 self->send(snk * stg * src, "numbers.txt"); in CAF_TEST()
463 expect((open_stream_msg), from(self).to(snk)); in CAF_TEST()
464 expect((upstream_msg::ack_open), from(snk).to(stg)); in CAF_TEST()
471 CAF_CHECK_EQUAL(deref<sum_up_actor>(snk).state.fin_called, 1); in CAF_TEST()