Reset thread transmit packet buffer for event sending This function allocates header bytes for event transmission, and should be called before store the event data to the packet buffer. */
| 362 | should be called before store the event data to the packet buffer. |
| 363 | */ |
| 364 | static int reset_transmit_packet(binlog_send_info *info, ushort flags, |
| 365 | ulong *ev_offset, const char **errmsg) |
| 366 | { |
| 367 | int ret= 0; |
| 368 | String *packet= &info->thd->packet; |
| 369 | |
| 370 | /* reserve and set default header */ |
| 371 | packet->length(0); |
| 372 | packet->set("\0", 1, &my_charset_bin); |
| 373 | |
| 374 | if (info->thd->semi_sync_slave) |
| 375 | { |
| 376 | if (repl_semisync_master.reserve_sync_header(packet)) |
| 377 | { |
| 378 | info->error= ER_UNKNOWN_ERROR; |
| 379 | *errmsg= "Failed to run hook 'reserve_header'"; |
| 380 | ret= 1; |
| 381 | } |
| 382 | } |
| 383 | |
| 384 | *ev_offset= packet->length(); |
| 385 | return ret; |
| 386 | } |
| 387 | |
| 388 | int get_user_var_int(const char *name, |
| 389 | long long int *value, int *null_value) |
no test coverage detected