[nio-cvs] r42 - in branches/home/psmith/restructure: . src/protocol/yarpc

[psmith at common-lisp.net]

Author: psmith
Date: Wed Jan 17 23:26:42 2007
New Revision: 42

Modified:
   branches/home/psmith/restructure/run-yarpc-client.lisp
   branches/home/psmith/restructure/src/protocol/yarpc/yarpc-client-state-machine.lisp
Log:
loop sending rpc's and minor correction

Modified: branches/home/psmith/restructure/run-yarpc-client.lisp
==============================================================================
--- branches/home/psmith/restructure/run-yarpc-client.lisp	(original)
+++ branches/home/psmith/restructure/run-yarpc-client.lisp	Wed Jan 17 23:26:42 2007
@@ -6,5 +6,7 @@
 (sb-thread:make-thread #'(lambda()(nio:start-server 'identity 'identity nil :host "127.0.0.1" :port 9897)) :name "nio-server")
 (sleep 4)
 (let ((sm (nio:add-connection "127.0.0.1" 16323 'nio-yarpc:yarpc-client-state-machine)))
-(format t "toplevel adding conn ~A~%" sm)
-(format t "Result of remote-execute ~A~%" (nio-yarpc:remote-execute sm "(nio-yarpc:test-rpc-list)")))
+
+(loop
+  (format t "toplevel adding conn ~A~%" sm)
+  (format t "Result of remote-execute ~A~%" (nio-yarpc:remote-execute sm "(nio-yarpc:test-rpc-list)"))))

Modified: branches/home/psmith/restructure/src/protocol/yarpc/yarpc-client-state-machine.lisp
==============================================================================
--- branches/home/psmith/restructure/src/protocol/yarpc/yarpc-client-state-machine.lisp	(original)
+++ branches/home/psmith/restructure/src/protocol/yarpc/yarpc-client-state-machine.lisp	Wed Jan 17 23:26:42 2007
@@ -68,13 +68,12 @@
   (format t "yarpc-client-state-machine:process-incoming-packet called :sm ~A :packet ~A~%" sm response)
   (let* ((*package* (find-package :nio-yarpc))
          (result  (read-from-string (response response))))
-    (nio-compat:add (result-queue sm) result)
-    (setf (state sm) STATE-INITIALISED)))
+    (setf (state sm) STATE-INITIALISED)    
+    (nio-compat:add (result-queue sm) result)))
   
 ;Called from an external thread i.e. *not* the nio thread
 ;Blocks calling thread on the remote m/c's response
 (defmethod remote-execute ((sm yarpc-client-state-machine) call-string)
-;    (queue-outgoing-packet 
   (assert (eql (state sm) STATE-INITIALISED))
   (nio-compat:add (job-queue sm) (make-instance 'call-method-packet :call-string call-string))
   (nio-compat:take (result-queue sm)))
\ No newline at end of file