yp.c 25.8 KB
Newer Older
1
2
3
4
5
6
7
8
9
10
11
12
/* Icecast
 *
 * This program is distributed under the GNU General Public License, version 2.
 * A copy of this license is included with this source.
 *
 * Copyright 2000-2004, Jack Moffitt <jack@xiph.org, 
 *                      Michael Smith <msmith@xiph.org>,
 *                      oddsock <oddsock@xiph.org>,
 *                      Karl Heyes <karl@xiph.org>
 *                      and others (see AUTHORS for details).
 */

13
/* -*- c-basic-offset: 4; indent-tabs-mode: nil; -*- */
14
15
16
17
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif

18
19
#include <stdio.h>
#include <string.h>
20
#include <stdlib.h>
21
#include <curl/curl.h>
22
23
24
25
26
27
28
29
30

#include <thread/thread.h>

#include "connection.h"
#include "refbuf.h"
#include "client.h"
#include "logging.h"
#include "format.h"
#include "source.h"
31
#include "cfgfile.h"
32
#include "stats.h"
33
34
35
36

#ifdef WIN32
#define snprintf _snprintf
#endif
37

Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
38
#define CATMODULE "yp" 
39

40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
struct yp_server
{
    char        *url;
    unsigned    url_timeout;
    unsigned    touch_interval;
    int         remove;

    CURL *curl;
    struct ypdata_tag *mounts, *pending_mounts;
    struct yp_server *next;
    char curl_error[CURL_ERROR_SIZE];
};



typedef struct ypdata_tag
{
    int remove;
58
    int release;
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
    int cmd_ok;

    char *sid;
    char *mount;
    char *url;
    char *listen_url;
    char *server_name;
    char *server_desc;
    char *server_genre;
    char *cluster_password;
    char *bitrate;
    char *audio_info;
    char *server_type;
    char *current_song;

    struct yp_server *server;
    time_t      next_update;
    unsigned    touch_interval;
    char        *error_msg;
    unsigned    (*process)(struct ypdata_tag *yp, char *s, unsigned len);

    struct ypdata_tag *next;
} ypdata_t;


static rwlock_t yp_lock;
static mutex_t yp_pending_lock;

87
volatile static struct yp_server *active_yps = NULL, *pending_yps = NULL;
88
static volatile int yp_update = 0;
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
static int yp_running;
static time_t now;
static thread_type *yp_thread;

static void *yp_update_thread(void *arg);
static void add_yp_info (ypdata_t *yp, char *stat_name, void *info, int type);
static unsigned do_yp_remove (ypdata_t *yp, char *s, unsigned len);
static unsigned do_yp_add (ypdata_t *yp, char *s, unsigned len);
static unsigned do_yp_touch (ypdata_t *yp, char *s, unsigned len);
static void yp_destroy_ypdata(ypdata_t *ypdata);


/* curl callback used to parse headers coming back from the YP server */
static int handle_returned_header (void *ptr, size_t size, size_t nmemb, void *stream)
{
    ypdata_t *yp = stream;
    unsigned bytes = size * nmemb;

    /* DEBUG2 ("header from YP is \"%.*s\"", bytes, ptr); */
    if (strncmp (ptr, "YPResponse: 1", 13) == 0)
        yp->cmd_ok = 1;

    if (strncmp (ptr, "YPMessage: ", 11) == 0)
    {
        unsigned len = bytes - 11;
        free (yp->error_msg);
        yp->error_msg = calloc (1, len);
        if (yp->error_msg)
            sscanf (ptr, "YPMessage: %[^\r\n]", yp->error_msg);
    }

    if (yp->process == do_yp_add)
    {
        if (strncmp (ptr, "SID: ", 5) == 0)
        {
            unsigned len = bytes - 5;
            free (yp->sid);
            yp->sid = calloc (1, len);
            if (yp->sid)
                sscanf (ptr, "SID: %[^\r\n]", yp->sid);
        }
        if (strncmp (ptr, "TouchFreq: ", 11) == 0)
        {
            unsigned secs;
            sscanf (ptr, "TouchFreq: %u", &secs);
            if (secs < 30)
                secs = 30;
            DEBUG1 ("server touch interval is %u", secs);
            yp->touch_interval = secs;
        }
    }
    return (int)bytes;
}


