BurstFS_Server/burstfs_request_manager.c
int rm_send_remote_requests(thrd_ctrl_t *thrd_ctrl,\
		int thrd_tag, long *tot_sz) {

	int i = 0;
	/* ToDo: Transfer the message in multiple
	 * rounds when total size > the size of
	 * send_msg_buf
	 * */

	*tot_sz = 0;

	int msg_cursor = 0;
    while(i < thrd_ctrl->del_req_stat->del_cnt) {
    	int packed_size = rm_pack_send_requests(thrd_ctrl->del_req_msg_buf,\
    			&(thrd_ctrl->del_req_set->msg_meta[msg_cursor]), \
				thrd_ctrl->del_req_stat->req_stat[i].req_cnt,\
						tot_sz);
		MPI_Send(thrd_ctrl->del_req_msg_buf, packed_size, MPI_CHAR,\
				thrd_ctrl->del_req_stat->req_stat[i].del_id,\
					CLI_DATA_TAG, MPI_COMM_WORLD);
		msg_cursor +=\
				thrd_ctrl->del_req_stat->req_stat[i].req_cnt;
		i++;

    }

    return ULFS_SUCCESS;
}
/**
* send the read requests to the
* remote delegators
* @return success/error code
*/
send the read requests to the
remote delegators
send the read requests to the remote delegators
int rm_send_remote_requests(thrd_ctrl_t *thrd_ctrl,\
		int thrd_tag, long *tot_sz) {
	int i = 0;
	*tot_sz = 0;
	int msg_cursor = 0;
    while(i < thrd_ctrl->del_req_stat->del_cnt) {
    	int packed_size = rm_pack_send_requests(thrd_ctrl->del_req_msg_buf,\
    			&(thrd_ctrl->del_req_set->msg_meta[msg_cursor]), \
				thrd_ctrl->del_req_stat->req_stat[i].req_cnt,\
						tot_sz);
		MPI_Send(thrd_ctrl->del_req_msg_buf, packed_size, MPI_CHAR,\
				thrd_ctrl->del_req_stat->req_stat[i].del_id,\
					CLI_DATA_TAG, MPI_COMM_WORLD);
		msg_cursor +=\
				thrd_ctrl->del_req_stat->req_stat[i].req_cnt;
		i++;
    }
    return ULFS_SUCCESS;
}
int rm_send_remote_requests ( thrd_ctrl_t * thrd_ctrl , int thrd_tag , long * tot_sz ) { int i = 0 ; * tot_sz = 0 ; int msg_cursor = 0 ; while ( i < thrd_ctrl -> del_req_stat -> del_cnt ) { int packed_size = rm_pack_send_requests ( thrd_ctrl -> del_req_msg_buf , & ( thrd_ctrl -> del_req_set -> msg_meta [ msg_cursor ] ) , thrd_ctrl -> del_req_stat -> req_stat [ i ] . req_cnt , tot_sz ) ; MPI_Send ( thrd_ctrl -> del_req_msg_buf , packed_size , MPI_CHAR , thrd_ctrl -> del_req_stat -> req_stat [ i ] . del_id , CLI_DATA_TAG , MPI_COMM_WORLD ) ; msg_cursor += thrd_ctrl -> del_req_stat -> req_stat [ i ] . req_cnt ; i ++ ; } return ULFS_SUCCESS ; }
send the read requests to the
remote delegators
send the read requests to the remote delegators
/* ToDo: Transfer the message in multiple
	 * rounds when total size > the size of
	 * send_msg_buf
	 * */