Mercurial > hg > orthanc
comparison UnitTestsSources/MultiThreadingTests.cpp @ 2242:4e8e0ad2001c
move USleep() in SystemToolbox
author | Sebastien Jodogne <s.jodogne@gmail.com> |
---|---|
date | Mon, 19 Dec 2016 15:31:01 +0100 |
parents | 21713ce8717b |
children | a3a65de1840f |
comparison
equal
deleted
inserted
replaced
2241:eb363ec95d86 | 2242:4e8e0ad2001c |
---|---|
141 ReusableDicomUserConnection::Locker lock(c, "ORTHANC", remote); | 141 ReusableDicomUserConnection::Locker lock(c, "ORTHANC", remote); |
142 lock.GetConnection().StoreFile("/home/jodogne/DICOM/Cardiac/MR.X.1.2.276.0.7230010.3.1.4.2831157719.2256.1336386844.676281"); | 142 lock.GetConnection().StoreFile("/home/jodogne/DICOM/Cardiac/MR.X.1.2.276.0.7230010.3.1.4.2831157719.2256.1336386844.676281"); |
143 } | 143 } |
144 | 144 |
145 printf("**\n"); fflush(stdout); | 145 printf("**\n"); fflush(stdout); |
146 Toolbox::USleep(1000000); | 146 SystemToolbox::USleep(1000000); |
147 printf("**\n"); fflush(stdout); | 147 printf("**\n"); fflush(stdout); |
148 | 148 |
149 { | 149 { |
150 RemoteModalityParameters remote("STORESCP", "localhost", 2000, ModalityManufacturer_Generic); | 150 RemoteModalityParameters remote("STORESCP", "localhost", 2000, ModalityManufacturer_Generic); |
151 ReusableDicomUserConnection::Locker lock(c, "ORTHANC", remote); | 151 ReusableDicomUserConnection::Locker lock(c, "ORTHANC", remote); |
182 //if (a == 84) { printf("BREAK\n"); return false; } | 182 //if (a == 84) { printf("BREAK\n"); return false; } |
183 | 183 |
184 outputs.push_back(boost::lexical_cast<std::string>(b)); | 184 outputs.push_back(boost::lexical_cast<std::string>(b)); |
185 } | 185 } |
186 | 186 |
187 Toolbox::USleep(30000); | 187 SystemToolbox::USleep(30000); |
188 | 188 |
189 return true; | 189 return true; |
190 } | 190 } |
191 }; | 191 }; |
192 | 192 |
201 s->GetListOfJobs(l); | 201 s->GetListOfJobs(l); |
202 for (ListOfStrings::iterator it = l.begin(); it != l.end(); ++it) | 202 for (ListOfStrings::iterator it = l.begin(); it != l.end(); ++it) |
203 { | 203 { |
204 printf(">> %s: %0.1f\n", it->c_str(), 100.0f * s->GetProgress(*it)); | 204 printf(">> %s: %0.1f\n", it->c_str(), 100.0f * s->GetProgress(*it)); |
205 } | 205 } |
206 Toolbox::USleep(3000); | 206 SystemToolbox::USleep(3000); |
207 } | 207 } |
208 } | 208 } |
209 | 209 |
210 | 210 |
211 TEST(MultiThreading, ServerScheduler) | 211 TEST(MultiThreading, ServerScheduler) |
246 { | 246 { |
247 printf("** %s\n", i->c_str()); | 247 printf("** %s\n", i->c_str()); |
248 } | 248 } |
249 | 249 |
250 //SystemToolbox::ServerBarrier(); | 250 //SystemToolbox::ServerBarrier(); |
251 //Toolbox::USleep(3000000); | 251 //SystemToolbox::USleep(3000000); |
252 | 252 |
253 scheduler.Stop(); | 253 scheduler.Stop(); |
254 | 254 |
255 done = true; | 255 done = true; |
256 if (t.joinable()) | 256 if (t.joinable()) |