462   run_grp_t *rgrp;  in rgrp_create()  local
465   rgrp = (run_grp_t *)malloc(sizeof(run_grp_t));  in rgrp_create()
466   dassert(1,rgrp);  in rgrp_create()
468   rgrp->task_list = task_mark_running(serv_st, ntasks, nproc);  in rgrp_create()
469   dassert(1,rgrp->task_list);  in rgrp_create()
470   rgrp->ntasks = ntasks;  in rgrp_create()
471   rgrp->nstart = nstart;  in rgrp_create()
472   rgrp->proclist = procs;  in rgrp_create()
473   rgrp->nproc = nproc;  in rgrp_create()
475   rgrp->req = MPI_REQUEST_NULL;  in rgrp_create()
477   ARMCI_INIT_HANDLE(&rgrp->nbh);  in rgrp_create()
478   rgrp->sendbuf = NULL;  in rgrp_create()
481     rgrp->next = serv_st->run_grp;  in rgrp_create()
482     rgrp->prev = serv_st->run_grp->prev;  in rgrp_create()
483     serv_st->run_grp->prev->next = rgrp;  in rgrp_create()
484     serv_st->run_grp->prev = rgrp;  in rgrp_create()
486     serv_st->run_grp = rgrp;  in rgrp_create()
487     rgrp->next = rgrp->prev = rgrp;  in rgrp_create()
489   rgrp->signalptr = NULL;  in rgrp_create()
490   rgrp->state = INIT;  in rgrp_create()
491   return rgrp;  in rgrp_create()
494 static void rgrp_finalize(serv_st_t *serv_st, run_grp_t *rgrp) {  in rgrp_finalize()  argument
496   dassert(1,rgrp);  in rgrp_finalize()
498   task_mark_done(serv_st, rgrp->ntasks, rgrp->nproc);  in rgrp_finalize()
499   serv_st_reclaim_procs(serv_st, rgrp->nproc, rgrp->proclist);  in rgrp_finalize()
500   rgrp->prev->next = rgrp->next;  in rgrp_finalize()
501   rgrp->next->prev = rgrp->prev;  in rgrp_finalize()
502   if(serv_st->run_grp == rgrp) {  in rgrp_finalize()
503     if(rgrp == rgrp->next)  in rgrp_finalize()
508   if(rgrp->sendbuf) {  in rgrp_finalize()
509     ARMCI_Wait(&rgrp->nbh);  in rgrp_finalize()
510     ARMCI_Free_local(rgrp->sendbuf); /*allocated when sending*/  in rgrp_finalize()
512   free(rgrp);  in rgrp_finalize()
621 void signal_rgrp_start(serv_st_t *serv_st, run_grp_t *rgrp);
695   run_grp_t *rgrp;  in server_code()  local
771 	rgrp = rgrp_create(&serv_st, nstart, ntasks, tlist->nproc, procs);  in server_code()
1516 void signal_rgrp_start(serv_st_t *serv_st, run_grp_t *rgrp) {  in signal_rgrp_start()  argument
1524   dassert(1,rgrp);  in signal_rgrp_start()
1525   dassert(1,rgrp->ntasks+2+rgrp->nproc <= 2+NUM_INLINE_TASKS + GA_Nnodes());  in signal_rgrp_start()
1527   bytes= sizeof(msg_head_t)+(2+rgrp->ntasks+rgrp->nproc)*sizeof(int);  in signal_rgrp_start()
1529   rgrp->sendbuf = (char *)buf;  in signal_rgrp_start()
1535   *ibuf++ = rgrp->ntasks;  in signal_rgrp_start()
1536   *ibuf++ = rgrp->nproc;  in signal_rgrp_start()
1537   for(i=0; i<rgrp->ntasks; i++){  in signal_rgrp_start()
1538     *ibuf++ = rgrp->task_list->tasks[rgrp->nstart+i];  in signal_rgrp_start()
1541   ptr = rgrp->proclist;  in signal_rgrp_start()
1544   for(i=0; i<rgrp->nproc; i++) {  in signal_rgrp_start()
1562     rgrp->signalptr = &serv_st->client_signalbuf[ldr_in_dflt_grp];  in signal_rgrp_start()
1563     dassert(1, *rgrp->signalptr == 0);  in signal_rgrp_start()
1571 …(serv_st->client_tgtbufs,serv_st->stamps, rgrp->sendbuf, serv_st->client_tgtbufs[leader], bytes, l…  in signal_rgrp_start()
1573   for(i=0; i<rgrp->nproc; i++) {  in signal_rgrp_start()
1575     int proc = buf[i+2+rgrp->ntasks];  in signal_rgrp_start()
1576 …armci_send(serv_st->client_tgtbufs,serv_st->stamps, rgrp->sendbuf, serv_st->client_tgtbufs[proc], …  in signal_rgrp_start()
1580   rgrp->state = SENT;  in signal_rgrp_start()
1589   run_grp_t *rgrp;  in signal_rgrp_start_list()  local
1591   rgrp = serv_st->run_grp->state==SENT ?   in signal_rgrp_start_list()
1594   dassert(1,rgrp);  in signal_rgrp_start_list()
1595   dassert(1,rgrp->state == INIT);  in signal_rgrp_start_list()
1598   dassert(1,rgrp);  in signal_rgrp_start_list()
1599   for(i=0; i<nrungrps; i++,rgrp=rgrp->prev) {  in signal_rgrp_start_list()
1600     dassert(1,rgrp);  in signal_rgrp_start_list()
1601     dassert(1,rgrp->state == INIT);  in signal_rgrp_start_list()
1603     signal_rgrp_start(serv_st, rgrp);  in signal_rgrp_start_list()
1611   rgrp = serv_st->run_grp->state==SENT ?   in signal_rgrp_start_list()
1618     run_grp_t *ptr = rgrp, *ptr1;  in signal_rgrp_start_list()
1635     rgrp->sendbuf = buf;  in signal_rgrp_start_list()
1641     for(i=0, ptr1=rgrp; i<cnt; i++, ptr1=ptr1->prev) {  in signal_rgrp_start_list()
1673 …nt_tgtbufs, serv_st->stamps, rgrp->sendbuf, serv_st->client_tgtbufs[proc_dest], bytes-sizeof(msg_s…  in signal_rgrp_start_list()
1676     rgrp = ptr;  in signal_rgrp_start_list()
1680   rgrp = serv_st->run_grp->state==SENT ?   in signal_rgrp_start_list()
1687     run_grp_t *ptr = rgrp, *ptr1;  in signal_rgrp_start_list()
1703     rgrp->sendbuf = buf;  in signal_rgrp_start_list()
1705     for(i=0, ptr1=rgrp; i<cnt; i++, ptr1=ptr1->prev) {  in signal_rgrp_start_list()
1748 …nt_tgtbufs, serv_st->stamps, rgrp->sendbuf, serv_st->client_tgtbufs[proc_dest], bytes-sizeof(msg_s…  in signal_rgrp_start_list()
1751     rgrp = ptr;  in signal_rgrp_start_list()
1833       dassert(1,serv_st->status[i].rgrp);  in full_poll_loop()
1835       rgrp_finalize(serv_st, serv_st->status[i].rgrp);  in full_poll_loop()
1836       serv_st->status[i].rgrp = NULL;  in full_poll_loop()
1870       rgrp_finalize(serv_st, serv_st->status[i].rgrp);  in full_waitany_loop()
1871       serv_st->status[i].rgrp = NULL;  in full_waitany_loop()