connection.c 23.1 KB
Newer Older
Jack Moffitt's avatar
Jack Moffitt committed
1
2
3
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
4
#include <time.h>
Jack Moffitt's avatar
Jack Moffitt committed
5
#include <sys/types.h>
6
#include <sys/stat.h>
7
8
9

#ifndef _WIN32
#include <sys/time.h>
Jack Moffitt's avatar
Jack Moffitt committed
10
11
#include <sys/socket.h>
#include <netinet/in.h>
12
#else
13
#include <winsock2.h>
14
15
#define snprintf _snprintf
#define strcasecmp stricmp
16
#define strncasecmp strnicmp
17
#endif
Jack Moffitt's avatar
Jack Moffitt committed
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

#include "os.h"

#include "thread.h"
#include "avl.h"
#include "sock.h"
#include "log.h"
#include "httpp.h"

#include "config.h"
#include "global.h"
#include "util.h"
#include "connection.h"
#include "refbuf.h"
#include "client.h"
#include "stats.h"
#include "logging.h"
35
#include "xslt.h"
36
#include "fserve.h"
37
38

#include "yp.h"
Jack Moffitt's avatar
Jack Moffitt committed
39
#include "source.h"
40
#include "geturl.h"
Michael Smith's avatar
Michael Smith committed
41
#include "format.h"
42
#include "format_mp3.h"
Jack Moffitt's avatar
Jack Moffitt committed
43
44
45
46
47
48
49
50
51

#define CATMODULE "connection"

typedef struct con_queue_tag {
	connection_t *con;
	struct con_queue_tag *next;
} con_queue_t;

typedef struct _thread_queue_tag {
52
	thread_type *thread_id;
Jack Moffitt's avatar
Jack Moffitt committed
53
54
55
56
57
58
59
60
61
62
63
64
65
	struct _thread_queue_tag *next;
} thread_queue_t;

static mutex_t _connection_mutex;
static unsigned long _current_id = 0;
static int _initialized = 0;
static cond_t _pool_cond;

static con_queue_t *_queue = NULL;
static mutex_t _queue_mutex;

static thread_queue_t *_conhands = NULL;

66
rwlock_t _source_shutdown_rwlock;
Jack Moffitt's avatar
Jack Moffitt committed
67
68
69
70
71
72
73
74
75
76
77

static void *_handle_connection(void *arg);

void connection_initialize(void)
{
	if (_initialized) return;
	
	thread_mutex_create(&_connection_mutex);
	thread_mutex_create(&_queue_mutex);
	thread_rwlock_create(&_source_shutdown_rwlock);
	thread_cond_create(&_pool_cond);
78
    thread_cond_create(&global.shutdown_cond);
Jack Moffitt's avatar
Jack Moffitt committed
79
80
81
82
83
84
85
86

	_initialized = 1;
}

void connection_shutdown(void)
{
	if (!_initialized) return;
	
87
    thread_cond_destroy(&global.shutdown_cond);
Jack Moffitt's avatar
Jack Moffitt committed
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
	thread_cond_destroy(&_pool_cond);
	thread_rwlock_destroy(&_source_shutdown_rwlock);
	thread_mutex_destroy(&_queue_mutex);
	thread_mutex_destroy(&_connection_mutex);

	_initialized = 0;
}

static unsigned long _next_connection_id(void)
{
	unsigned long id;

	thread_mutex_lock(&_connection_mutex);
	id = _current_id++;
	thread_mutex_unlock(&_connection_mutex);

	return id;
}

107
108
109
110
111
112
113
114
115
116
117
connection_t *create_connection(sock_t sock, char *ip) {
	connection_t *con;
	con = (connection_t *)malloc(sizeof(connection_t));
	memset(con, 0, sizeof(connection_t));
	con->sock = sock;
	con->con_time = time(NULL);
	con->id = _next_connection_id();
	con->ip = ip;
	return con;
}