/* capture returned data, but don't do anything with it, shouldn't be any */
static int handle_returned_data (void *ptr, size_t size, size_t nmemb, void *stream)
{
    return (int)(size*nmemb);
}


/* search the active and pending YP server lists */
static struct yp_server *find_yp_server (const char *url)
{
    struct yp_server *server;

156
    server = (struct yp_server *)active_yps;
157
158
159
160
161
162
    while (server)
    {
        if (strcmp (server->url, url) == 0)
            return server;
        server = server->next;
    }
163
    server = (struct yp_server *)pending_yps;
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
    while (server)
    {
        if (strcmp (server->url, url) == 0)
            break;
        server = server->next;
    }
    return server;
}


static void destroy_yp_server (struct yp_server *server)
{
    if (server == NULL)
        return;
    DEBUG1 ("Removing YP server entry for %s", server->url);
    if (server->curl)
        curl_easy_cleanup (server->curl);
    if (server->mounts) WARN0 ("active ypdata not freed up");
    if (server->pending_mounts) WARN0 ("pending ypdata not freed up");
    free (server->url);
    free (server);
}



/* search for a ypdata entry corresponding to a specific mountpoint */
190
static ypdata_t *find_yp_mount (ypdata_t *mounts, const char *mount)
191
{
192
    ypdata_t *yp = mounts;
193
194
195
196
197
198
199
200
201
    while (yp)
    {
        if (strcmp (yp->mount, mount) == 0)
            break;
        yp = yp->next;
    }
    return yp;
}

202
203
204

void yp_recheck_config (ice_config_t *config)
{
205
206
207
208
209
210
    int i;
    struct yp_server *server;

    DEBUG0("Updating YP configuration");
    thread_rwlock_rlock (&yp_lock);

211
    server = (struct yp_server *)active_yps;
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
    while (server)
    {
        server->remove = 1;
        server = server->next;
    }
    /* for each yp url in config, check to see if one exists 
       if not, then add it. */
    for (i=0 ; i < config->num_yp_directories; i++)
    {
        server = find_yp_server (config->yp_url[i]);
        if (server == NULL)
        {
            server = calloc (1, sizeof (struct yp_server));

            if (server == NULL)
            {
                destroy_yp_server (server);
                break;
            }
            server->url = strdup (config->yp_url[i]);
            server->url_timeout = config->yp_url_timeout[i];
233
            server->touch_interval = config->yp_touch_interval[i];
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
            server->curl = curl_easy_init();
            if (server->curl == NULL)
            {
                destroy_yp_server (server);
                break;
            }
            if (server->touch_interval < 30)
                server->touch_interval = 30;
            curl_easy_setopt (server->curl, CURLOPT_URL, server->url);
            curl_easy_setopt (server->curl, CURLOPT_HEADERFUNCTION, handle_returned_header);
            curl_easy_setopt (server->curl, CURLOPT_WRITEFUNCTION, handle_returned_data);
            curl_easy_setopt (server->curl, CURLOPT_WRITEDATA, server->curl);
            curl_easy_setopt (server->curl, CURLOPT_TIMEOUT, server->url_timeout);
            curl_easy_setopt (server->curl, CURLOPT_NOSIGNAL, 1L);
            curl_easy_setopt (server->curl, CURLOPT_ERRORBUFFER, &(server->curl_error[0]));
249
            server->next = (struct yp_server *)pending_yps;
250
251
252
253
254
255
256
257
258
259
260
            pending_yps = server;
            INFO3 ("Adding new YP server \"%s\" (timeout %ds, default interval %ds)",
                    server->url, server->url_timeout, server->touch_interval);
        }
        else
        {
            server->remove = 0;
        }
    }
    thread_rwlock_unlock (&yp_lock);
    yp_update = 1;
261
262
}

263

264
265
void yp_initialize()
{
266
    ice_config_t *config = config_get_config();
267
268
    thread_rwlock_create (&yp_lock);
    thread_mutex_create (&yp_pending_lock);
269
270
    yp_recheck_config (config);
    config_release_config ();
271
272
    yp_thread = thread_create("YP Touch Thread", yp_update_thread,
                            (void *)NULL, THREAD_ATTACHED);
273
}
274
275
276
277
278



