search for: source_t

...QTL_RAW_REQUEST)) + return COMMAND_BUILDQTL; else if(!strcmp(command, DEFAULT_TRANSFORMED_REQUEST)) return COMMAND_TRANSFORMED_STATS; else if(!strcmp(command, DEFAULT_RAW_REQUEST)) @@ -188,6 +204,14 @@ int response); static void command_buildm3u(client_t *client, source_t *source, int response); +static void command_buildpls(client_t *client, source_t *source, + int response); +static void command_buildasx(client_t *client, source_t *source, + int response); +static void command_buildram(client_t *client, source_t *source, + int respons...

...const char *mount, format_type_t type, mount_proxy *mountinfo) { + char buffer[PATH_MAX]; + time_t curtime; + struct tm *loctime; + + /* Get the current time. */ + curtime = time (NULL); + + /* Convert it to local time representation. */ + loctime = localtime (&curtime); + source_t *src; src = (source_t *)malloc(sizeof(source_t)); @@ -76,7 +86,8 @@ src->fallback_mount = strdup (mountinfo->fallback_mount); src->max_listeners = mountinfo->max_listeners; if (mountinfo->dumpfile != NULL) - src->dumpfilename = strdup (mountinfo->dumpfile); +...

...const char *mount, format_type_t type, mount_proxy *mountinfo) { + char buffer[PATH_MAX]; + time_t curtime; + struct tm *loctime; + + /* Get the current time. */ + curtime = time (NULL); + + /* Convert it to local time representation. */ + loctime = localtime (&curtime); + source_t *src; src = (source_t *)malloc(sizeof(source_t)); @@ -76,7 +86,8 @@ src->fallback_mount = strdup (mountinfo->fallback_mount); src->max_listeners = mountinfo->max_listeners; if (mountinfo->dumpfile != NULL) - src->dumpfilename = strdup (mountinfo->dumpfile); +...

...ne RTP_MPEG_CLK 90000 void *source_main(void *arg) { + int rtp_socket; + struct sockaddr_in rtp_sin; + unsigned char on=1; + char rtp_buf[RTP_PKT_SIZE]; + int rtp_done,rtp_amount; + struct timeval rtp_tv; + unsigned long rtp_timestamp=random(); /* random timestamp */ + source_t *source = (source_t *)arg; source_t *fallback_source; char buffer[4096]; @@ -224,6 +269,30 @@ } #endif + /* RTP diffusion initialization, if asked for */ + if (config->rtp_ip && (rtp_socket = socket(PF_INET,SOCK_DGRAM,0))>=0) { + rtp_sin.sin_addr.s_a...

...;/authentication> </mount> --> Index: src/auth.c =================================================================== --- src/auth.c (revision 6619) +++ src/auth.c (working copy) @@ -34,6 +34,30 @@ #define CATMODULE "auth" <p>+int auth_is_listener_connected(source_t *source, char *username) +{ + client_t *client; + avl_node *client_node; + + avl_tree_rlock(source->client_tree); + + client_node = avl_get_first(source->client_tree); + while(client_node) { + client = (client_t *)client_node->key; + if (client->username) {...

Hello, I work at SmarctJog.com, we have here some patches on IceCast for performance and reliability, these are mostly client/connection/source cleanups (a slave merge is underway, and some more good stuff (c)), but we'd like this to be merged in before the list gets any longer. Please find attached a list of our patches with a short desc: This one is actually not from us/me, it was found

...e lower level functions like the acl, etc. when the source is disconnected, when servicing queries, or otherwise? BEGIN icecast-2.3.2-moremntinfo.patch diff --git src/source.c src/source.c index 02bfc74..7e90d34 100644 --- src/source.c +++ src/source.c @@ -614,6 +614,10 @@ static void source_init (source_t *source) stats_event_args (source->mount, "listeners", "%lu", source->listeners); stats_event_args (source->mount, "listener_peak", "%lu", source->peak_listeners); stats_event_time (source->mount, "stream_start"); +...

On Sat, 2004-01-17 at 19:31, iceuse@kezako.net wrote: > Thanks, > Karl, do you plan to integrate this in your icecast-kh release? The idea is to put the the changes I've done into CVS. That way you get the best of both worlds, there's nothing conflicting AFAIK. karl. <p>--- >8 ---- List archives: http://www.xiph.org/archives/ icecast project homepage:

...modified files (perhaps you want to integrate them in your release, but also I'm not sure about locking or not the main source before moving the clients : if(source->fallback_override && source->fallback_mount) { /* get fallback source */ avl_tree_rlock (global.source_tree); source_t *fallback_source = source_find_mount (source->fallback_mount); avl_tree_unlock (global.source_tree); if (fallback_source) { INFO2 ("passing %d listeners to %s", fallback_source->mount,source->listeners ); /* Do we nee...

...oes the actual reading, making sure the read data is packaged in * blocks of 1400 bytes (near the common MTU size). This is because many * incoming streams come in small packets which could waste a lot of * bandwidth with many listeners due to headers and such like. */ static int complete_read (source_t *source) As far as I can see this fix has been applied only for the mp3 format. I guess the problem still remains for other formats, correct me if I am wrong. However, if I understand correctly your TCP_CORK solution would apply to all formats since it is applied on the client socket (irrespectiv...

...ease_config(); diff --git a/src/icecast b/src/icecast new file mode 100755 index 0000000..7e4f612 Binary files /dev/null and b/src/icecast differ diff --git a/src/source.c b/src/source.c index 02bfc74..b838799 100644 --- a/src/source.c +++ b/src/source.c @@ -579,7 +579,7 @@ static void source_init (source_t *source) listenurl = malloc (listen_url_size); memset (listenurl, '00', listen_url_size); snprintf (listenurl, listen_url_size, "http://%s:%d%s", - config->hostname, config->port, source->mount); + config->hostname, ( config->exposed_port ? config->exposed_port :...

...; *************** *** 209,214 **** --- 216,223 ---- config = config_get_config(); queue_limit = config->queue_size_limit; + global_listener_time_limit = config->client_time_limit; + mount_listener_time_limit = source->max_listener_time; timeout = config->source_timeout; hostname = config->hostname; port = config->port; *************** *** 428,435 **** avl_node_wlock(client_node); client = (client_t *)client_node->key; ! data_done = 0; /* do we have any old buffer...

Patch 1 was previously posted here: https://www.redhat.com/archives/libguestfs/2020-June/msg00086.html to handle this bug: https://bugzilla.redhat.com/show_bug.cgi?id=1848862 I was able to observe this bug and for me at least disabling readahead seems to cure it. Patches 2 and 3 are simplifications, removing a now-undocumented feature of virt-v2v-copy-to-local and thus simplifying greatly the

Hi Karl, Thanks for your help, About the "Connection:" header, you are right, it's: "Connection: close" and NOT "Connection: keep-alive". The protocol when the SERVER sends the data is http 1.0. It's http 1.1 when the browser requests the data. I don't understand the "Content-Length: 54000000" header either. Also I noticed the flash player on

> > One more detail about Icecast2 that I'd like to know is whether there is any > > load-balancing feature implemented or about to be implement? ... > I haven't heard or seen of this, nor do I think load balencing as you > describe it could be done seamlessly without modifying the media player. I made some tests and it turned out that Winamp, mpg123 and even MS Media

We're abusing icecast in a true narrowcasting setup (personalized stream per mountpoint). The streams itself are created in a piece of proprietory (spelling?, i'm dutch) software, icecast merely relays them. However, the intended endpoint is an embedded device. This device has trouble with tcp/ip packets not matching the max. packet size (MSS or MSS minus header). After eleborate testing,

It turns out that RHEL 5 Xen conversions don't work if the source disk is located on a block device. See patch 1/4 for the gory details. This patch series proposes a new tool called virt-v2v-copy-to-local which essentially is a way to make new virt-v2v work like the old virt-v2v, ie. copy first, convert after. Of course this is very slow and would only be used as a last resort, but I