Searched refs:parent_sent_pos (Results 1 – 1 of 1) sorted by relevance
| /dports/math/vowpal_wabbit/vowpal_wabbit-7.10/vowpalwabbit/ |
| H A D | allreduce.h | 63 …p(char* buffer, size_t left_read_pos, size_t right_read_pos, size_t& parent_sent_pos, socket_t par… in pass_up() argument
64 …e = min(ar_buf_size, min(left_read_pos, right_read_pos) / sizeof(T) * sizeof(T) - parent_sent_pos); in pass_up()
68 int write_size = send(parent_sock, buffer+parent_sent_pos, (int)my_bufsize, 0); in pass_up()
70 …cerr<<"Write to parent failed "<<my_bufsize<<" "<<write_size<<" "<<parent_sent_pos<<" "<<left_read… in pass_up()
73 parent_sent_pos += write_size; in pass_up()
91 size_t parent_sent_pos = 0; //First unsent float to parent in reduce() local
102 while (parent_sent_pos < n || child_read_pos[0] < n || child_read_pos[1] < n) in reduce()
105 pass_up<T>(buffer, child_read_pos[0], child_read_pos[1], parent_sent_pos, parent_sock, n); in reduce()
107 if(parent_sent_pos >= n && child_read_pos[0] >= n && child_read_pos[1] >= n) break; in reduce()
149 parent_sent_pos = n; in reduce()
|