Changeset 81a7f3f

Timestamp:

Aug 5, 2009 11:10:14 AM (15 years ago)

Author:

Ted Faber <faber@…>

Branches:

axis_example, compt_changes, info-ops, master, version-2.00, version-3.01, version-3.02

Children:

ab37086

Parents:

df783c1

Message:

Add handlers for serving files

Location:

fedd/federation

Files:

• deter_impl.py (modified) (1 diff)
• server.py (modified) (3 diffs)

fedd/federation/deter_impl.py

@@ -60 +60 @@
                 self.soap_services.update(self.experiment.soap_services) 
                 self.xmlrpc_services.update(self.experiment.xmlrpc_services) 
+                self.get_handler = self.experiment.get_handler
+            else:
+                self.get_handler = self.experiment.get_handler
 
             if config.has_section("splitter"):

fedd/federation/server.py

@@ -15 +15 @@
 from fedd_services import ns0
 from service_error import *
+
+import os.path
 
 import logging
@@ -39 +41 @@
         self.soap_methods = impl.soap_services
         self.xmlrpc_methods = impl.xmlrpc_services
+        self.get_handler = impl.get_handler
         self.log = logging.getLogger("fedd")
         if debug: self.handle_error = self.handle_error_debug
@@ -130 +133 @@
             self.send_xml(str(sw))
 
+    def do_GET(self):
+        """
+        If a get handler is registered, use that to retrieve data.
+        """
+        if self.server.get_handler:
+            code = 200
+            fid = fedid(cert=self.request.get_peer_cert())
+            print "in do_GET: %s %s" % (fid, self.request.get_peer_cert())
+            fname, type = self.server.get_handler(self.path, fid)
+            try:
+                f = open(fname, "rb")
+                size = os.path.getsize(fname)
+            except IOError, e:
+                code = 404
+                size = 0
+        else:
+            code = 404
+            size = 0
+
+        self.send_response(code)
+        if code == 200:
+            if type:
+                self.send_header('Content-type', type)
+            self.send_header('Content-Length', size)
+            self.end_headers()
+            bytes = f.read(4096)
+            while len(bytes):
+                self.wfile.write(bytes)
+                bytes = f.read(4096)
+            self.wfile.flush()
+        self.request.socket.close()
+
+
     def log_request(self, code=0, size=0):
         """