Sha256: b4b9c0b23783a9e10b4dfddc5eade4804dc02a280de4d7d009334afb3c2413a8
Contents?: true
Size: 1.67 KB
Versions: 9
Compression:
Stored size: 1.67 KB
Contents
# frozen_string_literal: true require_relative 'helper' require 'polyphony/adapters/trace' class TraceTest < MiniTest::Test def test_tracing_disabled records = [] t = Polyphony::Trace.new { |r| records << r if r[:event] =~ /^fiber_/ } t.enable snooze assert_equal 0, records.size ensure t&.disable Polyphony.trace(nil) end def test_tracing_enabled records = [] t = Polyphony::Trace.new(:fiber_all) { |r| records << r if r[:event] =~ /^fiber_/ } Polyphony.trace(true) t.enable snooze t.disable assert_equal 3, records.size events = records.map { |r| r[:event] } assert_equal [:fiber_schedule, :fiber_switchpoint, :fiber_run], events assert_equal [Fiber.current], records.map { |r| r[:fiber] }.uniq ensure t&.disable Polyphony.trace(nil) end def test_2_fiber_trace records = [] t = Polyphony::Trace.new(:fiber_all) { |r| records << r if r[:event] =~ /^fiber_/ } t.enable Polyphony.trace(true) f = spin { sleep 0 } suspend sleep 0 events = records.map { |r| [r[:fiber], r[:event]] } assert_equal [ [f, :fiber_create], [f, :fiber_schedule], [Fiber.current, :fiber_switchpoint], [f, :fiber_run], [f, :fiber_switchpoint], [f, :fiber_ev_loop_enter], [f, :fiber_schedule], [f, :fiber_ev_loop_leave], [f, :fiber_run], [f, :fiber_terminate], [Fiber.current, :fiber_switchpoint], [Fiber.current, :fiber_ev_loop_enter], [Fiber.current, :fiber_schedule], [Fiber.current, :fiber_ev_loop_leave], [Fiber.current, :fiber_run] ], events ensure t&.disable Polyphony.trace(nil) end end
Version data entries
9 entries across 9 versions & 1 rubygems