/* handler for curl, checks if successful handling occurred */
static int send_to_yp (const char *cmd, ypdata_t *yp, char *post)
279
{
280
281
282
283
284
285
286
287
288
289
290
    int curlcode;
    struct yp_server *server = yp->server;

    /* DEBUG2 ("send YP (%s):%s", cmd, post); */
    yp->cmd_ok = 0;
    curl_easy_setopt (server->curl, CURLOPT_POSTFIELDS, post);
    curl_easy_setopt (server->curl, CURLOPT_WRITEHEADER, yp);
    curlcode = curl_easy_perform (server->curl);
    if (curlcode)
    {
        yp->process = do_yp_add;
291
        yp->next_update += 300;
292
293
        ERROR2 ("connection to %s failed with \"%s\"", server->url, server->curl_error);
        return -1;
294
    }
295
296
    if (yp->cmd_ok == 0)
    {
297
298
        if (yp->error_msg == NULL)
            yp->error_msg = strdup ("no response from server");
299
        yp->process = do_yp_add;
300
        yp->next_update += 300;
301
302
        ERROR3 ("YP %s on %s failed: %s", cmd, server->url, yp->error_msg);
        return -1;
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
303
    }
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
    DEBUG2 ("YP %s at %s succeeded", cmd, server->url);
    return 0;
}


/* routines for building and issues requests to the YP server */
static unsigned do_yp_remove (ypdata_t *yp, char *s, unsigned len)
{
    if (yp->sid)
    {
        int ret = snprintf (s, len, "action=remove&sid=%s", yp->sid);
        if (ret >= (signed)len)
            return ret+1;

        INFO1 ("clearing up YP entry for %s", yp->mount);
        send_to_yp ("remove", yp, s);
        free (yp->sid);
        yp->sid = NULL;
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
322
    }
323
324
325
    yp_update = 1;
    yp->remove = 1;
    yp->process = do_yp_add;
326

327
    return 0;
328
329
}

330
331

static unsigned do_yp_add (ypdata_t *yp, char *s, unsigned len)
332
{
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
    int ret = snprintf (s, len, "action=add&sn=%s&genre=%s&cpswd=%s&desc="
                    "%s&url=%s&listenurl=%s&type=%s&b=%s&%s\r\n",
                    yp->server_name, yp->server_genre, yp->cluster_password,
                    yp->server_desc, yp->url, yp->listen_url,
                    yp->server_type, yp->bitrate, yp->audio_info);
    if (ret >= (signed)len)
        return ret+1;
    if (send_to_yp ("add", yp, s) == 0)
    {
        yp->process = do_yp_touch;
        /* force first touch in 5 secs */
        yp->next_update = time(NULL) + 5;
    }

    return 0;
}


static unsigned do_yp_touch (ypdata_t *yp, char *s, unsigned len)
{
    unsigned listeners = 0;
    char *val, *artist, *title;
    int ret;
356
    char *max_listeners;
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386

    artist = (char *)stats_get_value (yp->mount, "artist");
    title = (char *)stats_get_value (yp->mount, "title");
    if (artist || title)
    {
         char *song;
         char *separator = " - ";
         if (artist == NULL)
         {
             artist = strdup("");
             separator = "";
         }
         if (title == NULL) title = strdup("");
         song = malloc (strlen (artist) + strlen (title) + strlen (separator) +1);
         if (song)
         {
             sprintf (song, "%s%s%s", artist, separator, title);
             add_yp_info(yp, "yp_currently_playing", song, YP_CURRENT_SONG);
             free (song);
         }
    }
    free (artist);
    free (title);

    val = (char *)stats_get_value (yp->mount, "listeners");
    if (val)
    {
        listeners = atoi (val);
        free (val);
    }
387
388
389
390
391
392
393
394
395
396
    max_listeners = stats_get_value (yp->mount, "max_listeners");
    if (max_listeners == NULL || strcmp (max_listeners, "unlimited") == 0)
    {
        free (max_listeners);
        max_listeners = (char *)stats_get_value (NULL, "client_limit");
    }

    ret = snprintf (s, len, "action=touch&sid=%s&st=%s"
            "&listeners=%u&max_listeners=%s\r\n",
            yp->sid, yp->current_song, listeners, max_listeners);
397
398
399
400
401
402

    if (ret >= (signed)len)
        return ret+1; /* space required for above text and nul*/

    send_to_yp ("touch", yp, s);
    return 0;
403
}
404