Jack Moffitt's avatar
Jack Moffitt committed
118
119
120
121
122
123
static connection_t *_accept_connection(void)
{
	int sock;
	connection_t *con;
	char *ip;

124
    if (util_timed_wait_for_fd(global.serversock, 100) <= 0) {
Jack Moffitt's avatar
Jack Moffitt committed
125
126
127
		return NULL;
	}

128
	/* malloc enough room for a full IP address (including ipv6) */
129
	ip = (char *)malloc(MAX_ADDR_LEN);
Jack Moffitt's avatar
Jack Moffitt committed
130

131
	sock = sock_accept(global.serversock, ip, MAX_ADDR_LEN);
Jack Moffitt's avatar
Jack Moffitt committed
132
	if (sock >= 0) {
133
		con = create_connection(sock, ip);
Jack Moffitt's avatar
Jack Moffitt committed
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164

		return con;
	}

	if (!sock_recoverable(sock_error()))
		WARN2("accept() failed with error %d: %s", sock_error(), strerror(sock_error()));
	
	free(ip);

	return NULL;
}

static void _add_connection(connection_t *con)
{
	con_queue_t *node;

	node = (con_queue_t *)malloc(sizeof(con_queue_t));
	
	thread_mutex_lock(&_queue_mutex);
	node->con = con;
	node->next = _queue;
	_queue = node;
	thread_mutex_unlock(&_queue_mutex);

}

static void _signal_pool(void)
{
	thread_cond_signal(&_pool_cond);
}

165
static void _push_thread(thread_queue_t **queue, thread_type *thread_id)
Jack Moffitt's avatar
Jack Moffitt committed
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
{
	/* create item */
	thread_queue_t *item = (thread_queue_t *)malloc(sizeof(thread_queue_t));
	item->thread_id = thread_id;
	item->next = NULL;


	thread_mutex_lock(&_queue_mutex);
	if (*queue == NULL) {
		*queue = item;
	} else {
		item->next = *queue;
		*queue = item;
	}
	thread_mutex_unlock(&_queue_mutex);
}

183
static thread_type *_pop_thread(thread_queue_t **queue)
Jack Moffitt's avatar
Jack Moffitt committed
184
{
185
	thread_type *id;
Jack Moffitt's avatar
Jack Moffitt committed
186
187
188
189
190
191
192
	thread_queue_t *item;

	thread_mutex_lock(&_queue_mutex);

	item = *queue;
	if (item == NULL) {
		thread_mutex_unlock(&_queue_mutex);
Michael Smith's avatar
Michael Smith committed
193
		return NULL;
Jack Moffitt's avatar
Jack Moffitt committed
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
	}

	*queue = item->next;
	item->next = NULL;
	id = item->thread_id;
	free(item);

	thread_mutex_unlock(&_queue_mutex);

	return id;
}

static void _build_pool(void)
{
	ice_config_t *config;
Michael Smith's avatar
Michael Smith committed
209
	int i;
210
    thread_type *tid;
Jack Moffitt's avatar
Jack Moffitt committed
211
212
213
214
215
216
	char buff[64];

	config = config_get_config();

	for (i = 0; i < config->threadpool_size; i++) {
		snprintf(buff, 64, "Connection Thread #%d", i);
217
		tid = thread_create(buff, _handle_connection, NULL, THREAD_ATTACHED);
Jack Moffitt's avatar
Jack Moffitt committed
218
219
220
221
222
223
		_push_thread(&_conhands, tid);
	}
}

static void _destroy_pool(void)
{
224
	thread_type *id;
Jack Moffitt's avatar
Jack Moffitt committed
225
226
227
228
229
230
	int i;

	i = 0;

	thread_cond_broadcast(&_pool_cond);
	id = _pop_thread(&_conhands);
Michael Smith's avatar
Michael Smith committed
231
	while (id != NULL) {
Jack Moffitt's avatar
Jack Moffitt committed
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
		thread_join(id);
		_signal_pool();
		id = _pop_thread(&_conhands);
	}
}

void connection_accept_loop(void)
{
	connection_t *con;

	_build_pool();

	while (global.running == ICE_RUNNING) {
		con = _accept_connection();

		if (con) {
			_add_connection(con);
			_signal_pool();
		}
	}

253
254
255
    /* Give all the other threads notification to shut down */
    thread_cond_broadcast(&global.shutdown_cond);

Jack Moffitt's avatar
Jack Moffitt committed
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
	_destroy_pool();

	/* wait for all the sources to shutdown */
	thread_rwlock_wlock(&_source_shutdown_rwlock);
	thread_rwlock_unlock(&_source_shutdown_rwlock);
}

