Contents

module FlyAdmin
  class StopFFmpegJob < ActiveJob::Base
    queue_as :default

    def perform(*args)
      video_ids = Video.where(state: Video::FAILURE_STATE).select(:id).map(&:id)
      pid_file = "#{Rails.root}/tmp/pids/ffmpeg_pids.pid"
      if File.exists?(pid_file)

        File.open(pid_file) do |f|
          f.each_line do |line|
            str = /video_(\d+)\ with\ pid:\ (\d+)/.match(line)
            next unless str
            video_id = str[1].to_i
            ffmpeg_pid = str[2].to_i
            if video_ids.include?(video_id)
              system("kill -9 #{ffmpeg_pid}")
            end
          end
        end
        system("rm #{pid_file}")
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
fly_admin-0.0.8	app/jobs/fly_admin/stop_f_fmpeg_job.rb
fly_admin-0.0.7	app/jobs/fly_admin/stop_f_fmpeg_job.rb
fly_admin-0.0.6	app/jobs/fly_admin/stop_f_fmpeg_job.rb
fly_admin-0.0.5	app/jobs/fly_admin/stop_f_fmpeg_job.rb
fly_admin-0.0.4	app/jobs/fly_admin/stop_f_fmpeg_job.rb
fly_admin-0.0.3	app/jobs/fly_admin/stop_f_fmpeg_job.rb
fly_admin-0.0.2	app/jobs/fly_admin/stop_f_fmpeg_job.rb
fly_admin-0.0.1	app/jobs/fly_admin/stop_f_fmpeg_job.rb