mirror of
https://gitlab.xiph.org/xiph/icecast-server.git
synced 2025-01-03 14:56:34 -05:00
Revert stacksize stuff and changes for the thread module.
svn path=/trunk/icecast/; revision=2223
This commit is contained in:
parent
1902634e50
commit
c98a76ebbd
@ -216,7 +216,7 @@ static void _build_pool(void)
|
|||||||
|
|
||||||
for (i = 0; i < config->threadpool_size; i++) {
|
for (i = 0; i < config->threadpool_size; i++) {
|
||||||
snprintf(buff, 64, "Connection Thread #%d", i);
|
snprintf(buff, 64, "Connection Thread #%d", i);
|
||||||
tid = thread_create(buff, _handle_connection, NULL, ICE_DEFAULT_STACKSIZE, THREAD_ATTACHED);
|
tid = thread_create(buff, _handle_connection, NULL, THREAD_ATTACHED);
|
||||||
_push_thread(&_conhands, tid);
|
_push_thread(&_conhands, tid);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -364,7 +364,7 @@ static void *_handle_connection(void *arg)
|
|||||||
|
|
||||||
sock_set_blocking(con->sock, SOCK_NONBLOCK);
|
sock_set_blocking(con->sock, SOCK_NONBLOCK);
|
||||||
|
|
||||||
thread_create("Source Thread", source_main, (void *)source, ICE_DEFAULT_STACKSIZE, THREAD_DETACHED);
|
thread_create("Source Thread", source_main, (void *)source, THREAD_DETACHED);
|
||||||
|
|
||||||
continue;
|
continue;
|
||||||
} else if (parser->req_type == httpp_req_stats) {
|
} else if (parser->req_type == httpp_req_stats) {
|
||||||
@ -385,7 +385,7 @@ static void *_handle_connection(void *arg)
|
|||||||
stats->parser = parser;
|
stats->parser = parser;
|
||||||
stats->con = con;
|
stats->con = con;
|
||||||
|
|
||||||
thread_create("Stats Connection", stats_connection, (void *)stats, ICE_DEFAULT_STACKSIZE, THREAD_DETACHED);
|
thread_create("Stats Connection", stats_connection, (void *)stats, THREAD_DETACHED);
|
||||||
|
|
||||||
continue;
|
continue;
|
||||||
} else if (parser->req_type == httpp_req_play || parser->req_type == httpp_req_get) {
|
} else if (parser->req_type == httpp_req_play || parser->req_type == httpp_req_get) {
|
||||||
|
@ -6,8 +6,6 @@
|
|||||||
#define ICE_RUNNING 1
|
#define ICE_RUNNING 1
|
||||||
#define ICE_HALTING 2
|
#define ICE_HALTING 2
|
||||||
|
|
||||||
#define ICE_DEFAULT_STACKSIZE 8192
|
|
||||||
|
|
||||||
typedef struct ice_global_tag
|
typedef struct ice_global_tag
|
||||||
{
|
{
|
||||||
int serversock;
|
int serversock;
|
||||||
|
@ -74,7 +74,7 @@ void stats_initialize()
|
|||||||
|
|
||||||
/* fire off the stats thread */
|
/* fire off the stats thread */
|
||||||
_stats_running = 1;
|
_stats_running = 1;
|
||||||
_stats_thread_id = thread_create("Stats Thread", _stats_thread, NULL, ICE_DEFAULT_STACKSIZE, THREAD_ATTACHED);
|
_stats_thread_id = thread_create("Stats Thread", _stats_thread, NULL, THREAD_ATTACHED);
|
||||||
}
|
}
|
||||||
|
|
||||||
void stats_shutdown()
|
void stats_shutdown()
|
||||||
|
Loading…
Reference in New Issue
Block a user