/[storm]/storm/org/nongnu/storm/impl/p2p/P2PPool.java
ViewVC logotype

Diff of /storm/org/nongnu/storm/impl/p2p/P2PPool.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 1.7 by hemppah, Wed May 7 08:21:57 2003 UTC revision 1.8 by benja, Fri May 9 10:54:56 2003 UTC
# Line 89  public class P2PPool extends AbstractLoc Line 89  public class P2PPool extends AbstractLoc
89      }      }
90    
91      public SetCollector getIds() throws IOException {      public SetCollector getIds() throws IOException {
92          return cache.getIds();          Collector c = map.get("http://fenfire.org/2003/05/published-blocks");
93            final AsyncSetCollector result = new AsyncSetCollector();
94    
95            for(Iterator i=cache.getIds().iterator(); i.hasNext();)
96                result.receive(i.next());
97    
98            c.addCollectionListener(new CollectionListener() {
99                    public boolean item(Object item) {
100                        result.receive(new BlockId((String)item));
101                        return true;
102                    }
103                    public void finish(boolean timeout) {
104                        result.finish(timeout);
105                    }
106                });
107            return result;
108      }      }
109    
110      public void add(Block b) {      public void add(Block b) {

Legend:
Removed from v.1.7  
changed lines
  Added in v.1.8

savannah-hackers-public@gnu.org
ViewVC Help
Powered by ViewVC 1.1.26