X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=http_send.c;h=6c912951a964fdf73101381fe8f078ac4b699df6;hp=f9345acedb0e76ef8ef0487cd24ec411a35ea53f;hb=e9656de3ac6d281f585e5a60629d13631c569ae3;hpb=db34194eaab9819772bd55ea1ab08c719ed8f1c8 diff --git a/http_send.c b/http_send.c index f9345ace..6c912951 100644 --- a/http_send.c +++ b/http_send.c @@ -1,5 +1,5 @@ /* - * Copyright (C) 2005-2006 Andre Noll + * Copyright (C) 2005-2007 Andre Noll * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by @@ -22,7 +22,7 @@ #include "server.cmdline.h" #include "server.h" #include "http.h" -#include "afs.h" +#include "vss.h" #include "send.h" #include "list.h" #include "close_on_fork.h" @@ -38,8 +38,6 @@ #define HTTP_ERR_MSG "HTTP/1.0 400 Bad Request\n" /** \endcond */ -extern struct gengetopt_args_info conf; - /** the possible states of a client from the server's POV */ enum http_status { HTTP_CONNECTED, @@ -116,7 +114,7 @@ static void http_shutdown_client(struct http_client *hc, const char *msg) hc->fd, msg); numclients--; close(hc->fd); - + del_close_on_fork_list(hc->fd); list_for_each_entry_safe(qp, tmp, &hc->packet_queue, node) { free(qp->packet); list_del(&qp->node); @@ -124,21 +122,13 @@ static void http_shutdown_client(struct http_client *hc, const char *msg) } list_del(&hc->node); free(hc); - return; } -static void http_shutdown_clients_real(void) -{ - struct http_client *hc, *tmp; - list_for_each_entry_safe(hc, tmp, &clients, node) - http_shutdown_client(hc, "afs request"); -} static void http_shutdown_clients(void) { struct http_client *hc, *tmp; list_for_each_entry_safe(hc, tmp, &clients, node) - if (hc->status == HTTP_STREAMING) - http_shutdown_client(hc, "afs request"); + http_shutdown_client(hc, "vss request"); } static int http_send_msg(struct http_client *hc, const char *msg) @@ -206,9 +196,8 @@ static int send_queued_packets(struct http_client *hc) return 1; } -static void http_send(__a_unused struct audio_format_handler *af, - long unsigned current_chunk, - __a_unused long unsigned chunks_sent, const char *buf, size_t len) +static void http_send( long unsigned current_chunk, + __a_unused long unsigned chunks_sent, const char *buf, size_t len) { struct http_client *hc, *tmp; int ret; @@ -218,14 +207,12 @@ static void http_send(__a_unused struct audio_format_handler *af, hc->status != HTTP_READY_TO_STREAM) continue; if (hc->status == HTTP_READY_TO_STREAM) { - if (af->get_header_info && current_chunk) { + int hlen; + char *hbuf = vss_get_header(&hlen); + if (hbuf && hlen > 0 && current_chunk) { /* need to send header */ - int hlen; - char *buf = af->get_header_info(&hlen); - if (!buf || hlen <= 0) - continue; /* header not yet available */ PARA_INFO_LOG("queueing header: %d\n", hlen); - if (queue_packet(hc, buf, hlen) < 0) + if (queue_packet(hc, hbuf, hlen) < 0) continue; } else PARA_INFO_LOG("%s", "no need to queue header\n"); @@ -267,8 +254,7 @@ static int host_in_access_perm_list(struct http_client *hc) return 0; } -static void http_post_select(__a_unused struct audio_format_handler *af, fd_set *rfds, - fd_set *wfds) +static void http_post_select(fd_set *rfds, fd_set *wfds) { int i = -1, match; struct http_client *hc, *tmp; @@ -337,7 +323,9 @@ static void http_post_select(__a_unused struct audio_format_handler *af, fd_set PARA_INFO_LOG("accepted client #%d: %s (fd %d)\n", numclients, CLIENT_ADDR(hc), hc->fd); numclients++; - list_add(&hc->node, &clients); + para_list_add(&hc->node, &clients); + add_close_on_fork_list(hc->fd); + mark_fd_nonblock(hc->fd); return; err_out: PARA_WARNING_LOG("ignoring connect request from %s (%s)\n", @@ -347,8 +335,7 @@ err_out: free(hc); } -static void http_pre_select(struct audio_format_handler *af, int *max_fileno, - fd_set *rfds, fd_set *wfds) +static void http_pre_select(int *max_fileno, fd_set *rfds, fd_set *wfds) { struct http_client *hc, *tmp; @@ -373,7 +360,7 @@ static void http_pre_select(struct audio_format_handler *af, int *max_fileno, hc->check_w = 1; break; case HTTP_SENT_OK_MSG: - if (!af || !afs_playing()) + if (!vss_playing()) break; /* wait until server starts playing */ para_fd_set(hc->fd, wfds, max_fileno); hc->check_w = 1; @@ -384,12 +371,19 @@ static void http_pre_select(struct audio_format_handler *af, int *max_fileno, static int open_tcp_port(int port) { + int ret; + server_fd = init_tcp_socket(port); if (server_fd < 0) { - http_shutdown_clients_real(); + http_shutdown_clients(); self->status = SENDER_OFF; return server_fd; } + ret = mark_fd_nonblock(server_fd); + if (ret < 0) { + PARA_EMERG_LOG("%s\n", PARA_STRERROR(-ret)); + exit(EXIT_FAILURE); + } self->status = SENDER_ON; add_close_on_fork_list(server_fd); return 1; @@ -410,7 +404,7 @@ static int http_com_off(__a_unused struct sender_command_data *scd) del_close_on_fork_list(server_fd); server_fd = -1; } - http_shutdown_clients_real(); + http_shutdown_clients(); return 1; } @@ -438,7 +432,7 @@ static void add_perm_list_entry(struct sender_command_data *scd) ai->netmask = scd->netmask; PARA_INFO_LOG("adding %s/%i to access list\n", inet_ntoa(ai->addr), ai->netmask); - list_add(&ai->node, &access_perm_list); + para_list_add(&ai->node, &access_perm_list); } static int http_com_deny(struct sender_command_data *scd)