static connection_t *_get_connection(void)
{
	con_queue_t *node = NULL;
	con_queue_t *oldnode = NULL;
	connection_t *con = NULL;

	thread_mutex_lock(&_queue_mutex);
	if (_queue) {
		node = _queue;
		while (node->next) {
			oldnode = node;
			node = node->next;
		}
		
		/* node is now the last node
		** and oldnode is the previous one, or NULL
		*/
		if (oldnode) oldnode->next = NULL;
		else (_queue) = NULL;
	}
	thread_mutex_unlock(&_queue_mutex);

	if (node) {
		con = node->con;
		free(node);
	}

	return con;
}

293
294
295
/* TODO: Make this return an appropriate error code so that we can use HTTP
 * codes where appropriate
 */
296
int connection_create_source(client_t *client, connection_t *con, http_parser_t *parser, char *mount) {
297
298
	source_t *source;
	char *contenttype;
Michael Smith's avatar
Michael Smith committed
299
    mount_proxy *mountproxy, *mountinfo = NULL;
300

301
302
303
304
305
306
307
308
309
310
311
	/* check to make sure this source wouldn't
	** be over the limit
	*/
	global_lock();
	if (global.sources >= config_get_config()->source_limit) {
		INFO1("Source (%s) logged in, but there are too many sources", mount);
		global_unlock();
		return 0;
	}
	global.sources++;
	global_unlock();
312

313
	stats_event_inc(NULL, "sources");
Michael Smith's avatar
Michael Smith committed
314
315
316
317
318
319
320
321
322
    
    mountproxy = config_get_config()->mounts;
    while(mountproxy) {
        if(!strcmp(mountproxy->mountname, mount)) {
            mountinfo = mountproxy;
            break;
        }
        mountproxy = mountproxy->next;
    }
323
324
325
326
327

	contenttype = httpp_getvar(parser, "content-type");

	if (contenttype != NULL) {
		format_type_t format = format_get_type(contenttype);
328
		if (format == FORMAT_ERROR) {
329
			WARN1("Content-type \"%s\" not supported, dropping source", contenttype);
330
            goto fail;
331
		} else {
Michael Smith's avatar
Michael Smith committed
332
333
			source = source_create(client, con, parser, mount, 
                    format, mountinfo);
334
335
		}
	} else {
336
        format_type_t format = FORMAT_TYPE_MP3;
337
		ERROR0("No content-type header, falling back to backwards compatibility mode for icecast 1.x relays. Assuming content is mp3.");
Michael Smith's avatar
Michael Smith committed
338
        source = source_create(client, con, parser, mount, format, mountinfo);
339
	}
340

341
    source->send_return = 1;
342
343
344
345
	source->shutdown_rwlock = &_source_shutdown_rwlock;
	sock_set_blocking(con->sock, SOCK_NONBLOCK);
	thread_create("Source Thread", source_main, (void *)source, THREAD_DETACHED);
	return 1;
346
347
348
349
350
351
352
353

fail:
    global_lock();
    global.sources--;
    global_unlock();

    stats_event_dec(NULL, "sources");
    return 0;
354
355
}

356
357
static int _check_pass_http(http_parser_t *parser, 
        char *correctuser, char *correctpass)
358
359
360
361
362
363
364
365
366
367
368
369
370
{
    /* This will look something like "Basic QWxhZGRpbjpvcGVuIHNlc2FtZQ==" */
    char *header = httpp_getvar(parser, "authorization");
    char *userpass, *tmp;
    char *username, *password;

    if(header == NULL)
        return 0;

    if(strncmp(header, "Basic ", 6))
        return 0;

    userpass = util_base64_decode(header+6);
371
372
373
    if(userpass == NULL) {
        WARN1("Base64 decode of Authorization header \"%s\" failed",
                header+6);
374
        return 0;
375
    }
376
377
378
379
380
381
382
383
384
385

    tmp = strchr(userpass, ':');
    if(!tmp) {
        free(userpass);
        return 0;
    }
    *tmp = 0;
    username = userpass;
    password = tmp+1;

386
    if(strcmp(username, correctuser) || strcmp(password, correctpass)) {
387
388
389
        free(userpass);
        return 0;
    }
390
    free(userpass);
391
392
393
394

    return 1;
}

395
static int _check_pass_ice(http_parser_t *parser, char *correctpass)
396
{
397
    char *password;
398
399
400
401
402
403
404
405
406
407
408

    password = httpp_getvar(parser, "ice-password");
    if(!password)
        password = "";

	if (strcmp(password, correctpass))
        return 0;
    else
        return 1;
}

