@@ -472,7 +472,7 @@ mi_response_t *mi_rotate(const mi_params_t *params,
472472 lock_release (global_lock );
473473
474474 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 );
476476
477477 return init_mi_result_ok ();
478478}
@@ -1038,8 +1038,8 @@ static void event_flatstore_timer(unsigned int ticks, void *param)
10381038 file -> path .s , ticks , file -> pathname );
10391039 }
10401040 /* inform everyone they need to rotate */
1041- ipc_broadcast_rpc (event_flatstore_rotate , 0 );
10421041 lock_release (global_lock );
1042+ ipc_send_rpc_all (event_flatstore_rotate , 0 );
10431043}
10441044
10451045static void verify_delete (void ) {
@@ -1198,6 +1198,6 @@ static void update_counters_and_rotate(struct flat_file *file, ssize_t bytes_inc
11981198 if (hit_cnt || hit_sz ) {
11991199 raise_rotation_event (file ,
12001200 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 );
12021202 }
12031203}
0 commit comments