405
406
407


static void process_ypdata (struct yp_server *server, ypdata_t *yp)
408
{
409
410
    unsigned len = 512;
    char *s = NULL, *tmp;
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
411

412
413
414
    if (now < yp->next_update)
        return;
    yp->next_update = now + yp->touch_interval;
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
415

416
417
418
419
420
421
422
    /* loop just in case the memory area isn't big enough */
    while (1)
    {
        unsigned ret;
        if ((tmp = realloc (s, len)) == NULL)
            return;
        s = tmp;
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
423

424
425
426
427
428
429
        if (yp->release)
        {
            yp->process = do_yp_remove;
            yp->next_update = 0;
        }

430
431
432
433
434
        ret = yp->process (yp, s, len);
        if (ret == 0)
        {
           free (s);
           return;
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
435
        }
436
        len = ret;
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
437
    }
438
}
439
440
441


static void yp_process_server (struct yp_server *server)
442
{
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
    ypdata_t *yp;

    /* DEBUG1("processing yp server %s", server->url); */
    yp = server->mounts;
    while (yp)
    {
        now = time (NULL);
        process_ypdata (server, yp);
        yp = yp->next;
    }
}



static ypdata_t *create_yp_entry (source_t *source)
{
    ypdata_t *yp;
460
    char *s;
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
461

462
463
464
465
466
467
468
469
    if (source->running == 0 || source->yp_public == 0)
        return NULL;
    yp = calloc (1, sizeof (ypdata_t));
    do
    {
        unsigned len = 512;
        int ret;
        char *url;
470
        mount_proxy *mountproxy = NULL;
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
        ice_config_t *config;

        if (yp == NULL)
            break;
        yp->mount = strdup (source->mount);
        yp->server_name = strdup ("");
        yp->server_desc = strdup ("");
        yp->server_genre = strdup ("");
        yp->bitrate = strdup ("");
        yp->server_desc = strdup ("");
        yp->server_type = strdup ("");
        yp->cluster_password = strdup ("");
        yp->url = strdup ("");
        yp->current_song = strdup ("");
        yp->audio_info = strdup ("");
        yp->process = do_yp_add;

        url = malloc (len);
        if (url == NULL)
            break;
        config = config_get_config();
492
        ret = snprintf (url, len, "http://%s:%d%s", config->hostname, config->port, source->mount);
493
        if (ret >= (signed)len)
494
        {
495
496
            s = realloc (url, ++ret);
            if (s) url = s;
497
            snprintf (url, ret, "http://%s:%d%s", config->hostname, config->port, source->mount);
498
        }
499
500
501
502
503
504
505
506
507
508
509
510

        mountproxy = config->mounts;
        while (mountproxy) {
            if (strcmp (mountproxy->mountname, source->mount) == 0) {
                if (mountproxy->cluster_password) {
                   add_yp_info (yp, "cluster_password", 
                       mountproxy->cluster_password, YP_CLUSTER_PASSWORD);
                }
                break;
            }
            mountproxy = mountproxy->next;
        }
511
512
513
514
515
516
517
        config_release_config();
        yp->listen_url = util_url_escape (url);
        free (url);
        if (yp->listen_url == NULL)
            break;

        /* ice-* is icecast, icy-* is shoutcast */
518
        add_yp_info (yp, "server_type", source->format->contenttype, YP_SERVER_TYPE);
519
520
521
522
523
524
525
526
        if ((s = httpp_getvar(source->parser, "ice-name"))) {
            add_yp_info (yp, "server_name", s, YP_SERVER_NAME);
        }
        if ((s = httpp_getvar(source->parser, "icy-name"))) {
            add_yp_info (yp, "server_name", s, YP_SERVER_NAME);
        }
        if ((s = httpp_getvar(source->parser, "ice-url"))) {
            add_yp_info(yp, "server_url", s, YP_SERVER_URL);
527
        }
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
        if ((s = httpp_getvar(source->parser, "icy-url"))) {
            add_yp_info(yp, "server_url", s, YP_SERVER_URL);
        }
        if ((s = httpp_getvar(source->parser, "ice-genre"))) {
            add_yp_info(yp, "genre", s, YP_SERVER_GENRE);
        }
        if ((s = httpp_getvar(source->parser, "icy-genre"))) {
            add_yp_info(yp, "genre", s, YP_SERVER_GENRE);
        }
        if ((s = httpp_getvar(source->parser, "ice-bitrate"))) {
            add_yp_info(yp, "bitrate", s, YP_BITRATE);
        }
        if ((s = httpp_getvar(source->parser, "icy-br"))) {
            add_yp_info(yp, "bitrate", s, YP_BITRATE);
        }
        if ((s = httpp_getvar(source->parser, "ice-description"))) {
            add_yp_info(yp, "server_description", s, YP_SERVER_DESC);
        }
        s = util_dict_urlencode (source->audio_info, '&');
        if (s)
            add_yp_info (yp, "audio_info", s, YP_AUDIO_INFO);
        free(s);
        return yp;
    } while (0);

    yp_destroy_ypdata (yp);
    return NULL;
}


