Changeset 45 for branches/home/psmith/restructure/src/protocol/yarpc/yarpc-state-machine.lisp

Timestamp:

01/19/07 02:07:22 (18 years ago)

Author:

psmith

Message:

Allowed yarpc server to do RPC calls inline if configured so

File:

• branches/home/psmith/restructure/src/protocol/yarpc/yarpc-state-machine.lisp (modified) (3 diffs)

branches/home/psmith/restructure/src/protocol/yarpc/yarpc-state-machine.lisp ¶

@@ -1 @@
-#|
+\#|
 Copyright (c) 2007
 All rights reserved.
@@ -53 +53 @@
 (defconstant STATE-SEND-RESPONSE 1)
 
+
+(defparameter +process-jobs-inline+ t
+  "Set this to make the NIO thread process the RPC calls - warning the procedure should not block!")
+
+
+
+(defun run-job(&key (wait-on-job-pdw t))
+  (format t "~A Server toplevel waiting for job~%" (nio-compat:get-readable-time))
+  (destructuring-bind (job result-queue) (nio-compat:take nio-yarpc:job-queue :blocking-call wait-on-job-pdw)
+    (format t "~A Server received job ~A~%" (nio-compat:get-readable-time) job)
+    (nio-compat:add result-queue (nio-yarpc:execute-call job))))
+
+
 (defmethod process-outgoing-packet((sm yarpc-state-machine))
   (format t "yarpc-state-machine: process-outgoing-packet called, polling the results-queue ~%")
@@ -64 +77 @@
   (assert (eql (state sm) STATE-INITIALISED))
   (format t "yarpc-state-machine:process-incoming-packet called :sm ~A :packet ~A~%" sm call)
-  (nio-compat:add job-queue (list (call-string call) (result-queue sm))))
+  (nio-compat:add job-queue (list (call-string call) (result-queue sm)))
+  (when +process-jobs-inline+ (run-job :wait-on-job-pdw nil)))