class RBMK::Worker

Public Class Methods

hire(peer, upstream;) click to toggle source
# File lib/rbmk/worker.rb, line 6
def self.hire peer, upstream; new(peer, upstream).serve end
new(peer, upstream) click to toggle source
# File lib/rbmk/worker.rb, line 8
def initialize peer, upstream
        @upstream = upstream
        @upstream.mktemp
        @peer = peer
        @conn = LDAP::Server::Connection.new @peer.socket,
                server: @upstream,
                logger: $log,
                operation_class: RBMK::Operation,
                operation_args: [self],
                schema: @upstream.schema,
                namingContexts: @upstream.root_dse['namingContexts']
        user_init
end

Public Instance Methods

serve() click to toggle source
# File lib/rbmk/worker.rb, line 22
def serve
        @conn.handle_requests
ensure
        @peer.close
end

Protected Instance Methods

user_init() click to toggle source

Patch this method to implement your additional worker init actions

# File lib/rbmk/worker.rb, line 31
def user_init; end