/* Check for changes in the YP servers configured */
static void check_servers ()
{
561
562
    struct yp_server *server = (struct yp_server *)active_yps,
                     **server_p = (struct yp_server **)&active_yps;
563
564
565
566
567
568
569
570
571
572

    while (server)
    {
        if (server->remove)
        {
            struct yp_server *to_go = server;
            DEBUG1 ("YP server \"%s\"removed", server->url);
            *server_p = server->next;
            server = server->next;
            destroy_yp_server (to_go);
573
            continue;
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
574
        }
575
576
577
578
579
580
581
582
        server_p = &server->next;
        server = server->next;
    }
    /* add new server entries */
    while (pending_yps)
    {
        avl_node *node;

583
        server = (struct yp_server *)pending_yps;
584
585
586
        pending_yps = server->next;

        DEBUG1("Add pending yps %s", server->url);
587
        server->next = (struct yp_server *)active_yps;
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
        active_yps = server;

        /* new YP server configured, need to populate with existing sources */
        avl_tree_rlock (global.source_tree);
        node = avl_get_first (global.source_tree);
        while (node)
        {
            ypdata_t *yp;

            source_t *source = node->key;
            if ((yp = create_yp_entry (source)) != NULL)
            {
                DEBUG1 ("Adding existing mount %s", source->mount);
                yp->server = server;
                yp->touch_interval = server->touch_interval;
                yp->next = server->mounts;
                server->mounts = yp;
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
605
            }
606
            node = avl_get_next (node);
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
607
        }
608
        avl_tree_unlock (global.source_tree);
609
    }
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
}


static void add_pending_yp (struct yp_server *server)
{
    ypdata_t *current, *yp;
    unsigned count = 0;

    if (server->pending_mounts == NULL)
        return;
    current = server->mounts;
    server->mounts = server->pending_mounts;
    server->pending_mounts = NULL;
    yp = server->mounts;
    while (1)
    {
        count++;
        if (yp->next == NULL)
            break;
        yp = yp->next;
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
630
    }
631
632
633
634
    yp->next = current;
    DEBUG2 ("%u YP entries added to %s", count, server->url);
}

635

636
637
638
static void delete_marked_yp (struct yp_server *server)
{
    ypdata_t *yp = server->mounts, **prev = &server->mounts;
639

640
641
642
643
644
645
646
647
648
649
650
651
652
653
    while (yp)
    {
        if (yp->remove)
        {
            ypdata_t *to_go = yp;
            DEBUG2 ("removed %s from YP server %s", yp->mount, server->url);
            *prev = yp->next;
            yp = yp->next;
            yp_destroy_ypdata (to_go);
            continue;
        }
        prev = &yp->next;
        yp = yp->next;
    }
654
}
655
656
657


