2 * Copyright (C) 2008 Wim Taymans <wim.taymans at gmail.com>
4 * This library is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU Library General Public
6 * License as published by the Free Software Foundation; either
7 * version 2 of the License, or (at your option) any later version.
9 * This library is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 * Library General Public License for more details.
14 * You should have received a copy of the GNU Library General Public
15 * License along with this library; if not, write to the
16 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
17 * Boston, MA 02111-1307, USA.
20 #include "rtsp-session-pool.h"
24 #define DEFAULT_MAX_SESSIONS 0
33 static void gst_rtsp_session_pool_get_property (GObject *object, guint propid,
34 GValue *value, GParamSpec *pspec);
35 static void gst_rtsp_session_pool_set_property (GObject *object, guint propid,
36 const GValue *value, GParamSpec *pspec);
37 static void gst_rtsp_session_pool_finalize (GObject * object);
39 static gchar * create_session_id (GstRTSPSessionPool *pool);
41 G_DEFINE_TYPE (GstRTSPSessionPool, gst_rtsp_session_pool, G_TYPE_OBJECT);
44 gst_rtsp_session_pool_class_init (GstRTSPSessionPoolClass * klass)
46 GObjectClass *gobject_class;
48 gobject_class = G_OBJECT_CLASS (klass);
50 gobject_class->get_property = gst_rtsp_session_pool_get_property;
51 gobject_class->set_property = gst_rtsp_session_pool_set_property;
52 gobject_class->finalize = gst_rtsp_session_pool_finalize;
54 g_object_class_install_property (gobject_class, PROP_MAX_SESSIONS,
55 g_param_spec_uint ("max-sessions", "Max Sessions",
56 "the maximum amount of sessions (0 = unlimited)",
57 0, G_MAXUINT, DEFAULT_MAX_SESSIONS,
58 G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
60 klass->create_session_id = create_session_id;
64 gst_rtsp_session_pool_init (GstRTSPSessionPool * pool)
66 pool->lock = g_mutex_new ();
67 pool->sessions = g_hash_table_new_full (g_str_hash, g_str_equal,
68 NULL, g_object_unref);
69 pool->max_sessions = DEFAULT_MAX_SESSIONS;
73 gst_rtsp_session_pool_finalize (GObject * object)
75 GstRTSPSessionPool * pool = GST_RTSP_SESSION_POOL (object);
77 g_mutex_free (pool->lock);
78 g_hash_table_unref (pool->sessions);
80 G_OBJECT_CLASS (gst_rtsp_session_pool_parent_class)->finalize (object);
84 gst_rtsp_session_pool_get_property (GObject *object, guint propid,
85 GValue *value, GParamSpec *pspec)
87 GstRTSPSessionPool *pool = GST_RTSP_SESSION_POOL (object);
90 case PROP_MAX_SESSIONS:
91 g_value_set_uint (value, gst_rtsp_session_pool_get_max_sessions (pool));
94 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, propid, pspec);
100 gst_rtsp_session_pool_set_property (GObject *object, guint propid,
101 const GValue *value, GParamSpec *pspec)
103 GstRTSPSessionPool *pool = GST_RTSP_SESSION_POOL (object);
106 case PROP_MAX_SESSIONS:
107 gst_rtsp_session_pool_set_max_sessions (pool, g_value_get_uint (value));
110 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, propid, pspec);
116 * gst_rtsp_session_pool_new:
118 * Create a new #GstRTSPSessionPool instance.
120 * Returns: A new #GstRTSPSessionPool. g_object_unref() after usage.
123 gst_rtsp_session_pool_new (void)
125 GstRTSPSessionPool *result;
127 result = g_object_new (GST_TYPE_RTSP_SESSION_POOL, NULL);
133 * gst_rtsp_session_pool_set_max_sessions:
134 * @pool: a #GstRTSPSessionPool
135 * @max: the maximum number of sessions
137 * Configure the maximum allowed number of sessions in @pool to @max.
138 * A value of 0 means an unlimited amount of sessions.
141 gst_rtsp_session_pool_set_max_sessions (GstRTSPSessionPool *pool, guint max)
143 g_return_if_fail (GST_IS_RTSP_SESSION_POOL (pool));
145 g_mutex_lock (pool->lock);
146 pool->max_sessions = max;
147 g_mutex_unlock (pool->lock);
151 * gst_rtsp_session_pool_get_max_sessions:
152 * @pool: a #GstRTSPSessionPool
154 * Get the maximum allowed number of sessions in @pool. 0 means an unlimited
155 * amount of sessions.
157 * Returns: the maximum allowed number of sessions.
160 gst_rtsp_session_pool_get_max_sessions (GstRTSPSessionPool *pool)
164 g_return_val_if_fail (GST_IS_RTSP_SESSION_POOL (pool), 0);
166 g_mutex_lock (pool->lock);
167 result = pool->max_sessions;
168 g_mutex_unlock (pool->lock);
174 * gst_rtsp_session_pool_get_n_sessions:
175 * @pool: a #GstRTSPSessionPool
177 * Get the amount of active sessions in @pool.
179 * Returns: the amount of active sessions in @pool.
182 gst_rtsp_session_pool_get_n_sessions (GstRTSPSessionPool *pool)
186 g_return_val_if_fail (GST_IS_RTSP_SESSION_POOL (pool), 0);
188 g_mutex_lock (pool->lock);
189 result = g_hash_table_size (pool->sessions);
190 g_mutex_unlock (pool->lock);
196 * gst_rtsp_session_pool_find:
197 * @pool: the pool to search
198 * @sessionid: the session id
200 * Find the session with @sessionid in @pool. The access time of the session
201 * will be updated with gst_rtsp_session_touch().
203 * Returns: the #GstRTSPSession with @sessionid or %NULL when the session did
204 * not exist. g_object_unref() after usage.
207 gst_rtsp_session_pool_find (GstRTSPSessionPool *pool, const gchar *sessionid)
209 GstRTSPSession *result;
211 g_return_val_if_fail (GST_IS_RTSP_SESSION_POOL (pool), NULL);
212 g_return_val_if_fail (sessionid != NULL, NULL);
214 g_mutex_lock (pool->lock);
215 result = g_hash_table_lookup (pool->sessions, sessionid);
217 g_object_ref (result);
218 g_mutex_unlock (pool->lock);
221 gst_rtsp_session_touch (result);
227 create_session_id (GstRTSPSessionPool *pool)
232 for (i = 0; i < 16; i++) {
233 id[i] = g_random_int_range ('a', 'z');
236 return g_strndup (id, 16);
240 * gst_rtsp_session_pool_create:
241 * @pool: a #GstRTSPSessionPool
243 * Create a new #GstRTSPSession object in @pool.
245 * Returns: a new #GstRTSPSession.
248 gst_rtsp_session_pool_create (GstRTSPSessionPool *pool)
250 GstRTSPSession *result = NULL;
251 GstRTSPSessionPoolClass *klass;
255 g_return_val_if_fail (GST_IS_RTSP_SESSION_POOL (pool), NULL);
257 klass = GST_RTSP_SESSION_POOL_GET_CLASS (pool);
261 /* start by creating a new random session id, we assume that this is random
262 * enough to not cause a collision, which we will check later */
263 if (klass->create_session_id)
264 id = klass->create_session_id (pool);
271 g_mutex_lock (pool->lock);
272 /* check session limit */
273 if (pool->max_sessions > 0) {
274 if (g_hash_table_size (pool->sessions) >= pool->max_sessions)
275 goto too_many_sessions;
277 /* check if the sessionid existed */
278 result = g_hash_table_lookup (pool->sessions, id);
280 /* found, retry with a different session id */
287 /* not found, create session and insert it in the pool */
288 result = gst_rtsp_session_new (id);
289 /* take additional ref for the pool */
290 g_object_ref (result);
291 g_hash_table_insert (pool->sessions, result->sessionid, result);
293 g_mutex_unlock (pool->lock);
296 } while (result == NULL);
303 g_warning ("no create_session_id vmethod in GstRTSPSessionPool %p", pool);
308 g_warning ("can't create session id with GstRTSPSessionPool %p", pool);
313 g_warning ("can't find unique sessionid for GstRTSPSessionPool %p", pool);
314 g_mutex_unlock (pool->lock);
320 g_warning ("session pool reached max sessions of %d", pool->max_sessions);
321 g_mutex_unlock (pool->lock);
328 * gst_rtsp_session_pool_remove:
329 * @pool: a #GstRTSPSessionPool
330 * @sess: a #GstRTSPSession
332 * Remove @sess from @pool, releasing the ref that the pool has on @sess.
334 * Returns: %TRUE if the session was found and removed.
337 gst_rtsp_session_pool_remove (GstRTSPSessionPool *pool, GstRTSPSession *sess)
341 g_return_val_if_fail (GST_IS_RTSP_SESSION_POOL (pool), FALSE);
342 g_return_val_if_fail (GST_IS_RTSP_SESSION (sess), FALSE);
344 g_mutex_lock (pool->lock);
345 found = g_hash_table_remove (pool->sessions, sess->sessionid);
346 g_mutex_unlock (pool->lock);
352 cleanup_func (gchar *sessionid, GstRTSPSession *sess, GstRTSPSessionPool *pool)
354 return gst_rtsp_session_is_expired (sess);
358 * gst_rtsp_session_pool_cleanup:
359 * @pool: a #GstRTSPSessionPool
361 * Inspect all the sessions in @pool and remove the sessions that are inactive
362 * for more than their timeout.
364 * Returns: the amount of sessions that got removed.
367 gst_rtsp_session_pool_cleanup (GstRTSPSessionPool *pool)
371 g_return_val_if_fail (GST_IS_RTSP_SESSION_POOL (pool), 0);
373 g_mutex_lock (pool->lock);
374 result = g_hash_table_foreach_remove (pool->sessions, (GHRFunc) cleanup_func, pool);
375 g_mutex_unlock (pool->lock);