Class: Ldumbd::PreforkServer

Inherits:
Object
  • Object
show all
Defined in:
lib/ldumbd/preforkserver.rb

Instance Method Summary collapse

Constructor Details

#initialize(opt) ⇒ PreforkServer

Returns a new instance of PreforkServer.



6
7
8
9
10
11
12
13
14
15
16
 
# File 'lib/ldumbd/preforkserver.rb', line 6

def initialize(opt)
  @acceptor = nil
  @bind_address = opt[:bindaddr] || '0.0.0.0'
  @port = opt[:port] || 1389
  @group = opt[:group]
  @user = opt[:user]
  @nodelay = opt.has_key?(:nodelay) ? opt[:nodelay] : true
  @listen = opt[:listen] || 10
  @num_processes = opt[:num_processes] || 10
  @debug = opt[:debug]
end

Instance Method Details

#join ⇒ Object 



38
39
40
 
# File 'lib/ldumbd/preforkserver.rb', line 38

def join
  Process.waitall
end

#run(&block) ⇒ Object 



18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
 
# File 'lib/ldumbd/preforkserver.rb', line 18

def run(&block)
  start
  Process::GID.change_privilege(Etc.getgrnam(@group)) if @group
  Process::UID.change_privilege(Etc.getpwnam(@user)) if @user
  @num_processes.times do
    fork do
      trap('INT') { exit }

      puts "child #$$ accepting connections on #{@bind_address}:#{@port}" if @debug
      loop do
        socket = @acceptor.accept
        block.call(socket)
        socket.close
      end
      exit
    end
  end
  self
end