[Gzz-commits] storm/org/nongnu/storm/http/client testSimpleHT...

[Hermanni Hyytiälä]

CVSROOT:        /cvsroot/storm
Module name:    storm
Changes by:     Hermanni Hyytiälä <address@hidden>      03/04/28 03:59:39

Modified files:
        org/nongnu/storm/http/client: testSimpleHTTPClient.test 

Log message:
        Not quite yet, continue at the office

CVSWeb URLs:
http://savannah.gnu.org/cgi-bin/viewcvs/storm/storm/org/nongnu/storm/http/client/testSimpleHTTPClient.test.diff?tr1=1.2&tr2=1.3&r1=text&r2=text

Patches:
Index: storm/org/nongnu/storm/http/client/testSimpleHTTPClient.test
diff -u storm/org/nongnu/storm/http/client/testSimpleHTTPClient.test:1.2 
storm/org/nongnu/storm/http/client/testSimpleHTTPClient.test:1.3
--- storm/org/nongnu/storm/http/client/testSimpleHTTPClient.test:1.2    Fri Apr 
25 10:44:09 2003
+++ storm/org/nongnu/storm/http/client/testSimpleHTTPClient.test        Mon Apr 
28 03:59:39 2003
@@ -26,6 +26,11 @@
 from org.nongnu.storm.http.client import HTTPConnection
 from org.nongnu.storm.http.client import HTTPRequest
 from org.nongnu.storm.http.client import HTTPResponse
+from org.nongnu.storm.impl import TransientPool
+from org.nongnu.storm.modules.gispmap import GispP2PMap
+from org.nongnu.storm.impl.p2p import Peer
+from org.nongnu.storm.impl import DirPool
+from org.nongnu.storm.util import HTTPProxy
 
 host0 = "127.0.0.1"
 host1 = "fishy.it.jyu.fi"
@@ -33,7 +38,7 @@
 host3 = "kanetti1390.kanetti.com"
 
 port = 5555
-request = "/rewrite/urn:x-storm:1.0:text/plain,\
+request = "rewrite/urn:x-storm:1.0:text/plain,\
 dvi7nrvd36pnprsmg4x55klqnqzvfgkc.f2aagxw4lfv7smbyzpm5tpf6ypajrdvh6ndqfky"
 
 protocol1 = "HTTP/1.1"
@@ -42,11 +47,30 @@
 
 def testHTTPClient():
 
+        empty = java.util.Collections.EMPTY_SET
+        pool = DirPool(java.io.File("/home/hemppah/cvs/storm"), empty)
+        
+        #pub = TransientPool(empty)
+        #cache = TransientPool(empty)
+        #map1 = GispP2PMap("/home/hemppah/cvs/storm")    
+        #peer = Peer(pub, cache, map1)    
+        #pool = peer.getPool()
+        
+        
+        java.lang.Thread(HTTPProxy(pool, 5555)).start()
+        
+        print "HTTP proxy thread started..."
+        
         httpconn = org.nongnu.storm.http.client.HTTPConnection(host0, port)
                 
         req = httpconn.newRequest("GET", request, protocol2, 
java.lang.Boolean.FALSE)
-                
+        print "Make GET request(s)..."
+        
         resp = httpconn.send(req)       
-        #print resp.status, resp.reason
+        print resp.status, resp.reason
         #assert resp.status == "Ok"
-        httpconn.close  
+        
+        httpconn.close
+        #java.lang.Thread.currentThread().interrupt()
+        java.lang.Thread.interrupt()
+        print "HTTP proxy thread stopped..."