Changeset 8cab4c2 for fedd/federation/emulab_access.py

Timestamp:

Mar 4, 2012 6:45:19 PM (12 years ago)

Author:

Ted Faber <faber@…>

Branches:

compt_changes, master

Children:

6527d60

Parents:

2bb8b35

Message:

More improved logging

File:

• fedd/federation/emulab_access.py (modified) (22 diffs)

fedd/federation/emulab_access.py

@@ -241 +241 @@
             return rv
 
+        self.log.info("RequestAccess called by %s" % fid)
         # The dance to get into the request body
         if req.has_key('RequestAccessRequestBody'):
@@ -291 +292 @@
             f.close()
         except EnvironmentError, e:
+            self.log.info("RequestAccess failed for by %s: internal error" \
+                    % fid)
             raise service_error(service_error.internal, 
                     "Can't open %s/%s : %s" % (self.certdir, aid, e))
+        self.log.debug('RequestAccess Returning allocation ID: %s' % allocID)
         resp = self.build_access_response({ 'fedid': allocID } ,
                 pname, services, proof)
@@ -298 +302 @@
 
     def ReleaseAccess(self, req, fid):
+        self.log.info("ReleaseAccess called by %s" % fid)
         # The dance to get into the request body
         if req.has_key('ReleaseAccessRequestBody'):
@@ -335 +340 @@
             self.log.debug("Removing %s" % cf)
             os.remove(cf)
+            self.log.info("ReleaseAccess succeeded for %s" % fid)
             return { 'allocID': req['allocID'], 'proof': proof.to_dict() } 
         else:
@@ -811 +817 @@
         rv = None   # Return value from segment creation
 
+        self.log.info("StartSegment called by %s" % fid)
         try:
             req = req['StartSegmentRequestBody']
@@ -826 +833 @@
                 with_proof=True)
         if not access_ok:
+            self.log.info("StartSegment for %s failed: access denied" % fid)
             raise service_error(service_error.access, "Access denied")
         else:
@@ -852 +860 @@
             os.mkdir(softdir)
         except EnvironmentError:
+            self.log.info("StartSegment for %s failed: internal error" % fid)
             raise service_error(service_error.internal, "Cannot create tmp dir")
 
@@ -884 +893 @@
             rv = starter(self, ename, proj, user, expfile, tmpdir, gid=gid)
         except service_error, e:
+            self.log.info("StartSegment for %s failed: %s"  % (fid, e))
             err = e
         except:
             t, v, st = sys.exc_info()
+            self.log.info("StartSegment for %s failed: unexpected error:  %s" \
+                    % (fid, v, traceback.extract_tb(st)))
             err = service_error(service_error.internal, "%s: %s" % \
                     (v, traceback.extract_tb(st)))
@@ -895 +907 @@
 
         if rv:
+            self.log.info("StartSegment for %s succeeded" % fid)
             return self.finalize_experiment(starter, topo, aid, req['allocID'],
                     proof)
@@ -904 +917 @@
 
     def TerminateSegment(self, req, fid):
+        self.log.info("TerminateSegment called by %s" % fid)
         try:
             req = req['TerminateSegmentRequestBody']
@@ -934 +948 @@
 
         if not proj:
+            self.log.info("TerminateSegment failed for %s: cannot find project"\
+                    % fid)
             raise service_error(service_error.internal, 
                     "Can't find project for %s" % aid)
@@ -941 +957 @@
 
         if not user:
+            self.log.info("TerminateSegment failed for %s: cannot find user"\
+                    % fid)
             raise service_error(service_error.internal, 
                     "Can't find creation user for %s" % aid)
         if not ename:
+            self.log.info(
+                    "TerminateSegment failed for %s: cannot find experiment"\
+                    % fid)
             raise service_error(service_error.internal, 
                     "Can't find experiment name for %s" % aid)
@@ -950 +971 @@
                 cert=xmlrpc_cert)
         stopper(self, user, proj, ename, gid, nonce)
+        self.log.info("TerminateSegment succeeded for %s %s %s" % \
+                (fid, proj, ename))
         return { 'allocID': req['allocID'], 'proof': proof.to_dict() }
 
     def InfoSegment(self, req, fid):
+        self.log.info("InfoSegment called by %s" % fid)
         try:
             req = req['InfoSegmentRequestBody']
@@ -983 +1007 @@
 
         if not proj:
+            self.log.info("InfoSegment failed for %s: cannot find project"% fid)
             raise service_error(service_error.internal, 
                     "Can't find project for %s" % aid)
@@ -990 +1015 @@
 
         if not user:
+            self.log.info("InfoSegment failed for %s: cannot find user"% fid)
             raise service_error(service_error.internal, 
                     "Can't find creation user for %s" % aid)
         if not ename:
+            self.log.info("InfoSegment failed for %s: cannot find exp"% fid)
             raise service_error(service_error.internal, 
                     "Can't find experiment name for %s" % aid)
@@ -999 +1026 @@
                 cert=xmlrpc_cert)
         info(self, user, proj, ename)
+        self.log.info("InfoSegment gathered info for %s %s %s %s" % \
+                (fid, user, proj, ename))
         self.decorate_topology(info, topo)
         self.state_lock.acquire()
@@ -1005 +1034 @@
             self.write_state()
         self.state_lock.release()
+        self.log.info("InfoSegment updated info for %s %s %s %s" % \
+                (fid, user, proj, ename))
 
         rv = { 
@@ -1010 +1041 @@
                 'proof': proof.to_dict(),
                 }
+        self.log.info("InfoSegment succeeded info for %s %s %s %s" % \
+                (fid, user, proj, ename))
         if topo:
             rv['segmentdescription'] = { 'topdldescription' : topo.to_dict() }
@@ -1024 +1057 @@
                 return None
 
+        self.log.info("OperationSegment called by %s" % fid)
         try:
             req = req['OperationSegmentRequestBody']
@@ -1035 +1069 @@
                 with_proof=True)
         if not access_ok:
+            self.log.info("OperationSegment failed for %s: access denied" % fid)
             raise service_error(service_error.access, "Access denied")
 
@@ -1042 +1077 @@
 
         if op is None :
+            self.log.info("OperationSegment failed for %s: no operation" % fid)
             raise service_error(service_error.req, "missing operation")
         elif targets is None:
+            self.log.info("OperationSegment failed for %s: no targets" % fid)
             raise service_error(service_error.req, "no targets")
 
@@ -1072 +1109 @@
                 cert=xmlrpc_cert)
         ops(self, op, ptargets, params, topo)
+        self.log.info("OperationSegment operated for %s" % fid)
         
         status.extend(ops.status)
+        self.log.info("OperationSegment succeed for %s" % fid)
 
         return {