module TellaPeer

# File lib/tella_peer.rb, line 19
def self.logger
  if @logger 
    @logger
  else
    @logger = Logger.new(STDOUT)
    @logger
  end
end

# File lib/tella_peer.rb, line 51
def self.start_connection_builder
  Thread.new {
    begin
      loop do
        logger.debug 'Building client connections'
        Connections.build_from_connections
        sleep 5
      end
    rescue
      logger.error "Connection builder crashed"
      logger.error $!
    ensure
      logger.warn "Connection builder finished"
    end
  }
end

# File lib/tella_peer.rb, line 28
def self.start_outbound_sceduler
  Thread.new {
    begin
      count = 0
      loop do
        logger.debug 'Send Ping'
        Connections.ping
        sleep 5
        logger.debug 'Send Query'
        Connections.query
        sleep 5
        Connections.clear_logs if count % 100 == 0
        count += 1
      end
    rescue
      logger.error "Outbound sceduler crashed"
      logger.error $!
    ensure
      logger.warn "Outbound sceduler finished"
    end
  }
end