@@ -472,7 +472,7 @@ mi_response_t *mi_rotate(const mi_params_t *params,
472
472
lock_release (global_lock );
473
473
474
474
raise_rotation_event (found_fd , ROTATE_REASON_MI );
475
- ipc_broadcast_rpc (event_flatstore_rotate , 0 );
475
+ ipc_send_rpc_all (event_flatstore_rotate , 0 );
476
476
477
477
return init_mi_result_ok ();
478
478
}
@@ -1038,8 +1038,8 @@ static void event_flatstore_timer(unsigned int ticks, void *param)
1038
1038
file -> path .s , ticks , file -> pathname );
1039
1039
}
1040
1040
/* inform everyone they need to rotate */
1041
- ipc_broadcast_rpc (event_flatstore_rotate , 0 );
1042
1041
lock_release (global_lock );
1042
+ ipc_send_rpc_all (event_flatstore_rotate , 0 );
1043
1043
}
1044
1044
1045
1045
static void verify_delete (void ) {
@@ -1198,6 +1198,6 @@ static void update_counters_and_rotate(struct flat_file *file, ssize_t bytes_inc
1198
1198
if (hit_cnt || hit_sz ) {
1199
1199
raise_rotation_event (file ,
1200
1200
hit_cnt ? ROTATE_REASON_COUNT : ROTATE_REASON_SIZE );
1201
- ipc_broadcast_rpc (event_flatstore_rotate , 0 );
1201
+ ipc_send_rpc_all (event_flatstore_rotate , 0 );
1202
1202
}
1203
1203
}
0 commit comments