1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
|
#!/usr/bin/env ruby
require 'optparse'
# This hash will hold all of the options
# parsed from the command-line by
# OptionParser.
options = {}
optparse = OptionParser.new do|opts|
# This displays the help screen, all programs are
# assumed to have this option.
opts.on( '-h', '--help', 'Display this screen' ) do
puts opts
exit
end
opts.on( '-p', '--pid FILE', 'pid_file' ) do |a|
options[:pid_file] = a
end
opts.on( '-l', '--log FILE', 'log_file' ) do |a|
options[:log_file] = a
end
opts.on( '-L', '--lock FILE', 'lock_file' ) do |a|
options[:lock_file] = a
end
opts.on( '-d', '--daemonize', 'Daemonize' ) do
options[:daemonize] = true
end
opts.on( '-s', '--daemonize_delay DELAY', 'Daemonized time' ) do |d|
options[:daemonize_delay] = d
end
opts.on( '-r', '--raise', 'Raised execution' ) do
options[:raise] = true
end
opts.on( '-w', '--watch_file FILE', 'Exit on touched file' ) do |w|
options[:watch_file] = w
end
opts.on( '-W', '--watch_file_delay DELAY', 'Exit on touched file, after delay' ) do |w|
options[:watch_file_delay] = w
end
end
optparse.parse!
module Sample
def puts(mes = "")
tm = Time.now
STDOUT.puts "#{tm} (#{tm.to_f}) - #{mes}"
STDOUT.flush
end
def daemonize(pid_file, log_file, daemonize_delay = 0)
puts "daemonize start #{pid_file}, #{log_file}, #{daemonize_delay}"
if daemonize_delay && daemonize_delay.to_f > 0
puts "daemonize delay start #{daemonize_delay}"
sleep daemonize_delay.to_f
puts "daemonize delay end"
end
daemon
STDOUT.reopen(log_file, "a")
STDERR.reopen(log_file, "a")
File.open(pid_file, 'w'){|f| f.write $$.to_s}
puts "daemonized"
end
def daemon
exit if fork # Parent exits, child continues.
Process.setsid # Become session leader.
exit if fork # Zap session leader. See [1].
STDIN.reopen "/dev/null" # Free file descriptors and
STDOUT.reopen "/dev/null", "a" # point them somewhere sensible.
STDERR.reopen '/dev/null', 'a'
return 0
end
end
extend Sample
if options[:daemonize]
daemonize(options[:pid_file], options[:log_file], options[:daemonize_delay])
end
puts "Started #{ARGV.inspect}, #{options.inspect}, #{ENV['ENV1']}"
if options[:lock_file]
if File.exist?(options[:lock_file])
puts "Lock file exists, exiting"
exit 1
else
File.open(options[:lock_file], 'w'){|f| f.write $$ }
end
end
if options[:raise]
puts "Raised"
File.unlink(options[:lock_file]) if options[:lock_file]
exit 1
end
trap("USR1") do
puts "USR1 signal!"
end
trap("USR2") do
puts "USR2 start memory leak"
$ar = []
300_000.times{|i| $ar << "memory leak #{i}" * 10}
end
loop do
sleep 0.1
puts "tick"
if options[:watch_file]
if File.exist?(options[:watch_file])
puts "watch file finded"
File.unlink(options[:watch_file])
if options[:watch_file_delay]
puts "watch_file delay start"
sleep options[:watch_file_delay].to_f
puts "watch_file delay end"
end
break
end
end
end
puts "exit"
File.unlink(options[:lock_file]) if options[:lock_file]
exit 0
|
