#2764

Committed 08 Dec 2014 03:40PM UTC coverage: 91.388% (-0.4%) from 91.753%

Build # #2764

Build Type

push

Committed by

Commit Message

Merge pull request #201 from rkday/fallback_handling

Posting to a shutdown thread pool - JRuby consistency and better naming

Run Details

18 of 26 new or added lines in 5 files covered. (69.23%)

212 existing lines in 36 files now uncovered.

2812 of 3077 relevant lines covered (91.39%)

369.8 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

76.67

/lib/concurrent/actor/behaviour/supervised.rb

module Concurrent
  module Actor
    module Behaviour

      # Sets and holds the supervisor of the actor if any. There is at most one supervisor
      # for each actor. Each supervisor is automatically linked. Messages:
      # `:pause!, :resume!, :reset!, :restart!` are accepted only from supervisor.
      class Supervised < Abstract
        attr_reader :supervisor

        def initialize(core, subsequent)
          super core, subsequent
          @supervisor = nil
        end

        def on_envelope(envelope)
          case envelope.message
          when :supervise
            supervise envelope.sender
          when :supervisor
            supervisor
          when :un_supervise
            un_supervise envelope.sender
          when :pause!, :resume!, :reset!, :restart!
            # allow only supervisor to control the actor
            if @supervisor == envelope.sender
              pass envelope
            else
              false
            end
          else
            pass envelope
          end
        end

        def supervise(ref)
          @supervisor = ref
          behaviour!(Linking).link ref
          true
        end

        def un_supervise(ref)
          if @supervisor == ref
            behaviour!(Linking).unlink ref
            @supervisor = nil
            true
          else
            false
          end
        end

        def on_event(event)
          @supervisor = nil if event == :terminated
          super event
        end
      end
    end
  end
end

1	module Concurrent	1✔
2	module Actor	1✔
3	module Behaviour	1✔
4
5	# Sets and holds the supervisor of the actor if any. There is at most one supervisor
6	# for each actor. Each supervisor is automatically linked. Messages:
7	# `:pause!, :resume!, :reset!, :restart!` are accepted only from supervisor.
8	class Supervised < Abstract	1✔
9	attr_reader :supervisor	1✔
10
11	def initialize(core, subsequent)	1✔
12	super core, subsequent	14✔
13	@supervisor = nil	14✔
14	end
15
16	def on_envelope(envelope)	1✔
17	case envelope.message	48✔
18	when :supervise
19	supervise envelope.sender	10✔
20	when :supervisor
21	supervisor	3✔
22	when :un_supervise
23	un_supervise envelope.sender	×
24	when :pause!, :resume!, :reset!, :restart!
25	# allow only supervisor to control the actor
26	if @supervisor == envelope.sender	3✔
27	pass envelope	3✔
28	else
UNCOV 29	false	×
30	end
31	else
32	pass envelope	32✔
33	end
34	end
35
36	def supervise(ref)	1✔
37	@supervisor = ref	10✔
38	behaviour!(Linking).link ref	10✔
39	true	10✔
40	end
41
42	def un_supervise(ref)	1✔
UNCOV 43	if @supervisor == ref	×
UNCOV 44	behaviour!(Linking).unlink ref	×
UNCOV 45	@supervisor = nil	×
UNCOV 46	true	×
47	else
UNCOV 48	false	×
49	end
50	end
51
52	def on_event(event)	1✔
53	@supervisor = nil if event == :terminated	19✔
54	super event	19✔
55	end
56	end
57	end
58	end
59	end

ruby-concurrency / concurrent-ruby / #2764

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous