Mercurial > hg > orthanc

comparison UnitTestsSources/MultiThreadingTests.cpp @ 2242:4e8e0ad2001c

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
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())