88 throws Exception
89 {
90 assert equals(rr.listModuleIds(), mids)
91 : String.format("%s : %s", rr.listModuleIds(), mids);
92 assert equals(pr.listModuleIds(), mids)
93 : String.format("%s : %s", pr.listModuleIds(), mids);
94 out.format("Module ids: %s%n", mids);
95 for (ModuleId mid : mids) {
96 assert equals(rr.readModuleInfo(mid),
97 pr.readModuleInfo(mid));
98 assert equals(rr.fetch(mid), pr.fetch(mid));
99 }
100 }
101
102 static void testRemove(RemoteRepository rr, PublishedRepository pr)
103 throws Exception
104 {
105 check(rr, pr);
106 ModuleId mid = mids.iterator().next();
107 mids.remove(mid);
108 pr.remove(mid);
109 rr.updateCatalog(false);
110 check(rr, pr);
111 }
112
113 static void test(int port) throws Exception {
114
115 URI u = URI.create("http://localhost:" + port);
116
117 RemoteRepository rr = RemoteRepository.create(REM_REPO, u);
118 out.format("Remote %s %s%n", REM_REPO, u);
119
120 assert rr.isCatalogStale();
121 assert rr.updateCatalog(false);
122 assert !rr.isCatalogStale();
123 assert !rr.updateCatalog(false);
124 assert rr.updateCatalog(true);
125
126 PublishedRepository pr = _PublishedRepository.open();
127
|
88 throws Exception
89 {
90 assert equals(rr.listModuleIds(), mids)
91 : String.format("%s : %s", rr.listModuleIds(), mids);
92 assert equals(pr.listModuleIds(), mids)
93 : String.format("%s : %s", pr.listModuleIds(), mids);
94 out.format("Module ids: %s%n", mids);
95 for (ModuleId mid : mids) {
96 assert equals(rr.readModuleInfo(mid),
97 pr.readModuleInfo(mid));
98 assert equals(rr.fetch(mid), pr.fetch(mid));
99 }
100 }
101
102 static void testRemove(RemoteRepository rr, PublishedRepository pr)
103 throws Exception
104 {
105 check(rr, pr);
106 ModuleId mid = mids.iterator().next();
107 mids.remove(mid);
108 // Ensure time stamp of catelog after removal is at least one second >
109 // This is the minimum increment represented by the Last-modified header
110 Thread.sleep(2000);
111 pr.remove(mid);
112 rr.updateCatalog(false);
113 check(rr, pr);
114 }
115
116 static void test(int port) throws Exception {
117
118 URI u = URI.create("http://localhost:" + port);
119
120 RemoteRepository rr = RemoteRepository.create(REM_REPO, u);
121 out.format("Remote %s %s%n", REM_REPO, u);
122
123 assert rr.isCatalogStale();
124 assert rr.updateCatalog(false);
125 assert !rr.isCatalogStale();
126 assert !rr.updateCatalog(false);
127 assert rr.updateCatalog(true);
128
129 PublishedRepository pr = _PublishedRepository.open();
130
|