RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2024-12-18 01:16:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

*** empty log message ***

Browse Source 
git-svn-id: https://ceph.svn.sf.net/svnroot/ceph@397 29311d96-e01e-0410-9327-a35deaab8ce9
This commit is contained in:
sage 2005-07-05 17:07:32 +00:00
parent 919f5ecd8d
commit 1ea60c98b7
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
ceph/tcpsyn.cc
View File

@ -161,6 +161,7 @@ int main(int oargc, char **oargv) {
}
// create client
int nclients = 0;
for (int i=0; i<NUMCLIENT; i++) {
if (myrank != MPI_DEST_TO_RANK(MSG_ADDR_CLIENT(i),world)) continue;
@ -177,11 +178,16 @@ int main(int oargc, char **oargv) {
syn[i]->sargs = syn_sargs;
syn[i]->iargs = syn_iargs;
syn[i]->start_thread();
nclients++;
}
if (nclients) {
cout << "waiting for " << nclients << " clients to finish" << endl;
}
for (int i=0; i<NUMCLIENT; i++) {
if (myrank != MPI_DEST_TO_RANK(MSG_ADDR_CLIENT(i),world)) continue;
cout << "waiting for synthetic client" << i << " to finish" << endl;
// cout << "waiting for synthetic client" << i << " to finish" << endl;
syn[i]->join_thread();
delete syn[i];