tvhlog(LOG_INFO, "serviceprobe", "%20s: checking...",
t->s_svcname);
- s = subscription_create_from_service(t, "serviceprobe", &sq.sq_st, 0);
+ s = subscription_create_from_service(t, "serviceprobe", &sq.sq_st, 0,
+ NULL, NULL, "serviceprobe");
if(s == NULL) {
t->s_sp_onqueue = 0;
TAILQ_REMOVE(&serviceprobe_queue, t, s_sp_link);
*/
th_subscription_t *
subscription_create_from_service(service_t *t, const char *name,
- streaming_target_t *st, int flags)
+ streaming_target_t *st, int flags,
+ const char *hostname, const char *username,
+ const char *client)
{
th_subscription_t *s;
source_info_t si;
s = subscription_create(INT32_MAX, name, st, flags,
subscription_input_direct,
- NULL, NULL, NULL);
+ hostname, username, client);
if(t->s_status != SERVICE_RUNNING) {
if((r = service_start(t, INT32_MAX, 1)) != 0) {
st = calloc(1, sizeof(streaming_target_t));
streaming_target_init(st, dummy_callback, NULL, 0);
- subscription_create_from_service(t, "dummy", st, 0);
+ subscription_create_from_service(t, "dummy", st, 0, NULL, NULL, "dummy");
tvhlog(LOG_NOTICE, "subscription",
"Dummy join %s ok", id);
flags = 0;
}
- s = subscription_create_from_service(service, "HTTP", st, flags);
+ s = subscription_create_from_service(service, "HTTP", st, flags,
+ inet_ntoa(hc->hc_peer->sin_addr),
+ hc->hc_username,
+ http_arg_get(&hc->hc_args, "User-Agent"));
if(s) {
name = strdupa(service->s_ch ?
service->s_ch->ch_name : service->s_nicename);