409
static int _check_relay_pass(http_parser_t *parser)
410
{
411
412
413
414
415
416
417
    char *pass = config_get_config()->relay_password;
    if(!pass)
        pass = config_get_config()->source_password;

    return _check_pass_http(parser, "relay", pass);
}

418
419
420
421
422
423
424
425
426
427
428
static int _check_admin_pass(http_parser_t *parser)
{
    char *pass = config_get_config()->admin_password;
    char *user = config_get_config()->admin_username;
    if(!pass || !user)
        return 0;

    return _check_pass_http(parser, "admin", pass);
}

static int _check_source_pass(http_parser_t *parser, char *mount)
429
430
{
    char *pass = config_get_config()->source_password;
431
    char *user = "source";
432
    int ret;
433

434
435
436
437
438
439
440
    mount_proxy *mountinfo = config_get_config()->mounts;
    while(mountinfo) {
        if(!strcmp(mountinfo->mountname, mount)) {
            pass = mountinfo->password;
            user = mountinfo->username;
            break;
        }
441
        mountinfo = mountinfo->next;
442
443
444
445
446
447
448
449
    }

    if(!pass) {
        WARN0("No source password set, rejecting source");
        return 0;
    }

    ret = _check_pass_http(parser, user, pass);
450
451
452
453
454
455
456
457
    if(!ret && config_get_config()->ice_login)
    {
        ret = _check_pass_ice(parser, pass);
        if(ret)
            WARN0("Source is using deprecated icecast login");
    }

    return ret;
458
459
}

Michael Smith's avatar
Michael Smith committed
460
461
462
463
464
465
static void handle_fallback_request(client_t *client)
{
    source_t *source;
    char *mount, *value, *old;
    int bytes;

466
467
468
469
    mount = httpp_get_query_param(client->parser, "mount");
    value = httpp_get_query_param(client->parser, "fallback");

    if(!_check_source_pass(client->parser, mount)) {
Michael Smith's avatar
Michael Smith committed
470
471
472
473
474
475
476
477
478
479
480
481
482
483
		INFO0("Bad or missing password on fallback configuration request");
        client_send_401(client);
        return;
    }

    if(value == NULL || mount == NULL) {
        client_send_400(client, "Missing parameter");
        return;
    }

    avl_tree_rlock(global.source_tree);
    source = source_find_mount(mount);
    avl_tree_unlock(global.source_tree);

484
485
486
487
488
    if(source == NULL) {
        client_send_400(client, "Current source not found");
        return;
    }

Michael Smith's avatar
Michael Smith committed
489
490
491
492
493
494
495
496
497
498
499
500
    old = source->fallback_mount;
    source->fallback_mount = strdup(value);
    free(old);

    client->respcode = 200;
	bytes = sock_write(client->con->sock, 
            "HTTP/1.0 200 OK\r\nContent-Type: text/html\r\n\r\n"
            "Fallback configured");
    if(bytes > 0) client->con->sent_bytes = bytes;
    client_destroy(client);
}

501
502
503
504
505
506
507
508
509
static void handle_metadata_request(client_t *client)
{
    source_t *source;
    char *action;
    char *mount;
    char *value;
    mp3_state *state;
    int bytes;

510
511
512
513
514
    action = httpp_get_query_param(client->parser, "mode");
    mount = httpp_get_query_param(client->parser, "mount");
    value = httpp_get_query_param(client->parser, "song");

    if(!_check_source_pass(client->parser, mount)) {
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
		INFO0("Metadata request with wrong or missing password");
        client_send_401(client);
        return;
    }

    if(value == NULL || action == NULL || mount == NULL) {
        client_send_400(client, "Missing parameter");
        return;
    }

    avl_tree_rlock(global.source_tree);
    source = source_find_mount(mount);
    avl_tree_unlock(global.source_tree);

    if(source == NULL) {
        client_send_400(client, "No such mountpoint");
        return;
    }

    if(source->format->type != FORMAT_TYPE_MP3) {
        client_send_400(client, "Not mp3, cannot update metadata");
        return;
    }

    if(strcmp(action, "updinfo") != 0) {
        client_send_400(client, "No such action");
        return;
    }

    state = source->format->_state;
    thread_mutex_lock(&(state->lock));
    free(state->metadata);
    state->metadata = strdup(value);
    state->metadata_age++;
549
    state->metadata_raw = 0;
550
551
552
    thread_mutex_unlock(&(state->lock));

    DEBUG2("Metadata on mountpoint %s changed to \"%s\"", mount, value);
553
    stats_event(mount, "title", value);
554
555
556
557
558
559
560
561
    client->respcode = 200;
	bytes = sock_write(client->con->sock, 
            "HTTP/1.0 200 OK\r\nContent-Type: text/html\r\n\r\n"
            "Update successful");
    if(bytes > 0) client->con->sent_bytes = bytes;
    client_destroy(client);
}

