From 972031013495586c98409e86304ab22779cfdbd0 Mon Sep 17 00:00:00 2001
From: erickson <erickson@9efc2488-bf62-4759-914b-345cdb29e865>
Date: Mon, 26 Nov 2007 22:35:42 +0000
Subject: [PATCH] added error message. re-tabbed to 4 spaces

git-svn-id: svn://svn.open-ils.org/OpenSRF/trunk@1147 9efc2488-bf62-4759-914b-345cdb29e865
---
 src/python/osrf/stack.py | 73 ++++++++++++++++++++--------------------
 1 file changed, 37 insertions(+), 36 deletions(-)

diff --git a/src/python/osrf/stack.py b/src/python/osrf/stack.py
index 4002812..8cced83 100644
--- a/src/python/osrf/stack.py
+++ b/src/python/osrf/stack.py
@@ -22,74 +22,75 @@ from time import time
 
 
 def osrfPushStack(netMessage):
-   ses = osrfSession.findSession(netMessage.thread)
+    ses = osrfSession.findSession(netMessage.thread)
 
-   if not ses:
-      # This is an incoming request from a client, create a new server session
-      pass
+    if not ses:
+        # This is an incoming request from a client, create a new server session
+        osrfLogErr("server-side sessions don't exist yet")
+        pass
 
-   ses.setRemoteId(netMessage.sender)
+    ses.setRemoteId(netMessage.sender)
 
-   oMessages = osrfJSONToObject(netMessage.body)
+    oMessages = osrfJSONToObject(netMessage.body)
 
-   osrfLogInternal("osrfPushStack(): received %d messages" % len(oMessages))
+    osrfLogInternal("osrfPushStack(): received %d messages" % len(oMessages))
 
-   # Pass each bundled opensrf message to the message handler
-   t = time()
-   for m in oMessages:
-      osrfHandleMessage(ses, m)
-   t = time() - t
+    # Pass each bundled opensrf message to the message handler
+    t = time()
+    for m in oMessages:
+        osrfHandleMessage(ses, m)
+    t = time() - t
 
-   if isinstance(ses, osrfServerSession):
-      osrfLogInfo("Message processing duration %f" % t)
+    if isinstance(ses, osrfServerSession):
+        osrfLogInfo("Message processing duration %f" % t)
 
 def osrfHandleMessage(session, message):
 
-   osrfLogInternal("osrfHandleMessage(): processing message of type %s" % message.type())
+    osrfLogInternal("osrfHandleMessage(): processing message of type %s" % message.type())
 
-   if isinstance(session, osrfClientSession):
-      
-      if message.type() == OSRF_MESSAGE_TYPE_RESULT:
-         session.pushResponseQueue(message)
-         return
+    if isinstance(session, osrfClientSession):
 
-      if message.type() == OSRF_MESSAGE_TYPE_STATUS:
+        if message.type() == OSRF_MESSAGE_TYPE_RESULT:
+            session.pushResponseQueue(message)
+            return
+
+        if message.type() == OSRF_MESSAGE_TYPE_STATUS:
 
-         statusCode = int(message.payload().statusCode())
-         statusText = message.payload().status()
-         osrfLogInternal("osrfHandleMessage(): processing STATUS,  statusCode =  %d" % statusCode)
+            statusCode = int(message.payload().statusCode())
+            statusText = message.payload().status()
+            osrfLogInternal("osrfHandleMessage(): processing STATUS,  statusCode =  %d" % statusCode)
 
-         if statusCode == OSRF_STATUS_COMPLETE:
+        if statusCode == OSRF_STATUS_COMPLETE:
             # The server has informed us that this request is complete
             req = session.findRequest(message.threadTrace())
             if req: 
-               osrfLogInternal("marking request as complete: %d" % req.id)
-               req.setComplete()
+                osrfLogInternal("marking request as complete: %d" % req.id)
+                req.setComplete()
             return
 
-         if statusCode == OSRF_STATUS_OK:
+        if statusCode == OSRF_STATUS_OK:
             # We have connected successfully
             osrfLogDebug("Successfully connected to " + session.service)
             session.state = OSRF_APP_SESSION_CONNECTED
             return
 
-         if statusCode == OSRF_STATUS_CONTINUE:
+        if statusCode == OSRF_STATUS_CONTINUE:
             # server is telling us to reset our wait timeout and keep waiting for a response
             session.resetRequestTimeout(message.threadTrace())
             return;
 
-         if statusCode == OSRF_STATUS_TIMEOUT:
+        if statusCode == OSRF_STATUS_TIMEOUT:
             osrfLogDebug("The server did not receive a request from us in time...")
             session.state = OSRF_APP_SESSION_DISCONNECTED
             return
 
-         if statusCode == OSRF_STATUS_NOTFOUND:
+        if statusCode == OSRF_STATUS_NOTFOUND:
             osrfLogErr("Requested method was not found on the server: %s" % statusText)
             session.state = OSRF_APP_SESSION_DISCONNECTED
             raise osrfServiceException(statusText)
 
-         raise osrfProtocolException("Unknown message status: %d" % statusCode)
-      
-         
-   
-   
+        raise osrfProtocolException("Unknown message status: %d" % statusCode)
+
+
+
+
-- 
2.43.2