static void *yp_update_thread(void *arg)
658
{
659
660
661
662
663
664
665
666
667
668
669
    INFO0("YP update thread started");

    yp_running = 1;
    while (yp_running)
    {
        struct yp_server *server;

        thread_sleep (200000);

        /* do the YP communication */
        thread_rwlock_rlock (&yp_lock);
670
        server = (struct yp_server *)active_yps;
671
672
673
674
675
        while (server)
        {
            /* DEBUG1 ("trying %s", server->url); */
            yp_process_server (server);
            server = server->next;
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
676
        }
677
678
679
680
681
682
683
        thread_rwlock_unlock (&yp_lock);

        /* update the local YP structure */
        if (yp_update)
        {
            thread_rwlock_wlock (&yp_lock);
            check_servers ();
684
            server = (struct yp_server *)active_yps;
685
686
687
688
689
690
            while (server)
            {
                /* DEBUG1 ("Checking yps %s", server->url); */
                add_pending_yp (server);
                delete_marked_yp (server);
                server = server->next;
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
691
            }
692
693
            yp_update = 0;
            thread_rwlock_unlock (&yp_lock);
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
694
695
        }
    }
696
697
698
699
700
    thread_rwlock_destroy (&yp_lock);
    thread_mutex_destroy (&yp_pending_lock);
    /* free server and ypdata left */
    while (active_yps)
    {
701
        struct yp_server *server = (struct yp_server *)active_yps;
702
703
704
        active_yps = server->next;
        destroy_yp_server (server);
    }
705

706
    return NULL;
707
}
708

709
710
711


static void yp_destroy_ypdata(ypdata_t *ypdata)
712
{
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
713
    if (ypdata) {
714
715
716
717
718
        if (ypdata->mount) {
            free (ypdata->mount);
        }
        if (ypdata->url) {
            free (ypdata->url);
719
        }
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
        if (ypdata->sid) {
            free(ypdata->sid);
        }
        if (ypdata->server_name) {
            free(ypdata->server_name);
        }
        if (ypdata->server_desc) {
            free(ypdata->server_desc);
        }
        if (ypdata->server_genre) {
            free(ypdata->server_genre);
        }
        if (ypdata->cluster_password) {
            free(ypdata->cluster_password);
        }
        if (ypdata->listen_url) {
            free(ypdata->listen_url);
        }
        if (ypdata->current_song) {
            free(ypdata->current_song);
        }
        if (ypdata->bitrate) {
            free(ypdata->bitrate);
        }
        if (ypdata->server_type) {
            free(ypdata->server_type);
        }
747
748
749
        if (ypdata->audio_info) {
            free(ypdata->audio_info);
        }
750
751
752
        if (ypdata->audio_info) {
            free(ypdata->cluster_password);
        }
753
754
        free (ypdata->error_msg);
        free (ypdata);
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
755
    }
756
}
757

758
static void add_yp_info (ypdata_t *yp, char *stat_name, void *info, int type)
759
760
{
    char *escaped;
761
762

    if (!info)
763
        return;
764
765
766

    switch (type)
    {
767
        case YP_SERVER_NAME:
768
769
770
771
772
773
774
775
776
            escaped = util_url_escape(info);
            if (escaped)
            {
                if (yp->server_name)
                    free (yp->server_name);
                yp->server_name = escaped;
                stats_event (yp->mount, stat_name, (char *)info);
            }
            break;
777
        case YP_SERVER_DESC:
778
779
780
781
782
783
784
785
786
            escaped = util_url_escape(info);
            if (escaped)
            {
                if (yp->server_desc)
                    free (yp->server_desc);
                yp->server_desc = escaped;
                stats_event(yp->mount, stat_name, (char *)info);
            }
            break;
787
        case YP_SERVER_GENRE:
788
789
790
791
792
793
794
795
796
            escaped = util_url_escape(info);
            if (escaped)
            {
                if (yp->server_genre)
                    free (yp->server_genre);
                yp->server_genre = escaped;
                stats_event (yp->mount, stat_name, (char *)info);
            }
            break;
797
        case YP_SERVER_URL:
798
799
800
801
802
803
804
805
806
            escaped = util_url_escape(info);
            if (escaped)
            {
                if (yp->url)
                    free (yp->url);
                yp->url = escaped;
                stats_event (yp->mount, stat_name, (char *)info);
            }
            break;
807
        case YP_BITRATE:
808
809
810
811
812
813
814
815
816
            escaped = util_url_escape(info);
            if (escaped)
            {
                if (yp->bitrate)
                    free (yp->bitrate);
                yp->bitrate = escaped;
                stats_event (yp->mount, stat_name, (char *)info);
            }
            break;
817
        case YP_AUDIO_INFO:
818
819
820
821
            if (yp->audio_info)
                free (yp->audio_info);
            yp->audio_info = strdup (info);
            break;
822
        case YP_SERVER_TYPE:
823
824
825
826
827
828
829
830
            escaped = util_url_escape(info);
            if (escaped)
            {
                if (yp->server_type)
                    free (yp->server_type);
                yp->server_type = escaped;
            }
            break;
831
        case YP_CURRENT_SONG:
832
833
834
835
836
837
838
839
840
            escaped = util_url_escape(info);
            if (escaped)
            {
                if (yp->current_song)
                    free (yp->current_song);
                yp->current_song = escaped;
                stats_event (yp->mount, "yp_currently_playing", (char *)info);
            }
            break;
841
842
843
844
845
846
847
848
849
        case YP_CLUSTER_PASSWORD:
            escaped = util_url_escape(info);
            if (escaped)
            {
                if (yp->cluster_password)
                    free (yp->cluster_password);
                yp->cluster_password = escaped;
            }
            break;
850
851
852
853
854
855
856
857
858
859
860
861
862
863
    }
}