562
563
564
static void _handle_source_request(connection_t *con, 
        http_parser_t *parser, char *uri)
{
565
566
567
568
    client_t *client;

	client = client_create(con, parser);

569
570
571
    INFO1("Source logging in at mountpoint \"%s\"", uri);
    stats_event_inc(NULL, "source_connections");
				
572
	if (!_check_source_pass(parser, uri)) {
573
		INFO1("Source (%s) attempted to login with invalid or missing password", uri);
574
        client_send_401(client);
575
576
577
578
579
580
581
582
583
        return;
	}

	/* check to make sure this source has
	** a unique mountpoint
	*/

	avl_tree_rlock(global.source_tree);
	if (source_find_mount(uri) != NULL) {
584
		avl_tree_unlock(global.source_tree);
585
		INFO1("Source tried to log in as %s, but mountpoint is already used", uri);
586
        client_send_404(client, "Mountpoint in use");
587
588
589
590
		return;
	}
	avl_tree_unlock(global.source_tree);

591
	if (!connection_create_source(client, con, parser, uri)) {
592
        client_send_404(client, "Mountpoint in use");
593
594
595
596
597
	}
}

static void _handle_stats_request(connection_t *con, 
        http_parser_t *parser, char *uri)
Jack Moffitt's avatar
Jack Moffitt committed
598
599
{
	stats_connection_t *stats;
600
601
602

	stats_event_inc(NULL, "stats_connections");
				
603
	if (!_check_admin_pass(parser)) {
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
        ERROR0("Bad password for stats connection");
		connection_close(con);
		httpp_destroy(parser);
        return;
	}
					
	stats_event_inc(NULL, "stats");
					
	/* create stats connection and create stats handler thread */
	stats = (stats_connection_t *)malloc(sizeof(stats_connection_t));
	stats->parser = parser;
	stats->con = con;
					
	thread_create("Stats Connection", stats_connection, (void *)stats, THREAD_DETACHED);
}

