mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-30 04:00:37 +00:00
Code Issues 1 Projects Releases Wiki Activity

netclientclock: Destroy a cached clock 60 seconds after its last use

Browse source 
There's not much lost by having the clock idle around a bit longer but it will
potentially allow anybody wanting to use the same clock server again to sync
much faster.
This commit is contained in:
Sebastian Dröge 2016-01-04 17:18:07 +02:00
parent 33dcec7b74
commit 29136a0186
1 changed files with 32 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

35
libs/gst/net/gstnetclientclock.c
View file

@ -73,6 +73,8 @@ typedef struct
GstClock *clock; /* GstNetClientInternalClock */
GList *clocks; /* GstNetClientClocks */
GstClockID remove_id;
} ClockCache;
G_LOCK_DEFINE_STATIC (clocks_lock);
@ -1102,6 +1104,24 @@ update_clock_cache (ClockCache * cache)
GST_OBJECT_UNLOCK (cache->clock);
}
static gboolean
remove_clock_cache (GstClock * clock, GstClockTime time, GstClockID id,
gpointer user_data)
{
ClockCache *cache = user_data;
G_LOCK (clocks_lock);
if (!cache->clocks) {
gst_clock_id_unref (cache->remove_id);
gst_object_unref (cache->clock);
g_free (cache);
clocks = g_list_remove (clocks, cache);
}
G_UNLOCK (clocks_lock);
return TRUE;
}
static void
gst_net_client_clock_finalize (GObject * object)
{
@ -1122,9 +1142,13 @@ gst_net_client_clock_finalize (GObject * object)
if (cache->clocks) {
update_clock_cache (cache);
} else {
gst_object_unref (cache->clock);
g_free (cache);
clocks = g_list_remove (clocks, cache);
GstClock *sysclock = gst_system_clock_obtain ();
GstClockTime time = gst_clock_get_time (sysclock) + 60 * GST_SECOND;
cache->remove_id = gst_clock_new_single_shot_id (sysclock, time);
gst_clock_id_wait_async (cache->remove_id, remove_clock_cache, cache,
NULL);
gst_object_unref (sysclock);
}
break;
}
@ -1275,6 +1299,11 @@ gst_net_client_clock_constructed (GObject * object)
if (strcmp (internal_clock->address, self->priv->address) == 0 &&
internal_clock->port == self->priv->port) {
cache = tmp;
if (cache->remove_id) {
gst_clock_id_unschedule (cache->remove_id);
cache->remove_id = NULL;
}
break;
}
}