/* Add YP entries to active servers */
void yp_add (source_t *source)
{
    struct yp_server *server;

    /* make sure YP thread is not modifying the lists */
    thread_rwlock_rlock (&yp_lock);

    /* make sure we don't race against another yp_add */
    thread_mutex_lock (&yp_pending_lock);
864
    server = (struct yp_server *)active_yps;
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
    while (server)
    {
        ypdata_t *yp;
        /* add new ypdata to each servers pending yp */
        if ((yp = create_yp_entry (source)) != NULL)
        {
            DEBUG2 ("Adding %s to %s", source->mount, server->url);
            yp->server = server;
            yp->touch_interval = server->touch_interval;
            yp->next = server->pending_mounts;
            server->pending_mounts = yp;
            yp_update = 1;
        }
        server = server->next;
    }
    thread_mutex_unlock (&yp_pending_lock);
    thread_rwlock_unlock (&yp_lock);
    /* DEBUG1 ("Added %s to YP ", source->mount); */
}



/* Mark an existing entry in the YP list as to be marked for deletion */
void yp_remove (const char *mount)
{
890
    struct yp_server *server = (struct yp_server *)active_yps;
891
892
893
894

    thread_rwlock_rlock (&yp_lock);
    while (server)
    {
895
        ypdata_t *yp = find_yp_mount (server->mounts, mount);
896
897
        if (yp)
        {
898
899
            DEBUG2 ("release %s on YP %s", mount, server->url);
            yp->release = 1;
900
            yp->next_update = 0;
901
        }
902
        server = server->next;
903
    }
904
    thread_rwlock_unlock (&yp_lock);
905
}
906
907
908
909
910
911


/* This is similar to yp_remove, but we force a touch
 * attempt */
void yp_touch (const char *mount)
{
912
    struct yp_server *server = (struct yp_server *)active_yps;
913
    time_t trigger;
914
    ypdata_t *search_list = NULL;
915
916
917
918

    thread_rwlock_rlock (&yp_lock);
    /* do update in 3 secs, give stats chance to update */
    trigger = time(NULL) + 3;
919
920
921
    if (server)
        search_list = server->mounts;

922
923
    while (server)
    {
924
        ypdata_t *yp = find_yp_mount (search_list, mount);
925
926
        if (yp)
        {
927
            /* we may of found old entries not purged yet, so skip them */
928
            if (yp->release != 0 || yp->remove != 0)
929
930
931
932
            {
                search_list = yp->next;
                continue;
            }
933
934
935
936
937
            /* only force if touch */
            if (yp->process == do_yp_touch)
                yp->next_update = trigger;
        }
        server = server->next;
938
939
        if (server)
            search_list = server->mounts;
940
941
942
943
944
945
946
947
948
    }
    thread_rwlock_unlock (&yp_lock);
}


void yp_shutdown ()
{
    yp_running = 0;
    yp_update = 1;
949
950
    if (yp_thread)
        thread_join (yp_thread);
951
    curl_global_cleanup();
952
    INFO0 ("YP thread down");
953
954
}