diff --git a/src/ngx_stream_upsync_module.c b/src/ngx_stream_upsync_module.c index 59a345a..294a4de 100644 --- a/src/ngx_stream_upsync_module.c +++ b/src/ngx_stream_upsync_module.c @@ -3438,7 +3438,7 @@ ngx_stream_upsync_clear_all_events(ngx_cycle_t *cycle) next != ngx_queue_sentinel(head); next = ngx_queue_next(next)) { - queue_event = ngx_queue_data(next, ngx_delay_event_t, delay_delete_ev); + queue_event = ngx_queue_data(next, ngx_delay_event_t, queue); if (queue_event->delay_delete_ev.timer_set) { ngx_del_timer(&queue_event->delay_delete_ev); }