static void _handle_get_request(connection_t *con,
        http_parser_t *parser, char *uri)
{
    char *fullpath;
	client_t *client;
    int bytes;
626
	struct stat statbuf;
627
628
629
630
631
632
633
634
635
636
	source_t *source;

    DEBUG0("Client connected");

	/* make a client */
	client = client_create(con, parser);
	stats_event_inc(NULL, "client_connections");
					
	/* there are several types of HTTP GET clients
	** media clients, which are looking for a source (eg, URI = /stream.ogg)
637
	** stats clients, which are looking for /admin/stats.xml
638
639
640
641
642
643
	** and director server authorizers, which are looking for /GUID-xxxxxxxx 
    ** (where xxxxxx is the GUID in question) - this isn't implemented yet.
	** we need to handle the latter two before the former, as the latter two
	** aren't subject to the limits.
	*/
	/* TODO: add GUID-xxxxxx */
644
	if (strcmp(uri, "/admin/stats.xml") == 0) {
645
	    if (!_check_admin_pass(parser)) {
646
		    INFO0("Request for /admin/stats.xml with incorrect or no password");
647
648
649
            client_send_401(client);
            return;
    	}
650
651
652
653
654
655
        DEBUG0("Stats request, sending xml stats");
		stats_sendxml(client);
        client_destroy(client);
        return;
    }

656
657
658
659
660
661
    if(strcmp(uri, "/admin/metadata") == 0) {
        DEBUG0("Got metadata update request");
        handle_metadata_request(client);
        return;
    }

Michael Smith's avatar
Michael Smith committed
662
663
664
665
666
667
    if(strcmp(uri, "/admin/fallbacks") == 0) {
        DEBUG0("Got fallback request");
        handle_fallback_request(client);
        return;
    }

668
669
670
671
672
673
674
675
676
	/* Here we are parsing the URI request to see
	** if the extension is .xsl, if so, then process
	** this request as an XSLT request
	*/
    fullpath = util_get_path_from_normalised_uri(uri);
    if (util_check_valid_extension(fullpath) == XSLT_CONTENT) {
    	/* If the file exists, then transform it, otherwise, write a 404 */
    	if (stat(fullpath, &statbuf) == 0) {
            DEBUG0("Stats request, sending XSL transformed stats");
677
            client->respcode = 200;
678
679
680
681
682
683
684
685
686
687
688
689
		    bytes = sock_write(client->con->sock, 
                    "HTTP/1.0 200 OK\r\nContent-Type: text/html\r\n\r\n");
            if(bytes > 0) client->con->sent_bytes = bytes;
            stats_transform_xslt(client, fullpath);
		    client_destroy(client);
    	}
	    else {
            client_send_404(client, "The file you requested could not be found");
    	}
        free(fullpath);
        return;
	}
690
691
    else if(config_get_config()->fileserve && 
            stat(fullpath, &statbuf) == 0) {
692
        fserve_client_create(client, fullpath);
693
694
695
        free(fullpath);
        return;
    }
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
    free(fullpath);

    if(strcmp(util_get_extension(uri), "m3u") == 0) {
        char *sourceuri = strdup(uri);
        char *dot = strrchr(sourceuri, '.');
        *dot = 0;
	    avl_tree_rlock(global.source_tree);
    	source = source_find_mount(sourceuri);
	   	if (source) {
            client->respcode = 200;
            bytes = sock_write(client->con->sock,
                    "HTTP/1.0 200 OK\r\n"
                    "Content-Type: audio/x-mpegurl\r\n\r\n"
                    "http://%s:%d%s", 
                    config_get_config()->hostname, 
                    config_get_config()->port,
                    sourceuri
                    );
            if(bytes > 0) client->con->sent_bytes = bytes;
    	    client_destroy(client);
        }
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
        else if(config_get_config()->fileserve) {
            fullpath = util_get_path_from_normalised_uri(sourceuri);
            if(stat(fullpath, &statbuf) == 0) {
                fserve_client_create(client, fullpath);
                free(fullpath);
            }
            else {
                free(fullpath);
                fullpath = util_get_path_from_normalised_uri(uri);
                if(stat(fullpath, &statbuf) == 0) {
                    fserve_client_create(client, fullpath);
                    free(fullpath);
                }
                else {
                    free(fullpath);
                    client_send_404(client, 
                            "The file you requested could not be found");
                }
            }
        }
737
738
739
740
741
742
743
744
        else {
            client_send_404(client, "The file you requested could not be found");
        }
		avl_tree_unlock(global.source_tree);
        free(sourceuri);
        return;
    }

745
	if (strcmp(uri, "/admin/streamlist") == 0) {
746
		if (!_check_relay_pass(parser)) {
747
			INFO0("Client attempted to fetch /admin/streamlist with bad password");
748
            client_send_401(client);
749
		} else {
750
751
752
			avl_node *node;
			source_t *s;

753
754
755
756
757
            client->respcode = 200;
            bytes = sock_write(client->con->sock,
                    "HTTP/1.0 200 OK\r\n\r\n");
            if(bytes > 0) client->con->sent_bytes = bytes;

758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
			avl_tree_rlock(global.source_tree);
			node = avl_get_first(global.source_tree);
			while (node) {
				s = (source_t *)node->key;
				bytes = sock_write(client->con->sock, "%s\r\n", s->mount);
                if(bytes > 0) client->con->sent_bytes += bytes;
                else break;

				node = avl_get_next(node);
			}
			avl_tree_unlock(global.source_tree);
		    client_destroy(client);
		}
        return;
	}
				
	global_lock();
	if (global.clients >= config_get_config()->client_limit) {
Michael Smith's avatar
Michael Smith committed
776
777
        client_send_504(client,
                "The server is already full. Try again later.");
778
779
780
781
782
783
784
785
786
787
788
789
		global_unlock();
        return;
	}
	global_unlock();
					
	avl_tree_rlock(global.source_tree);
	source = source_find_mount(uri);
	if (source) {
        DEBUG0("Source found for client");
						
		global_lock();
		if (global.clients >= config_get_config()->client_limit) {
Michael Smith's avatar
Michael Smith committed
790
791
            client_send_504(client, 
                    "The server is already full. Try again later.");
792
793
794
795
			global_unlock();
            avl_tree_unlock(global.source_tree);
            return;
		}
Michael Smith's avatar
Michael Smith committed
796
797
798
799
800
801
802
803
804
        else if(source->max_listeners != -1 && 
                source->listeners >= source->max_listeners) 
        {
            client_send_504(client, 
                    "Too many clients on this mountpoint. Try again later.");
			global_unlock();
            avl_tree_unlock(global.source_tree);
            return;
        }
805
		global.clients++;
Michael Smith's avatar
Michael Smith committed
806
        source->listeners++;
807
808
		global_unlock();
						
Michael Smith's avatar
Michael Smith committed
809
810
811
812
        client->format_data = source->format->create_client_data(
                source->format, source, client);

        source->format->client_send_headers(source->format, source, client);
813
814
815
816
817
						
		bytes = sock_write(client->con->sock, "\r\n");
        if(bytes > 0) client->con->sent_bytes += bytes;
							
    	sock_set_blocking(client->con->sock, SOCK_NONBLOCK);
818
        sock_set_nodelay(client->con->sock);
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
						
		avl_tree_wlock(source->pending_tree);
		avl_insert(source->pending_tree, (void *)client);
		avl_tree_unlock(source->pending_tree);
	}
					
	avl_tree_unlock(global.source_tree);
					
	if (!source) {
        DEBUG0("Source not found for client");
        client_send_404(client, "The source you requested could not be found.");
	}
}

