Module: OverSIP::SysLoggerProcess

Defined in:
lib/oversip/syslogger_process.rb

Defined Under Namespace

Classes: SysLoggerWatcher

Class Method Summary collapse

Class Method Details

.run(options = {}) ⇒ Object

class SysLoggerWatcher



25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
 
# File 'lib/oversip/syslogger_process.rb', line 25

def self.run options={}
  $0 = ::OverSIP.master_name + "_syslogger"

  # Close Ruby Syslog open in the main process before forking.
  ::Syslog.close

  # Run a new Ruby Syslog.
  syslog_options = ::Syslog::LOG_PID | ::Syslog::LOG_NDELAY
  syslog_facility = ::OverSIP::Syslog::SYSLOG_FACILITY_MAPPING[::OverSIP.configuration[:core][:syslog_facility]]
  ::Syslog.open(::OverSIP.master_name, syslog_options, syslog_facility)

  ppid = ::Process.ppid

  at_exit do
    ::Syslog.notice sprintf("%7s %s", "INFO:", "<syslogger> syslogger process terminated")
    exit!
  end

  EM.run do
    begin
      syslogger_mq = ::POSIX_MQ.new ::OverSIP.syslogger_mq_name, ::IO::RDONLY | ::IO::NONBLOCK
      ::EM::PosixMQ.run syslogger_mq, SysLoggerWatcher

      # Change process permissions if requested.
      ::OverSIP::Launcher.set_user_group(options[:user], options[:group])

    rescue ::Exception => e
      ::Syslog.crit sprintf("%7s %s", "CRIT:", "<syslogger> #{e.class}: #{e}")
      ::Syslog.crit sprintf("%7s %s", "CRIT:", "<syslogger> syslogger process terminated")
      exit! 1
    end

    # Periodically check that master process remains alive and
    # die otherwise.
    ::EM.add_periodic_timer(1) do
      if ::Process.ppid != ppid
        # Wait 0.5 seconds. Maybe the master process has been killed properly and just now
        # it's sending us the QUIT signal.
        ::EM.add_timer(0.5) do
          ::Syslog.crit sprintf("%7s %s", "CRIT:", "<syslogger> master process died, syslogger process terminated")
          exit! 1
        end
      end
    end

    ::EM.error_handler do |e|
      ::Syslog.crit sprintf("%7s %s", "CRIT:", "<syslogger> error raised during event loop and rescued by EM.error_handler: #{e.message} (#{e.class})\n#{(e.backtrace || [])[0..3].join("\n")}")
    end

    ::Syslog.info sprintf("%7s %s", "INFO:", "<syslogger> syslogger process (PID #{$$}) ready")
  end
end