Contents

module Resque
  class Pool
    module Logging
      extend self

      # more than a little bit complicated...
      # copied this from Unicorn.
      def self.reopen_logs!
        log "Flushing logs"
        [$stdout, $stderr].each do |fd|
          if fd.instance_of? File
            # skip if the file is the exact same inode and device
            orig_st = fd.stat
            begin
              cur_st = File.stat(fd.path)
              next if orig_st.ino == cur_st.ino && orig_st.dev == cur_st.dev
            rescue Errno::ENOENT
            end
            # match up the encoding
            open_arg = 'a'
            if fd.respond_to?(:external_encoding) && enc = fd.external_encoding
              open_arg << ":#{enc.to_s}"
              enc = fd.internal_encoding and open_arg << ":#{enc.to_s}"
            end
            # match up buffering (does reopen reset this?)
            sync = fd.sync
            # sync to disk
            fd.fsync
            # reopen, and set ruby buffering appropriately
            fd.reopen fd.path, open_arg
            fd.sync = sync
            log "Reopened logfile: #{fd.path}"
          end
        end
      end

      # Given a string, sets the procline ($0)
      # Procline is always in the format of:
      #   resque-pool-master: STRING
      def procline(string)
        $0 = "resque-pool-master: #{string}"
      end

      # TODO: make this use an actual logger
      def log(message)
        puts "resque-pool-manager[#{Process.pid}]: #{message}"
        #$stdout.fsync
      end

      # TODO: make this use an actual logger
      def log_worker(message)
        puts "resque-pool-worker[#{Process.pid}]: #{message}"
        #$stdout.fsync
      end

    end
  end
end

Version data entries

6 entries across 6 versions & 2 rubygems

Version	Path
resque-pool-0.3.0.beta.2	lib/resque/pool/logging.rb
vitobotta-resque-pool-0.3.2.dev	lib/resque/pool/logging.rb
vitobotta-resque-pool-0.3.1.dev	lib/resque/pool/logging.rb
vitobotta-resque-pool-0.3.0.dev	lib/resque/pool/logging.rb
resque-pool-0.3.0.beta.1	lib/resque/pool/logging.rb
resque-pool-0.2.0	lib/resque/pool/logging.rb