?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
chromecast: remove useless variable
[vlc.git] / modules / services_discovery / podcast.c
blobd5b390823321dd01375e8331331ee7a5eb25386b
1 /*****************************************************************************
2 * podcast.c: Podcast services discovery module
3 *****************************************************************************
4 * Copyright (C) 2005-2009 the VideoLAN team
5 * $Id$
6 *
7 * Authors: Antoine Cellerier <dionoea -at- videolan -dot- org>
8 *
9 * This program is free software; you can redistribute it and/or modify
10 * it under the terms of the GNU General Public License as published by
11 * the Free Software Foundation; either version 2 of the License, or
12 * (at your option) any later version.
13 *
14 * This program is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 * GNU General Public License for more details.
18 *
19 * You should have received a copy of the GNU General Public License
20 * along with this program; if not, write to the Free Software
21 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
22 *****************************************************************************/
23
24 /*****************************************************************************
25 * Includes
26 *****************************************************************************/
27
28 #ifdef HAVE_CONFIG_H
29 # include "config.h"
30 #endif
31
32 #define VLC_MODULE_LICENSE VLC_LICENSE_GPL_2_PLUS
33 #include <vlc_common.h>
34 #include <vlc_plugin.h>
35 #include <vlc_services_discovery.h>
36 #include <vlc_network.h>
37
38 #include <assert.h>
39 #include <stdnoreturn.h>
40 #include <unistd.h>
41
42 /************************************************************************
43 * Macros and definitions
44 ************************************************************************/
45
46 /*****************************************************************************
47 * Module descriptor
48 *****************************************************************************/
49
50 /* Callbacks */
51 static int Open ( vlc_object_t * );
52 static void Close( vlc_object_t * );
53
54 VLC_SD_PROBE_HELPER("podcast", N_("Podcasts"), SD_CAT_INTERNET)
55
56 #define URLS_TEXT N_("Podcast URLs list")
57 #define URLS_LONGTEXT N_("Enter the list of podcasts to retrieve, " \
58 "separated by '|' (pipe)." )
59
60 vlc_module_begin ()
61 set_shortname( "Podcast")
62 set_description( N_("Podcasts") )
63 set_category( CAT_PLAYLIST )
64 set_subcategory( SUBCAT_PLAYLIST_SD )
65
66 add_string( "podcast-urls", NULL,
67 URLS_TEXT, URLS_LONGTEXT, false )
68
69 set_capability( "services_discovery", 0 )
70 set_callbacks( Open, Close )
71
72 VLC_SD_PROBE_SUBMODULE
73
74 vlc_module_end ()
75
76
77 /*****************************************************************************
78 * Local structures
79 *****************************************************************************/
80
81 enum {
82 UPDATE_URLS,
83 UPDATE_REQUEST
84 }; /* FIXME Temporary. Updating by compound urls string to be removed later. */
85
86 struct services_discovery_sys_t
87 {
88 /* playlist node */
89 input_thread_t **pp_input;
90 int i_input;
91
92 char **ppsz_urls;
93 int i_urls;
94
95 input_item_t **pp_items;
96 int i_items;
97
98 vlc_thread_t thread;
99 vlc_mutex_t lock;
100 vlc_cond_t wait;
101 bool b_update;
102 bool b_savedurls_loaded;
103 char *psz_request;
104 int update_type;
105 };
106
107 /*****************************************************************************
108 * Local prototypes
109 *****************************************************************************/
110 static void *Run( void * );
111 static int UrlsChange( vlc_object_t *, char const *, vlc_value_t,
112 vlc_value_t, void * );
113 static int Request( vlc_object_t *, char const *, vlc_value_t,
114 vlc_value_t, void * );
115 static void ParseRequest( services_discovery_t *p_sd );
116 static void ParseUrls( services_discovery_t *p_sd, char *psz_urls );
117 static void SaveUrls( services_discovery_t *p_sd );
118
119 /*****************************************************************************
120 * Open: initialize and create stuff
121 *****************************************************************************/
122 static int Open( vlc_object_t *p_this )
123 {
124 if( strcmp( p_this->obj.parent->obj.object_type, "playlist" ) )
125 return VLC_EGENERIC; /* FIXME: support LibVLC SD too! */
126
127 services_discovery_t *p_sd = ( services_discovery_t* )p_this;
128 services_discovery_sys_t *p_sys = malloc( sizeof( *p_sys ) );
129 if( !p_sys )
130 return VLC_ENOMEM;
131
132 p_sys->i_urls = 0;
133 p_sys->ppsz_urls = NULL;
134 p_sys->i_input = 0;
135 p_sys->pp_input = NULL;
136 p_sys->pp_items = NULL;
137 p_sys->i_items = 0;
138 vlc_mutex_init( &p_sys->lock );
139 vlc_cond_init( &p_sys->wait );
140 p_sys->b_update = true;
141 p_sys->b_savedurls_loaded = false;
142 p_sys->psz_request = NULL;
143 p_sys->update_type = UPDATE_URLS;
144
145 p_sd->p_sys = p_sys;
146 p_sd->description = _("Podcasts");
147
148 /* Launch the callback associated with this variable */
149 vlc_object_t *pl = p_sd->obj.parent;
150 var_Create( pl, "podcast-urls", VLC_VAR_STRING | VLC_VAR_DOINHERIT );
151 var_AddCallback( pl, "podcast-urls", UrlsChange, p_sys );
152
153 var_Create( pl, "podcast-request", VLC_VAR_STRING );
154 var_AddCallback( pl, "podcast-request", Request, p_sys );
155
156 if (vlc_clone (&p_sys->thread, Run, p_sd, VLC_THREAD_PRIORITY_LOW))
157 {
158 var_DelCallback( pl, "podcast-request", Request, p_sys );
159 var_DelCallback( pl, "podcast-urls", UrlsChange, p_sys );
160 vlc_cond_destroy( &p_sys->wait );
161 vlc_mutex_destroy( &p_sys->lock );
162 free (p_sys);
163 return VLC_EGENERIC;
164 }
165 return VLC_SUCCESS;
166 }
167
168 /*****************************************************************************
169 * Close:
170 *****************************************************************************/
171 static void Close( vlc_object_t *p_this )
172 {
173 services_discovery_t *p_sd = ( services_discovery_t* )p_this;
174 services_discovery_sys_t *p_sys = p_sd->p_sys;
175 vlc_object_t *pl = p_sd->obj.parent;
176
177 vlc_cancel (p_sys->thread);
178 vlc_join (p_sys->thread, NULL);
179
180 var_DelCallback( pl, "podcast-urls", UrlsChange, p_sys );
181 var_DelCallback( pl, "podcast-request", Request, p_sys );
182 vlc_cond_destroy( &p_sys->wait );
183 vlc_mutex_destroy( &p_sys->lock );
184
185 for( int i = 0; i < p_sys->i_input; i++ )
186 {
187 input_thread_t *p_input = p_sd->p_sys->pp_input[i];
188 if( !p_input )
189 continue;
190
191 input_Stop( p_input );
192 input_Close( p_input );
193
194 p_sd->p_sys->pp_input[i] = NULL;
195 }
196 free( p_sd->p_sys->pp_input );
197
198 for( int i = 0; i < p_sys->i_urls; i++ )
199 free( p_sys->ppsz_urls[i] );
200 free( p_sys->ppsz_urls );
201
202 for( int i = 0; i < p_sys->i_items; i++ )
203 input_item_Release( p_sys->pp_items[i] );
204 free( p_sys->pp_items );
205
206 free( p_sys->psz_request );
207 free( p_sys );
208 }
209
210 /*****************************************************************************
211 * Run: main thread
212 *****************************************************************************/
213 noreturn static void *Run( void *data )
214 {
215 services_discovery_t *p_sd = data;
216 services_discovery_sys_t *p_sys = p_sd->p_sys;
217
218 vlc_mutex_lock( &p_sys->lock );
219 mutex_cleanup_push( &p_sys->lock );
220 for( ;; )
221 {
222 while( !p_sys->b_update )
223 vlc_cond_wait( &p_sys->wait, &p_sys->lock );
224
225 int canc = vlc_savecancel ();
226 msg_Dbg( p_sd, "Update required" );
227
228 if( p_sys->update_type == UPDATE_URLS )
229 {
230 char *psz_urls = var_GetNonEmptyString( p_sd->obj.parent,
231 "podcast-urls" );
232 ParseUrls( p_sd, psz_urls );
233 free( psz_urls );
234 }
235 else if( p_sys->update_type == UPDATE_REQUEST )
236 ParseRequest( p_sd );
237
238 p_sys->b_update = false;
239
240 for( int i = 0; i < p_sd->p_sys->i_input; i++ )
241 {
242 input_thread_t *p_input = p_sd->p_sys->pp_input[i];
243 int state = var_GetInteger( p_input, "state" );
244
245 if( state == END_S || state == ERROR_S )
246 {
247 input_Stop( p_input );
248 input_Close( p_input );
249
250 p_sd->p_sys->pp_input[i] = NULL;
251 TAB_ERASE(p_sys->i_input, p_sys->pp_input, i);
252 i--;
253 }
254 }
255 vlc_restorecancel (canc);
256 }
257 vlc_cleanup_pop();
258 vlc_assert_unreachable(); /* dead code */
259 }
260
261 static int UrlsChange( vlc_object_t *p_this, char const *psz_var,
262 vlc_value_t oldval, vlc_value_t newval,
263 void *p_data )
264 {
265 VLC_UNUSED(p_this); VLC_UNUSED(psz_var); VLC_UNUSED(oldval);
266 VLC_UNUSED(newval);
267 services_discovery_sys_t *p_sys = (services_discovery_sys_t *)p_data;
268
269 vlc_mutex_lock( &p_sys->lock );
270 p_sys->b_update = true;
271 p_sys->update_type = UPDATE_URLS;
272 vlc_cond_signal( &p_sys->wait );
273 vlc_mutex_unlock( &p_sys->lock );
274 return VLC_SUCCESS;
275 }
276
277 static int Request( vlc_object_t *p_this, char const *psz_var,
278 vlc_value_t oldval, vlc_value_t newval,
279 void *p_data )
280 {
281 VLC_UNUSED(p_this); VLC_UNUSED(psz_var); VLC_UNUSED(oldval);
282 services_discovery_sys_t *p_sys = (services_discovery_sys_t *)p_data;
283
284 vlc_mutex_lock( &p_sys->lock );
285 free( p_sys->psz_request );
286 p_sys->psz_request = NULL;
287 if( newval.psz_string && *newval.psz_string ) {
288 p_sys->psz_request = strdup( newval.psz_string );
289 p_sys->b_update = true;
290 p_sys->update_type = UPDATE_REQUEST;
291 vlc_cond_signal( &p_sys->wait );
292 }
293 vlc_mutex_unlock( &p_sys->lock );
294 return VLC_SUCCESS;
295 }
296
297 static void ParseUrls( services_discovery_t *p_sd, char *psz_urls )
298 {
299 services_discovery_sys_t *p_sys = p_sd->p_sys;
300 int i_new_items = 0;
301 input_item_t **pp_new_items = NULL;
302
303 int i_new_urls = 0;
304 char **ppsz_new_urls = NULL;
305 p_sys->b_savedurls_loaded = true;
306
307 int i, j;
308
309 for( ;; )
310 {
311 if( !psz_urls )
312 break;
313
314 char *psz_tok = strchr( psz_urls, '|' );
315 if( psz_tok ) *psz_tok = '\0';
316
317 for( i = 0; i < p_sys->i_urls; i++ )
318 if( !strcmp( psz_urls, p_sys->ppsz_urls[i] ) )
319 break;
320 if( i == p_sys->i_urls )
321 {
322 TAB_APPEND( i_new_urls, ppsz_new_urls, strdup( psz_urls ) );
323
324 input_item_t *p_input;
325 p_input = input_item_New( psz_urls, psz_urls );
326 input_item_AddOption( p_input, "demux=podcast", VLC_INPUT_OPTION_TRUSTED );
327
328 TAB_APPEND( i_new_items, pp_new_items, p_input );
329 services_discovery_AddItem( p_sd, p_input );
330
331 TAB_APPEND( p_sys->i_input, p_sys->pp_input,
332 input_CreateAndStart( p_sd, p_input, NULL ) );
333 }
334 else
335 {
336 TAB_APPEND( i_new_urls, ppsz_new_urls,
337 strdup( p_sys->ppsz_urls[i]) );
338 TAB_APPEND( i_new_items, pp_new_items, p_sys->pp_items[i] );
339 }
340 if( psz_tok )
341 psz_urls = psz_tok+1;
342 else
343 break;
344 }
345
346 /* delete removed items and signal the removal */
347 for( i = 0; i<p_sys->i_items; ++i )
348 {
349 for( j = 0; j < i_new_items; ++j )
350 if( pp_new_items[j] == p_sys->pp_items[i] ) break;
351 if( j == i_new_items )
352 {
353 services_discovery_RemoveItem( p_sd, p_sys->pp_items[i] );
354 input_item_Release( p_sys->pp_items[i] );
355 }
356 }
357 free( p_sys->pp_items );
358 for( int i = 0; i < p_sys->i_urls; i++ )
359 free( p_sys->ppsz_urls[i] );
360 free( p_sys->ppsz_urls );
361
362 p_sys->ppsz_urls = ppsz_new_urls;
363 p_sys->i_urls = i_new_urls;
364 p_sys->pp_items = pp_new_items;
365 p_sys->i_items = i_new_items;
366 }
367
368 static void ParseRequest( services_discovery_t *p_sd )
369 {
370 services_discovery_sys_t *p_sys = p_sd->p_sys;
371
372 char *psz_request = p_sys->psz_request;
373
374 int i;
375
376 char *psz_tok = strchr( psz_request, ':' );
377 if( !psz_tok ) return;
378 *psz_tok = '\0';
379
380 if ( ! p_sys->b_savedurls_loaded )
381 {
382 char *psz_urls = var_GetNonEmptyString( p_sd->obj.parent,
383 "podcast-urls" );
384 ParseUrls( p_sd, psz_urls );
385 free( psz_urls );
386 }
387
388 if( !strcmp( psz_request, "ADD" ) )
389 {
390 psz_request = psz_tok + 1;
391 for( i = 0; i<p_sys->i_urls; i++ )
392 if( !strcmp(p_sys->ppsz_urls[i],psz_request) )
393 break;
394 if( i == p_sys->i_urls )
395 {
396 TAB_APPEND( p_sys->i_urls, p_sys->ppsz_urls,
397 strdup( psz_request ) );
398
399 input_item_t *p_input;
400 p_input = input_item_New( psz_request, psz_request );
401 input_item_AddOption( p_input, "demux=podcast", VLC_INPUT_OPTION_TRUSTED );
402
403 TAB_APPEND( p_sys->i_items, p_sys->pp_items, p_input );
404 services_discovery_AddItem( p_sd, p_input );
405
406 TAB_APPEND( p_sys->i_input, p_sys->pp_input,
407 input_CreateAndStart( p_sd, p_input, NULL ) );
408 SaveUrls( p_sd );
409 }
410 }
411 else if ( !strcmp( psz_request, "RM" ) )
412 {
413 psz_request = psz_tok + 1;
414 for( i = 0; i < p_sys->i_urls; i++ )
415 if( !strcmp(p_sys->ppsz_urls[i], psz_request) )
416 {
417 services_discovery_RemoveItem( p_sd, p_sys->pp_items[i] );
418 input_item_Release( p_sys->pp_items[i] );
419 TAB_ERASE(p_sys->i_urls, p_sys->ppsz_urls, i );
420 TAB_ERASE(p_sys->i_items, p_sys->pp_items, i );
421 break;
422 }
423 SaveUrls( p_sd );
424 }
425
426 free( p_sys->psz_request );
427 p_sys->psz_request = NULL;
428 }
429
430 static void SaveUrls( services_discovery_t *p_sd )
431 {
432 services_discovery_sys_t *p_sys = p_sd->p_sys;
433 int i;
434 char *psz_urls;
435 int len = 0;
436
437 for( i=0; i < p_sys->i_urls; i++ )
438 len += strlen( p_sys->ppsz_urls[i] ) + 1;
439
440 psz_urls = (char*) calloc( len, sizeof(char) );
441
442 for( i=0; i < p_sys->i_urls; i++ )
443 {
444 strcat( psz_urls, p_sys->ppsz_urls[i] );
445 if( i < p_sys->i_urls - 1 ) strcat( psz_urls, "|" );
446 }
447
448 config_PutPsz( p_sd, "podcast-urls", psz_urls );
449
450 free( psz_urls );
451 }
VLC Development tree mirror