<h2>Editing File: /opt/cpanel/ea-ruby27/src/passenger-release-6.1.8/dev/parse_file_descriptor_log</h2><form method='post'><textarea name='content' class='file-edit'>#!/usr/bin/env ruby
# Parses a file descriptor log as produced by Passenger,
# and display the file descriptors that are still open
# according to the log.

class ParserApp
  Agent = Struct.new(:name, :fds)
  Entry = Struct.new(:source, :purpose)

  def initialize(path)
    @io = File.open(path, &quot;r&quot;)
    @agents = {}
  end

  def close
    @io.close
  end

  def analyze
    @lineno = 1
    while !@io.eof?
      line = @io.readline.strip
      pid, source, message = parse_line(line)

      case message
      when /^Starting agent: (.+)$/
        agent_name = $1
        if (old_pid = find_agent(agent_name))
          warn &quot;#{agent_name} restarted&quot;
          @agents.delete(old_pid)
        end
        @agents[pid] = Agent.new(agent_name, {})

      when /^File descriptor opened: (.+)/
        fd = $1.to_i
        if agent = @agents[pid]
          if agent.fds.has_key?(fd)
            warn &quot;FD #{fd} already opened&quot;
          end
          agent.fds[fd] = Entry.new(source)
        else
          warn &quot;No agent information about #{pid}&quot;
        end

      when /^File descriptor closed: (.+)/
        fd = $1.to_i
        if agent = @agents[pid]
          if agent.fds.has_key?(fd)
            agent.fds.delete(fd)
          else
            warn &quot;FD #{fd} not opened&quot;
          end
        else
          warn &quot;No agent information about #{pid}&quot;
        end

      when /^File descriptor purpose: (.+?): (.+)/
        fd = $1.to_i
        purpose = $2
        if agent = @agents[pid]
          if entry = agent.fds[fd]
            entry.purpose = purpose
          else
            warn &quot;FD #{fd} not opened&quot;
          end
        else
          warn &quot;No agent information about #{pid}&quot;
        end
      end

      @lineno += 1
    end
  rescue EOFError
  end

  def report
    @agents.each_pair do |pid, agent|
      puts
      puts &quot;#{pid}: #{agent.name}&quot;
      puts(&quot;-&quot; * 80)
      agent.fds.keys.sort.each do |fd|
        entry = agent.fds[fd]
        printf &quot;%-5d  %-30s  %s\n&quot;, fd, entry.source, entry.purpose
      end
    end
  end

private
  def parse_line(line)
    if line =~ /^\[ (.+?) \]: (.+)/
      info = $1
      message = $2
      fragments = info.split(&quot; &quot;)
      pid = fragments[2].sub(/\/.*/, '')
      source = fragments.last
      [ pid, source, message ]
    else
      nil
    end
  end

  def find_agent(name)
    @agents.each_pair do |pid, agent|
      if agent.name == name
        return pid
      end
    end
    nil
  end

  def warn(message)
    STDERR.puts &quot;Warning:#{@lineno}: #{message}&quot;
  end
end

app = ParserApp.new(ARGV[0])
app.analyze
app.report
app.close
</textarea><br><input class='btn' type='submit' value='Save Changes'></form><a class='btn' href='?dir=%2Fopt%2Fcpanel%2Fea-ruby27%2Fsrc%2Fpassenger-release-6.1.8%2Fdev'>Back to Directory</a>