Searched refs:child_unprocessed (Results 1 – 1 of 1) sorted by relevance
89 …int child_unprocessed[2] = {0,0}; //The number of bytes sent by the child but not yet added to the… in reduce() local126 … int read_size = recv(child_sockets[i], child_read_buf[i] + child_unprocessed[i], (int)count, 0); in reduce()135 int old_unprocessed = child_unprocessed[i]; in reduce()136 child_unprocessed[i] = child_read_pos[i] % (int)sizeof(T); in reduce()137 for(int j = 0;j < child_unprocessed[i];j++) { in reduce()