Mercurial > hg > blitz_stable

comparison test/org/dancres/blitz/LeaseTrackTest.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.io.Serializable;
4 import java.rmi.MarshalledObject;
5
6 import net.jini.core.entry.Entry;
7 import net.jini.core.lease.Lease;
8
9 import org.dancres.blitz.mangler.*;
10
11 import org.dancres.blitz.lease.SpaceUID;
12
13 import org.dancres.blitz.disk.Disk;
14
15 public class LeaseTrackTest {
16 /**
17 Write 3 entries, saving leases
18
19 sync
20
21 Update entry 0 lease
22
23 sync
24
25 Cancel entry 0 lease
26
27 sync
28
29 stop
30 */
31 public static void main(String args[]) {
32 try {
33 System.out.println("Start space");
34
35 SpaceImpl mySpace = new SpaceImpl(null);
36
37 System.out.println("Prepare entry");
38
39 EntryMangler myMangler = new EntryMangler();
40 TestEntry myEntry = new TestEntry();
41 myEntry.init();
42
43 System.out.println("init'd entry");
44 MangledEntry myPackedEntry = myMangler.mangle(new TestEntry());
45
46 System.out.println("Do write");
47 SpaceUID[] myUIDs = new SpaceUID[3];
48
49 for (int i = 0; i < 3; i++ ) {
50 myUIDs[i] = mySpace.write(myPackedEntry, null, 50000).getUID();
51 }
52
53 Disk.sync();
54
55 System.out.println("Renew entry");
56 mySpace.getLeaseControl().renew(myUIDs[0], 500000);
57
58 Disk.sync();
59 System.out.println("Cancel entry");
60 mySpace.getLeaseControl().cancel(myUIDs[0]);
61
62 Disk.sync();
63 System.out.println("Settling");
64
65 try {
66 Thread.sleep(5000);
67 } catch (InterruptedException anIE) {
68 }
69
70 System.out.println("Do stop");
71
72 mySpace.stop();
73
74 } catch (Exception anE) {
75 System.err.println("Got exception :(");
76 anE.printStackTrace(System.err);
77 }
78 }
79
80 public static class TestEntry implements Entry {
81 public String rhubarb;
82 public Integer count;
83
84 public TestEntry() {
85 }
86
87 public void init() {
88 rhubarb = "blah";
89 count = new Integer(5);
90 }
91
92 public String toString() {
93 return super.toString() + ", " + rhubarb + ", " + count;
94 }
95 }
96 }