Mercurial > hg > blitz_stable

comparison test/org/dancres/blitz/BulkWriteTakeTest.java @ 0:3dc0c5604566

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Initial checkin of blitz 2.0 fcs - no installer yet.
author Dan Creswell <dan.creswell@gmail.com>
date Sat, 21 Mar 2009 11:00:06 +0000
parents
children
comparison
equal deleted inserted replaced
-1:000000000000 0:3dc0c5604566
1 package org.dancres.blitz;
2
3 import java.util.ArrayList;
4 import java.util.List;
5 import java.util.Collection;
6 import java.util.Iterator;
7
8 import net.jini.core.entry.Entry;
9 import net.jini.core.lease.Lease;
10
11 import org.dancres.blitz.mangler.*;
12
13 public class BulkWriteTakeTest {
14 public static void main(String args[]) {
15
16 try {
17 System.out.println("Start space");
18
19 SpaceImpl mySpace = new SpaceImpl(null);
20
21 System.out.println("Prepare entry");
22
23 EntryMangler myMangler = new EntryMangler();
24
25 ArrayList myMangled = new ArrayList();
26 ArrayList myLeases = new ArrayList();
27
28 for (int i = 0; i < 100; i++) {
29 TestEntry myEntry = new TestEntry(Integer.toString(i));
30 MangledEntry myPackedEntry = myMangler.mangle(myEntry);
31 myMangled.add(myPackedEntry);
32 myLeases.add(new Long(300000 + i));
33 }
34
35 List myLeaseResults = mySpace.write(myMangled, null, myLeases);
36
37 for (int i = 0; i < myLeaseResults.size(); i++) {
38 System.out.println("Lease: " + i + " is " + ((WriteTicket) myLeaseResults.get(i)).getExpirationTime());
39 }
40
41 MangledEntry myTemplate = myMangler.mangle(new TestEntry());
42
43 Collection myTakes;
44 int myTotal = 0;
45
46 while ((myTakes = mySpace.take(new MangledEntry[] {myTemplate},
47 null, 30000, 25)).size() != 0) {
48
49 System.out.println("Chunk");
50 Iterator myTaken = myTakes.iterator();
51 while (myTaken.hasNext()) {
52 System.out.println(myTaken.next());
53 ++myTotal;
54 }
55 }
56
57 System.out.println("Total takes: " + myTotal);
58
59 mySpace.stop();
60
61 } catch (Exception anE) {
62 System.err.println("Got exception :(");
63 anE.printStackTrace(System.err);
64 }
65
66 }
67
68 public static class TestEntry implements Entry {
69 public String rhubarb;
70 public Integer count;
71
72 public TestEntry(String aThing) {
73 }
74
75 public TestEntry() {
76 }
77
78 public void init() {
79 rhubarb = "blah";
80 count = new Integer(5);
81 }
82
83 public String toString() {
84 return super.toString() + ", " + rhubarb + ", " + count;
85 }
86 }
87 }