2 * Copyright (C) 2006 Andre Noll <maan@systemlinux.org>
4 * This program is free software; you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License as published by
6 * the Free Software Foundation; either version 2 of the License, or
7 * (at your option) any later version.
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
14 * You should have received a copy of the GNU General Public License
15 * along with this program; if not, write to the Free Software
16 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111, USA.
20 * based on server.c of dccp-cs-0.01.tar.bz2,
21 * (C) 2005 Ian McDonald <imcdnzl@gmail.com>
32 #include "server.cmdline.h"
33 extern struct gengetopt_args_info conf
;
34 /** the list of connected clients **/
35 static struct list_head clients
;
36 static int listen_fd
= -1;
37 static struct sender
*self
;
39 /** describes one connected client */
41 /** the dccp socket */
43 /** address information about the client */
44 struct sockaddr_in addr
;
45 /** the position of this client in the client list */
46 struct list_head node
;
47 int header_sent
; /* non-zero if audio file header has been sent */
50 static void dccp_pre_select(__unused
struct audio_format
*af
, int *max_fileno
, fd_set
*rfds
,
51 __unused fd_set
*wfds
)
55 FD_SET(listen_fd
, rfds
);
56 *max_fileno
= MAX(*max_fileno
, listen_fd
);
59 static void dccp_post_select(__unused
struct audio_format
*af
, fd_set
*rfds
,
60 __unused fd_set
*wfds
)
62 struct dccp_client
*dc
;
65 if (!FD_ISSET(listen_fd
, rfds
))
67 PARA_NOTICE_LOG("%s", "accepting...\n");
68 dc
= para_calloc(sizeof(struct dccp_client
));
69 ret
= para_accept(listen_fd
, &dc
->addr
, sizeof(struct sockaddr_in
));
71 PARA_ERROR_LOG("%s", PARA_STRERROR(-ret
));
74 PARA_NOTICE_LOG("%s", "connection\n");
76 list_add(&dc
->node
, &clients
);
79 static int dccp_open(void)
81 struct sockaddr_in servaddr
;
84 ret
= dccp_get_socket();
89 bzero(&servaddr
, sizeof(servaddr
));
90 servaddr
.sin_family
= AF_INET
;
91 servaddr
.sin_addr
.s_addr
= htonl(INADDR_ANY
);
92 servaddr
.sin_port
= htons(conf
.dccp_port_arg
);
93 ret
= bind(listen_fd
, (struct sockaddr
*)&servaddr
, sizeof(servaddr
));
96 ret
= dccp_set_socket(listen_fd
);
99 ret
= listen(listen_fd
, 0);
101 return -E_DCCP_LISTEN
;
102 PARA_DEBUG_LOG("listening on fd %d\n", listen_fd
);
106 static void dccp_shutdown_client(struct dccp_client
*dc
)
113 static void dccp_send(__unused
struct audio_format
*af
,
114 long unsigned current_chunk
,
115 __unused
long unsigned chunks_sent
, const char *buf
, size_t len
)
117 struct dccp_client
*dc
, *tmp
;
121 if (listen_fd
< 0 || !len
)
124 list_for_each_entry_safe(dc
, tmp
, &clients
, node
) {
125 if (!_write_ok(dc
->fd
))
127 if (!dc
->header_sent
&& af
->get_header_info
&& current_chunk
) {
128 header_buf
= af
->get_header_info(&header_len
);
129 if (!header_buf
|| header_len
<= 0)
130 continue; /* header not yet available */
131 ret
= write(dc
->fd
, header_buf
, header_len
);
132 if (ret
!= header_len
) {
133 dccp_shutdown_client(dc
);
136 if (!_write_ok(dc
->fd
))
139 // PARA_DEBUG_LOG("writing %d bytes to fd %d\n", len, dc->fd);
140 ret
= write(dc
->fd
, buf
, len
);
142 dccp_shutdown_client(dc
);
146 static void dccp_shutdown_clients(void)
148 struct dccp_client
*dc
, *tmp
;
150 list_for_each_entry_safe(dc
, tmp
, &clients
, node
)
151 dccp_shutdown_client(dc
);
154 static char *dccp_info(void)
158 struct dccp_client
*dc
, *tmp
;
161 list_for_each_entry_safe(dc
, tmp
, &clients
, node
)
163 buf
= make_message("%d connected clients\n", num_clients
);
167 static char *dccp_help(void)
169 return make_message("no help available\n");
172 void dccp_send_init(struct sender
*s
)
176 INIT_LIST_HEAD(&clients
);
179 s
->pre_select
= dccp_pre_select
;
180 s
->post_select
= dccp_post_select
;
181 s
->shutdown_clients
= dccp_shutdown_clients
;
183 s
->client_cmds
[SENDER_ON
] = NULL
;
184 s
->client_cmds
[SENDER_OFF
] = NULL
;
185 s
->client_cmds
[SENDER_DENY
] = NULL
;
186 s
->client_cmds
[SENDER_ALLOW
] = NULL
;
187 s
->client_cmds
[SENDER_ADD
] = NULL
;
188 s
->client_cmds
[SENDER_DELETE
] = NULL
;
192 PARA_ERROR_LOG("%s\n", PARA_STRERROR(-ret
));
194 s
->status
= SENDER_ON
;