@@ -37,13 +37,21 @@ module RB232 @reader_thread = Thread.new { buffer = "" while (@stop == false) - buffer += @port.read_string(1) - messages = buffer.split(@separator,3) - if messages.size > 1 - changed - notify_observers(messages[0]) - buffer = "" - end + new_string = "" + # Read in as much data as possible + begin + new_string = @port.read_string(255) + if (new_string.size > 0) + buffer += new_string + messages = buffer.split(@separator,2) + if messages.size > 1 + changed + notify_observers(messages[0]) + buffer = messages[1] || "" + end + end + end while (new_string.size > 0 && @stop == false) + sleep(0.5) end } end @@ -56,4 +64,4 @@ module RB232 end -end \ No newline at end of file +end lib/rb232/text_protocol.rb 85b91f82e0f0c733e81adb2b00671ef78d9ad057 James Smith james@floppy.org.uk http://github.com/Floppy/rb232/commit/c3bac991c833dd98a659b3b7d2be10c47cfa39c1 c3bac991c833dd98a659b3b7d2be10c47cfa39c1 2008-08-22T01:37:51-07:00 2008-08-22T01:37:51-07:00 Change text protocol for non-blocking reads. Read all available data in one go, then sleep a short while until trying again. Reduces CPU load and blocks. 71ce6f3e33d8f3bdb7518ccf345a8e685061393a James Smith james@floppy.org.uk