plugins/org.eclipse.dltk.ruby.abstractdebugger/debugger/dbgp/Communicator.rb

require 'socket'
require 'monitor'
require 'common/Params'
require 'common/Logger'

module XoredDebugger
	class Communicator
	    include Logger
        
	    def initialize(thread)
	        params = Params.instance
            @socket = TCPSocket.new(params.host, params.port)
            @socket.sync = true
            @monitor = Monitor.new()
	    end
        
	    def receive_command
            #IDE: command [SPACE] [args] -- data [NULL]
            line = ''       
            while((ch = @socket.getc) != 0)
                if (ch.nil?)
                    raise IOError
                end
                line << ch
            end
            log('RECEIVED: ' + line)
            return Command.new(line)
        end
        
        def sendPacket(packet)
            @monitor.synchronize do
	            #DEBUGGER: [NUMBER] [NULL] XML(data) [NULL]
	            xml = packet.to_xml
	            log('SENDING: ' + xml)            
	            @socket.write(xml.length.to_s)
	            @socket.putc(0)
	            @socket.write(xml)
	            @socket.putc(0)
	            @socket.flush
            end
        end	  
        
        def close()
            begin
                @socket.close
            rescue Exception
            end
        end  
	end 
end