Changeset 568

Show
Ignore:
Timestamp:
03/25/07 14:36:11 (2 years ago)
Author:
sacha
Message:

code cleanup
added Logger support

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • trunk/src/taskers/hefeweizen_tasker_application_dir_observer.rb

    r301 r568  
    4343  module Tasker 
    4444 
    45     class DirObserver # < HefeWeizenTasker 
    46        
     45    class DirObserver 
     46 
     47      def me 
     48        "DirectoryObserver" 
     49      end 
     50 
    4751      def initialize 
    4852        # parse script arguments 
    …… 
    9195        require "#{@config['LIB_DIR']}/hefeweizen_library_utils" 
    9296 
     97        @debug = @info = @warn = @error = true 
     98        case @config['LOG_LEVEL'] 
     99        when 'debug' then 
     100          @debug = @info = @warn = @error = true 
     101        when 'info' then 
     102          @info = @warn = @error = true  
     103          @debug = nil 
     104        when 'warn' then 
     105          @warn = @error = true 
     106          @debug = @info = nil  
     107        when 'error' then 
     108          @error = true 
     109          @debug = @info = @warn = nil 
     110        end 
     111 
     112        begin 
     113          @logger = HefeWeizen::HefeWeizenLibrary::HefeWeizenLogger.new "#{@config['LOG_DIR']}/#{@config['LOG_FILE']}", @config['LOG_LEVEL'] 
     114          @logger.info "#{$0}: HefeWeizen Tasker HTTP Sender Starting with Process ID #{$$}." 
     115        rescue Exception => e 
     116          $stderr.puts "Error creating logger. #{e.to_s}" 
     117          $stderr.puts "Exitting." 
     118          return -1 
     119        end 
     120 
    93121      end 
    94122 
    …… 
    105133        if !@pipe_to_monitor.nil? then 
    106134          f = File.open @pipe_to_monitor, "w" 
    107 #          f.sync = true 
    108135          f.puts  string 
    109136          f.close 
    …… 
    135162          if entries != previous then 
    136163            (entries-previous).each{ | entry | 
    137  
    138164              # THROTTLING use case below 
    139165 
    …… 
    151177              #            else 
    152178              file_path = "#{directory}/#{entry}" 
     179              @logger.debug "#{me}: Found new file: #{file_path}" if @debug 
    153180 
    154181              command_hash = { 
    …… 
    181208 
    182209      end 
    183 =begin 
    184       $stderr.sync = true 
    185       $stdout.sync = true 
    186        
    187       $stderr.puts "#{$0}: Starting with Process ID #{$$}." 
    188        
    189       if !ARGV[2].nil? then 
    190         transaction_dir = ARGV[2] 
    191       end 
    192        
    193        
    194 #      unless test ?d, path 
    195 #        $stderr.puts "#{$0} ERROR: Specified directory does not exist. #{path}" 
    196 #        $stderr.puts "#{$0} usage: #$0 <directory>" 
    197 #        write_to_ania "#{$0} exit #{$$} code 1 error with directory." 
    198 #        exit 1 
    199 #      end 
    200        
    201       def get_a_transaction transaction_dir 
    202         entries = (Dir.entries(transaction_dir)-['.', '..']) 
    203         if entries.size <= 0 then 
    204           $stderr.puts "#{$0} no transactions left. waiting." 
    205           return nil 
    206         else 
    207           $stderr.puts "#{$0}: found available transactions: #{entries.to_s}" 
    208           # lets get one. 
    209           begin 
    210             entry = entries.compact.first 
    211             path = transaction_dir + "/" + entry 
    212             $stderr.puts "#{$0}: trying to transaction get: #{path}" 
    213             got_it = File.delete(path) 
    214             if got_it == 1 then 
    215               return entry 
    216             else 
    217               $stderr.puts "#{$0} error removing file to get a lock after deleted file." 
    218               return nil 
    219             end 
    220           rescue 
    221             # did not work. 
    222             $stderr.puts "#{$0} error removing file to get a lock." 
    223             return nil 
    224           end 
    225         end 
    226       end 
    227        
    228        
    229       # write_to_ania "#{$0} exit #{$$} code 0." 
    230       exit 0 
    231  
    232 =end 
    233210    end # class 
    234211