File tree Expand file tree Collapse file tree 1 file changed +20
-26
lines changed
Expand file tree Collapse file tree 1 file changed +20
-26
lines changed Original file line number Diff line number Diff line change @@ -164,19 +164,16 @@ static DWORD WINAPI call_startfn(LPVOID vindex)
164164 ConverseRunPE (0 );
165165
166166 if (CharmLibInterOperate ) {
167- while (1 ) {
168- if (!_cleanUp .load ()) {
169- StartInteropScheduler ();
170- CmiNodeAllBarrier ();
171- } else {
172- if (CmiMyRank () == CmiMyNodeSize ()) {
173- while (ckExitComplete .load () == 0 ) { CommunicationServerThread (5 ); }
174- } else {
175- CsdScheduler (-1 );
176- CmiNodeAllBarrier ();
177- }
178- break ;
179- }
167+ while (!_cleanUp .load ()) {
168+ StartInteropScheduler ();
169+ CmiNodeAllBarrier ();
170+ }
171+
172+ if (CmiMyRank () == CmiMyNodeSize ()) {
173+ while (ckExitComplete .load () == 0 ) { CommunicationServerThread (5 ); }
174+ } else {
175+ CsdScheduler (-1 );
176+ CmiNodeAllBarrier ();
180177 }
181178 }
182179
@@ -373,19 +370,16 @@ static void *call_startfn(void *vindex)
373370 ConverseRunPE (0 );
374371
375372 if (CharmLibInterOperate ) {
376- while (1 ) {
377- if (!_cleanUp .load ()) {
378- StartInteropScheduler ();
379- CmiNodeAllBarrier ();
380- } else {
381- if (CmiMyRank () == CmiMyNodeSize ()) {
382- while (ckExitComplete .load () == 0 ) { CommunicationServerThread (5 ); }
383- } else {
384- CsdScheduler (-1 );
385- CmiNodeAllBarrier ();
386- }
387- break ;
388- }
373+ while (!_cleanUp .load ()) {
374+ StartInteropScheduler ();
375+ CmiNodeAllBarrier ();
376+ }
377+
378+ if (CmiMyRank () == CmiMyNodeSize ()) {
379+ while (ckExitComplete .load () == 0 ) { CommunicationServerThread (5 ); }
380+ } else {
381+ CsdScheduler (-1 );
382+ CmiNodeAllBarrier ();
389383 }
390384 }
391385
You can’t perform that action at this time.
0 commit comments