Lines Matching refs:limiter

151 rate_limiter_free (RateLimiter *limiter)
153 g_object_unref (limiter->file);
154 g_slice_free (RateLimiter, limiter);
438 RateLimiter *limiter;
440 limiter = g_slice_new0 (RateLimiter);
441 limiter->file = g_object_ref (file);
442 g_hash_table_insert (monitor->priv->rate_limiter, file, limiter);
444 return limiter;
449 RateLimiter *limiter)
451 if (limiter->send_virtual_changes_done_at != 0)
453 emit_in_idle (monitor, limiter->file, NULL,
455 limiter->send_virtual_changes_done_at = 0;
461 RateLimiter *limiter,
464 if (limiter->send_delayed_change_at != 0)
467 limiter->file, NULL,
469 limiter->send_delayed_change_at = 0;
470 limiter->last_sent_change_time = time_now;
482 RateLimiter *limiter,
491 if (limiter->last_sent_change_time != 0)
494 expire_at = limiter->last_sent_change_time + 2 * monitor->priv->rate_limit_msec;
504 if (limiter->send_delayed_change_at != 0)
508 time_difference (time_now, limiter->send_delayed_change_at));
511 if (limiter->send_virtual_changes_done_at != 0)
515 time_difference (time_now, limiter->send_virtual_changes_done_at));
526 RateLimiter *limiter = value;
529 if (limiter->send_delayed_change_at != 0 &&
530 time_difference (data->time_now, limiter->send_delayed_change_at) == 0)
531 rate_limiter_send_delayed_change_now (data->monitor, limiter, data->time_now);
533 if (limiter->send_virtual_changes_done_at != 0 &&
534 time_difference (data->time_now, limiter->send_virtual_changes_done_at) == 0)
535 rate_limiter_send_virtual_changes_done_now (data->monitor, limiter);
537 return calc_min_time (data->monitor, limiter, data->time_now, &data->min_time);
582 RateLimiter *limiter = value;
585 return calc_min_time (data->monitor, limiter, data->time_now, &data->min_time);
648 RateLimiter *limiter;
653 limiter = g_hash_table_lookup (monitor->priv->rate_limiter, child);
657 if (limiter)
659 rate_limiter_send_delayed_change_now (monitor, limiter, get_time_msecs ());
661 limiter->send_virtual_changes_done_at = 0;
663 rate_limiter_send_virtual_changes_done_now (monitor, limiter);
674 if (limiter)
676 since_last = time_difference (limiter->last_sent_change_time, time_now);
682 if (limiter->send_delayed_change_at == 0)
684 limiter->send_delayed_change_at = time_now + monitor->priv->rate_limit_msec;
685 update_rate_limiter_timeout (monitor, limiter->send_delayed_change_at);
690 if (limiter == NULL)
691 limiter = new_limiter (monitor, child);
697 limiter->last_sent_change_time = time_now;
698 limiter->send_delayed_change_at = 0;
706 limiter->send_virtual_changes_done_at = time_now + DEFAULT_VIRTUAL_CHANGES_DONE_DELAY_SECS * 1000;
707 update_rate_limiter_timeout (monitor, limiter->send_virtual_changes_done_at);