* tell all cluster nodes to start mcasting */
| 173 | * tell all cluster nodes to start mcasting |
| 174 | */ |
| 175 | static void pload_send_start (uint32_t count, uint32_t size) |
| 176 | { |
| 177 | struct req_exec_pload_start req_exec_pload_start; |
| 178 | struct iovec iov; |
| 179 | |
| 180 | req_exec_pload_start.header.id = SERVICE_ID_MAKE (PLOAD_SERVICE, MESSAGE_REQ_EXEC_PLOAD_START); |
| 181 | req_exec_pload_start.msg_count = count; |
| 182 | req_exec_pload_start.msg_size = size; |
| 183 | iov.iov_base = (void *)&req_exec_pload_start; |
| 184 | iov.iov_len = sizeof (struct req_exec_pload_start); |
| 185 | |
| 186 | api->totem_mcast (&iov, 1, TOTEM_AGREED); |
| 187 | } |
| 188 | |
| 189 | /* |
| 190 | * send N empty data messages of size X |