static void *_handle_connection(void *arg)
{
	char header[4096];
	connection_t *con;
	http_parser_t *parser;
838
    char *rawuri, *uri;
839
	client_t *client;
Jack Moffitt's avatar
Jack Moffitt committed
840
841
842
843
844
845
846
847

	while (global.running == ICE_RUNNING) {
		memset(header, 0, 4096);

		thread_cond_wait(&_pool_cond);
		if (global.running != ICE_RUNNING) break;

		/* grab a connection and set the socket to blocking */
848
		while ((con = _get_connection())) {
849
			stats_event_inc(NULL, "connections");
Jack Moffitt's avatar
Jack Moffitt committed
850

851
			sock_set_blocking(con->sock, SOCK_BLOCK);
Jack Moffitt's avatar
Jack Moffitt committed
852

853
854
855
			/* fill header with the http header */
			if (util_read_header(con->sock, header, 4096) == 0) {
				/* either we didn't get a complete header, or we timed out */
Jack Moffitt's avatar
Jack Moffitt committed
856
857
858
859
				connection_close(con);
				continue;
			}

860
861
862
863
			parser = httpp_create_parser();
			httpp_initialize(parser, NULL);
			if (httpp_parse(parser, header, strlen(header))) {
				/* handle the connection or something */
Jack Moffitt's avatar
Jack Moffitt committed
864
				
865
866
				if (strcmp("ICE",  httpp_getvar(parser, HTTPP_VAR_PROTOCOL)) &&
                    strcmp("HTTP", httpp_getvar(parser, HTTPP_VAR_PROTOCOL))) {
867
                    ERROR0("Bad HTTP protocol detected");
Jack Moffitt's avatar
Jack Moffitt committed
868
869
870
871
872
					connection_close(con);
					httpp_destroy(parser);
					continue;
				}

873
874
875
876
877
                rawuri = httpp_getvar(parser, HTTPP_VAR_URI);
                uri = util_normalise_uri(rawuri);

                if(!uri) {
					client = client_create(con, parser);
878
                    client_send_404(client, "The path you requested was invalid");
879
880
                    continue;
                }
881

882
				if (parser->req_type == httpp_req_source) {
883
884
885
886
887
888
889
890
891
                    _handle_source_request(con, parser, uri);
                }
                else if (parser->req_type == httpp_req_stats) {
                    _handle_stats_request(con, parser, uri);
                }
                else if (parser->req_type == httpp_req_get) {
                    _handle_get_request(con, parser, uri);
                }
                else {
892
                    ERROR0("Wrong request type from client");
893
894
					connection_close(con);
					httpp_destroy(parser);
895
896
897
                }

                free(uri);
Jack Moffitt's avatar
Jack Moffitt committed
898
			} else {
899
                ERROR0("HTTP request parsing failed");
Jack Moffitt's avatar
Jack Moffitt committed
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
				connection_close(con);
				httpp_destroy(parser);
				continue;
			}
		}
	}

	thread_exit(0);

	return NULL;
}

void connection_close(connection_t *con)
{
	sock_close(con->sock);
	if (con->ip) free(con->ip);
	if (con->host) free(con->host);
	free(con);
}