[Gzz-commits] storm/org/nongnu/storm impl/p2p/P2PPool.java mo...

[Hermanni Hyytiälä]

CVSROOT:        /cvsroot/storm
Module name:    storm
Changes by:     Hermanni Hyytiälä <address@hidden>      03/05/07 04:10:32

Modified files:
        org/nongnu/storm/impl/p2p: P2PPool.java 
        org/nongnu/storm/modules/gispmap: GispP2PMap.java 

Log message:
        More debugging...

CVSWeb URLs:
http://savannah.gnu.org/cgi-bin/viewcvs/storm/storm/org/nongnu/storm/impl/p2p/P2PPool.java.diff?tr1=1.5&tr2=1.6&r1=text&r2=text
http://savannah.gnu.org/cgi-bin/viewcvs/storm/storm/org/nongnu/storm/modules/gispmap/GispP2PMap.java.diff?tr1=1.7&tr2=1.8&r1=text&r2=text

Patches:
Index: storm/org/nongnu/storm/impl/p2p/P2PPool.java
diff -u storm/org/nongnu/storm/impl/p2p/P2PPool.java:1.5 
storm/org/nongnu/storm/impl/p2p/P2PPool.java:1.6
--- storm/org/nongnu/storm/impl/p2p/P2PPool.java:1.5    Mon Apr 21 17:07:41 2003
+++ storm/org/nongnu/storm/impl/p2p/P2PPool.java        Wed May  7 04:10:31 2003
@@ -59,18 +59,22 @@
     public Block get(BlockId id) throws IOException {
        try {
            return cache.get(id);
+           p("Block found from the local pool..."
        } catch(FileNotFoundException _) {
+           p("Block did't found from the local pool..."
            Collector c = map.get(id.toString());
            for(Iterator i=c.blockingIterator(); i.hasNext();) {
                String url = (String)i.next();
                try {
                    URLConnection conn = new URL(url).openConnection();
                    String contentType = conn.getContentType();
+                   p("Trying to connect to: " + url
                    if(contentType == null) continue;
                    BlockOutputStream bos = 
                        cache.getBlockOutputStream(conn.getContentType());
                    CopyUtil.copy(conn.getInputStream(), bos);
                    if(bos.getBlockId().equals(id))
+                       
                        return bos.getBlock();
                    else
                        p("Block ids didn't match: "+id+" / "+
Index: storm/org/nongnu/storm/modules/gispmap/GispP2PMap.java
diff -u storm/org/nongnu/storm/modules/gispmap/GispP2PMap.java:1.7 
storm/org/nongnu/storm/modules/gispmap/GispP2PMap.java:1.8
--- storm/org/nongnu/storm/modules/gispmap/GispP2PMap.java:1.7  Tue May  6 
05:56:04 2003
+++ storm/org/nongnu/storm/modules/gispmap/GispP2PMap.java      Wed May  7 
04:10:31 2003
@@ -123,6 +123,6 @@
     }
 
     public static void main(String argv[]) throws Exception { 
-       new GispP2PMap(PORT, argv); 
+       new GispP2PMap(PORT, argv);     
     }
 }