[thirdparty/git.git] / daemon.c

#include "cache.h"
#include "pkt-line.h"
#include <signal.h>
#include <sys/wait.h>
#include <sys/socket.h>
#include <sys/time.h>
#include <netdb.h>
#include <netinet/in.h>
#include <arpa/inet.h>

static int verbose;

static const char daemon_usage[] = "git-daemon [--verbose] [--inetd | --port=n]";


static void logreport(const char *err, va_list params)
{
	/* We should do a single write so that it is atomic and output
	 * of several processes do not get intermingled. */
	char buf[1024];
	int buflen;
	int maxlen, msglen;

	/* sizeof(buf) should be big enough for "[pid] \n" */
	buflen = snprintf(buf, sizeof(buf), "[%ld] ", (long) getpid());

	maxlen = sizeof(buf) - buflen - 1; /* -1 for our own LF */
	msglen = vsnprintf(buf + buflen, maxlen, err, params);

	/* maxlen counted our own LF but also counts space given to
	 * vsnprintf for the terminating NUL.  We want to make sure that
	 * we have space for our own LF and NUL after the "meat" of the
	 * message, so truncate it at maxlen - 1.
	 */
	if (msglen > maxlen - 1)
		msglen = maxlen - 1;
	else if (msglen < 0)
		msglen = 0; /* Protect against weird return values. */
	buflen += msglen;

	buf[buflen++] = '\n';
	buf[buflen] = '\0';

	write(2, buf, buflen);
}

void logerror(const char *err, ...)
{
	va_list params;
	va_start(params, err);
	logreport(err, params);
	va_end(params);
}

void lognotice(const char *err, ...)
{
	va_list params;
	if (!verbose)
		return;
	va_start(params, err);
	logreport(err, params);
	va_end(params);
}


static int upload(char *dir, int dirlen)
{
	lognotice("Request for '%s'", dir);
	if (chdir(dir) < 0) {
		logerror("Cannot chdir('%s'): %s", dir, strerror(errno));
		return -1;
	}
	chdir(".git");

	/*
	 * Security on the cheap.
	 *
	 * We want a readable HEAD, usable "objects" directory, and 
	 * a "git-daemon-export-ok" flag that says that the other side
	 * is ok with us doing this.
	 */
	if (access("git-daemon-export-ok", F_OK) ||
	    access("objects/00", X_OK) ||
	    access("HEAD", R_OK)) {
		logerror("Not a valid gitd-enabled repository: '%s'", dir);
		return -1;
	}

	/*
	 * We'll ignore SIGTERM from now on, we have a
	 * good client.
	 */
	signal(SIGTERM, SIG_IGN);

	/* git-upload-pack only ever reads stuff, so this is safe */
	execlp("git-upload-pack", "git-upload-pack", ".", NULL);
	return -1;
}

static int execute(void)
{
	static char line[1000];
	int len;

	len = packet_read_line(0, line, sizeof(line));

	if (len && line[len-1] == '\n')
		line[--len] = 0;

	if (!strncmp("git-upload-pack /", line, 17))
		return upload(line + 16, len - 16);

	logerror("Protocol error: '%s'", line);
	return -1;
}


/*
 * We count spawned/reaped separately, just to avoid any
 * races when updating them from signals. The SIGCHLD handler
 * will only update children_reaped, and the fork logic will
 * only update children_spawned.
 *
 * MAX_CHILDREN should be a power-of-two to make the modulus
 * operation cheap. It should also be at least twice
 * the maximum number of connections we will ever allow.
 */
#define MAX_CHILDREN 128

static int max_connections = 25;

/* These are updated by the signal handler */
static volatile unsigned int children_reaped = 0;
static pid_t dead_child[MAX_CHILDREN];

/* These are updated by the main loop */
static unsigned int children_spawned = 0;
static unsigned int children_deleted = 0;

static struct child {
	pid_t pid;
	int addrlen;
	struct sockaddr_storage address;
} live_child[MAX_CHILDREN];

static void add_child(int idx, pid_t pid, struct sockaddr *addr, int addrlen)
{
	live_child[idx].pid = pid;
	live_child[idx].addrlen = addrlen;
	memcpy(&live_child[idx].address, addr, addrlen);
}

/*
 * Walk from "deleted" to "spawned", and remove child "pid".
 *
 * We move everything up by one, since the new "deleted" will
 * be one higher.
 */
static void remove_child(pid_t pid, unsigned deleted, unsigned spawned)
{
	struct child n;

	deleted %= MAX_CHILDREN;
	spawned %= MAX_CHILDREN;
	if (live_child[deleted].pid == pid) {
		live_child[deleted].pid = -1;
		return;
	}
	n = live_child[deleted];
	for (;;) {
		struct child m;
		deleted = (deleted + 1) % MAX_CHILDREN;
		if (deleted == spawned)
			die("could not find dead child %d\n", pid);
		m = live_child[deleted];
		live_child[deleted] = n;
		if (m.pid == pid)
			return;
		n = m;
	}
}

/*
 * This gets called if the number of connections grows
 * past "max_connections".
 *
 * We _should_ start off by searching for connections
 * from the same IP, and if there is some address wth
 * multiple connections, we should kill that first.
 *
 * As it is, we just "randomly" kill 25% of the connections,
 * and our pseudo-random generator sucks too. I have no
 * shame.
 *
 * Really, this is just a place-holder for a _real_ algorithm.
 */
static void kill_some_children(int signo, unsigned start, unsigned stop)
{
	start %= MAX_CHILDREN;
	stop %= MAX_CHILDREN;
	while (start != stop) {
		if (!(start & 3))
			kill(live_child[start].pid, signo);
		start = (start + 1) % MAX_CHILDREN;
	}
}

static void check_max_connections(void)
{
	for (;;) {
		int active;
		unsigned spawned, reaped, deleted;

		spawned = children_spawned;
		reaped = children_reaped;
		deleted = children_deleted;

		while (deleted < reaped) {
			pid_t pid = dead_child[deleted % MAX_CHILDREN];
			remove_child(pid, deleted, spawned);
			deleted++;
		}
		children_deleted = deleted;

		active = spawned - deleted;
		if (active <= max_connections)
			break;

		/* Kill some unstarted connections with SIGTERM */
		kill_some_children(SIGTERM, deleted, spawned);
		if (active <= max_connections << 1)
			break;

		/* If the SIGTERM thing isn't helping use SIGKILL */
		kill_some_children(SIGKILL, deleted, spawned);
		sleep(1);
	}
}

static void handle(int incoming, struct sockaddr *addr, int addrlen)
{
	pid_t pid = fork();
	char addrbuf[256] = "";
	int port = -1;

	if (pid) {
		unsigned idx;

		close(incoming);
		if (pid < 0)
			return;

		idx = children_spawned % MAX_CHILDREN;
		children_spawned++;
		add_child(idx, pid, addr, addrlen);

		check_max_connections();
		return;
	}

	dup2(incoming, 0);
	dup2(incoming, 1);
	close(incoming);

	if (addr->sa_family == AF_INET) {
		struct sockaddr_in *sin_addr = (void *) addr;
		inet_ntop(AF_INET, &sin_addr->sin_addr, addrbuf, sizeof(addrbuf));
		port = sin_addr->sin_port;

	} else if (addr->sa_family == AF_INET6) {
		struct sockaddr_in6 *sin6_addr = (void *) addr;

		char *buf = addrbuf;
		*buf++ = '['; *buf = '\0'; /* stpcpy() is cool */
		inet_ntop(AF_INET6, &sin6_addr->sin6_addr, buf, sizeof(addrbuf) - 1);
		strcat(buf, "]");

		port = sin6_addr->sin6_port;
	}
	lognotice("Connection from %s:%d", addrbuf, port);

	exit(execute());
}

static void child_handler(int signo)
{
	for (;;) {
		pid_t pid = waitpid(-1, NULL, WNOHANG);

		if (pid > 0) {
			unsigned reaped = children_reaped;
			dead_child[reaped % MAX_CHILDREN] = pid;
			children_reaped = reaped + 1;
			/* XXX: Custom logging, since we don't wanna getpid() */
			if (verbose)
				fprintf(stderr, "[%d] Disconnected\n", pid);
			continue;
		}
		break;
	}
}

static int serve(int port)
{
	struct addrinfo hints, *ai0, *ai;
	int gai;
	int socknum = 0, *socklist = NULL;
	int maxfd = -1;
	fd_set fds_init, fds;
	char pbuf[NI_MAXSERV];

	signal(SIGCHLD, child_handler);

	sprintf(pbuf, "%d", port);
	memset(&hints, 0, sizeof(hints));
	hints.ai_family = AF_UNSPEC;
	hints.ai_socktype = SOCK_STREAM;
	hints.ai_protocol = IPPROTO_TCP;
	hints.ai_flags = AI_PASSIVE;

	gai = getaddrinfo(NULL, pbuf, &hints, &ai0);
	if (gai)
		die("getaddrinfo() failed: %s\n", gai_strerror(gai));

	FD_ZERO(&fds_init);

	for (ai = ai0; ai; ai = ai->ai_next) {
		int sockfd;
		int *newlist;

		sockfd = socket(ai->ai_family, ai->ai_socktype, ai->ai_protocol);
		if (sockfd < 0)
			continue;
		if (sockfd >= FD_SETSIZE) {
			error("too large socket descriptor.");
			close(sockfd);
			continue;
		}

#ifdef IPV6_V6ONLY
		if (ai->ai_family == AF_INET6) {
			int on = 1;
			setsockopt(sockfd, IPPROTO_IPV6, IPV6_V6ONLY,
				   &on, sizeof(on));
			/* Note: error is not fatal */
		}
#endif

		if (bind(sockfd, ai->ai_addr, ai->ai_addrlen) < 0) {
			close(sockfd);
			continue;	/* not fatal */
		}
		if (listen(sockfd, 5) < 0) {
			close(sockfd);
			continue;	/* not fatal */
		}

		newlist = realloc(socklist, sizeof(int) * (socknum + 1));
		if (!newlist)
			die("memory allocation failed: %s", strerror(errno));

		socklist = newlist;
		socklist[socknum++] = sockfd;

		FD_SET(sockfd, &fds_init);
		if (maxfd < sockfd)
			maxfd = sockfd;
	}

	freeaddrinfo(ai0);

	if (socknum == 0)
		die("unable to allocate any listen sockets on port %u", port);

	for (;;) {
		int i;
		fds = fds_init;
		
		if (select(maxfd + 1, &fds, NULL, NULL, NULL) < 0) {
			if (errno != EINTR) {
				error("select failed, resuming: %s",
				      strerror(errno));
				sleep(1);
			}
			continue;
		}

		for (i = 0; i < socknum; i++) {
			int sockfd = socklist[i];

			if (FD_ISSET(sockfd, &fds)) {
				struct sockaddr_storage ss;
				int sslen = sizeof(ss);
				int incoming = accept(sockfd, (struct sockaddr *)&ss, &sslen);
				if (incoming < 0) {
					switch (errno) {
					case EAGAIN:
					case EINTR:
					case ECONNABORTED:
						continue;
					default:
						die("accept returned %s", strerror(errno));
					}
				}
				handle(incoming, (struct sockaddr *)&ss, sslen);
			}
		}
	}
}

int main(int argc, char **argv)
{
	int port = DEFAULT_GIT_PORT;
	int inetd_mode = 0;
	int i;

	for (i = 1; i < argc; i++) {
		char *arg = argv[i];

		if (!strncmp(arg, "--port=", 7)) {
			char *end;
			unsigned long n;
			n = strtoul(arg+7, &end, 0);
			if (arg[7] && !*end) {
				port = n;
				continue;
			}
		}

		if (!strcmp(arg, "--inetd")) {
			inetd_mode = 1;
			continue;
		}
		if (!strcmp(arg, "--verbose")) {
			verbose = 1;
			continue;
		}

		usage(daemon_usage);
	}

	if (inetd_mode) {
		fclose(stderr); //FIXME: workaround
		return execute();
	}

	return serve(port);
}
Commit	Line	Data
a87e8be2 LT	1	#include "cache.h"
a87e8be2 LT	2	#include "pkt-line.h"
eaa94919 LT	3	#include <signal.h>
eaa94919 LT	4	#include <sys/wait.h>
a87e8be2	5	#include <sys/socket.h>
3cd6ecda	6	#include <sys/time.h>
df076bdb	7	#include <netdb.h>
a87e8be2	8	#include <netinet/in.h>
f8ff0c06 PB	9	#include <arpa/inet.h>
	10
	11	static int verbose;
	12
	13	static const char daemon_usage[] = "git-daemon [--verbose] [--inetd \| --port=n]";
	14
	15
	16	static void logreport(const char *err, va_list params)
	17	{
	18	/* We should do a single write so that it is atomic and output
	19	* of several processes do not get intermingled. */
	20	char buf[1024];
	21	int buflen;
	22	int maxlen, msglen;
	23
	24	/* sizeof(buf) should be big enough for "[pid] \n" */
1bedd4ca	25	buflen = snprintf(buf, sizeof(buf), "[%ld] ", (long) getpid());
f8ff0c06 PB	26
	27	maxlen = sizeof(buf) - buflen - 1; /* -1 for our own LF */
	28	msglen = vsnprintf(buf + buflen, maxlen, err, params);
	29
	30	/* maxlen counted our own LF but also counts space given to
	31	* vsnprintf for the terminating NUL. We want to make sure that
	32	* we have space for our own LF and NUL after the "meat" of the
	33	* message, so truncate it at maxlen - 1.
	34	*/
	35	if (msglen > maxlen - 1)
	36	msglen = maxlen - 1;
	37	else if (msglen < 0)
	38	msglen = 0; /* Protect against weird return values. */
	39	buflen += msglen;
	40
	41	buf[buflen++] = '\n';
	42	buf[buflen] = '\0';
	43
	44	write(2, buf, buflen);
	45	}
	46
	47	void logerror(const char *err, ...)
	48	{
	49	va_list params;
	50	va_start(params, err);
	51	logreport(err, params);
	52	va_end(params);
	53	}
	54
	55	void lognotice(const char *err, ...)
	56	{
	57	va_list params;
	58	if (!verbose)
	59	return;
	60	va_start(params, err);
	61	logreport(err, params);
	62	va_end(params);
	63	}
a87e8be2	64
a87e8be2 LT	65
	66	static int upload(char *dir, int dirlen)
	67	{
f8ff0c06 PB	68	lognotice("Request for '%s'", dir);
	69	if (chdir(dir) < 0) {
	70	logerror("Cannot chdir('%s'): %s", dir, strerror(errno));
a87e8be2	71	return -1;
f8ff0c06	72	}
a87e8be2 LT	73	chdir(".git");
	74
	75	/*
	76	* Security on the cheap.
	77	*
	78	* We want a readable HEAD, usable "objects" directory, and
	79	* a "git-daemon-export-ok" flag that says that the other side
	80	* is ok with us doing this.
	81	*/
	82	if (access("git-daemon-export-ok", F_OK) \|\|
	83	access("objects/00", X_OK) \|\|
f8ff0c06 PB	84	access("HEAD", R_OK)) {
f8ff0c06 PB	85	logerror("Not a valid gitd-enabled repository: '%s'", dir);
a87e8be2	86	return -1;
f8ff0c06	87	}
a87e8be2	88
02d57da4 LT	89	/*
	90	* We'll ignore SIGTERM from now on, we have a
	91	* good client.
	92	*/
	93	signal(SIGTERM, SIG_IGN);
	94
a87e8be2 LT	95	/* git-upload-pack only ever reads stuff, so this is safe */
	96	execlp("git-upload-pack", "git-upload-pack", ".", NULL);
	97	return -1;
	98	}
	99
7d80694a	100	static int execute(void)
a87e8be2	101	{
7d80694a LT	102	static char line[1000];
	103	int len;
	104
	105	len = packet_read_line(0, line, sizeof(line));
	106
	107	if (len && line[len-1] == '\n')
	108	line[--len] = 0;
	109
a87e8be2 LT	110	if (!strncmp("git-upload-pack /", line, 17))
	111	return upload(line + 16, len - 16);
	112
f8ff0c06	113	logerror("Protocol error: '%s'", line);
a87e8be2 LT	114	return -1;
	115	}
	116
66e631de LT	117
	118	/*
	119	* We count spawned/reaped separately, just to avoid any
	120	* races when updating them from signals. The SIGCHLD handler
	121	* will only update children_reaped, and the fork logic will
	122	* only update children_spawned.
	123	*
	124	* MAX_CHILDREN should be a power-of-two to make the modulus
	125	* operation cheap. It should also be at least twice
	126	* the maximum number of connections we will ever allow.
	127	*/
	128	#define MAX_CHILDREN 128
	129
	130	static int max_connections = 25;
	131
	132	/* These are updated by the signal handler */
	133	static volatile unsigned int children_reaped = 0;
4d8fa916	134	static pid_t dead_child[MAX_CHILDREN];
66e631de LT	135
	136	/* These are updated by the main loop */
	137	static unsigned int children_spawned = 0;
	138	static unsigned int children_deleted = 0;
	139
4d8fa916	140	static struct child {
66e631de	141	pid_t pid;
7fa09084	142	int addrlen;
df076bdb	143	struct sockaddr_storage address;
66e631de LT	144	} live_child[MAX_CHILDREN];
66e631de LT	145
7fa09084	146	static void add_child(int idx, pid_t pid, struct sockaddr *addr, int addrlen)
66e631de LT	147	{
	148	live_child[idx].pid = pid;
	149	live_child[idx].addrlen = addrlen;
df076bdb	150	memcpy(&live_child[idx].address, addr, addrlen);
66e631de LT	151	}
	152
	153	/*
	154	* Walk from "deleted" to "spawned", and remove child "pid".
	155	*
	156	* We move everything up by one, since the new "deleted" will
	157	* be one higher.
	158	*/
	159	static void remove_child(pid_t pid, unsigned deleted, unsigned spawned)
	160	{
	161	struct child n;
	162
	163	deleted %= MAX_CHILDREN;
	164	spawned %= MAX_CHILDREN;
	165	if (live_child[deleted].pid == pid) {
	166	live_child[deleted].pid = -1;
	167	return;
	168	}
	169	n = live_child[deleted];
	170	for (;;) {
	171	struct child m;
	172	deleted = (deleted + 1) % MAX_CHILDREN;
	173	if (deleted == spawned)
	174	die("could not find dead child %d\n", pid);
	175	m = live_child[deleted];
	176	live_child[deleted] = n;
	177	if (m.pid == pid)
	178	return;
	179	n = m;
	180	}
	181	}
	182
	183	/*
	184	* This gets called if the number of connections grows
	185	* past "max_connections".
	186	*
	187	* We _should_ start off by searching for connections
	188	* from the same IP, and if there is some address wth
	189	* multiple connections, we should kill that first.
	190	*
	191	* As it is, we just "randomly" kill 25% of the connections,
	192	* and our pseudo-random generator sucks too. I have no
	193	* shame.
	194	*
	195	* Really, this is just a place-holder for a _real_ algorithm.
	196	*/
02d57da4	197	static void kill_some_children(int signo, unsigned start, unsigned stop)
66e631de LT	198	{
	199	start %= MAX_CHILDREN;
	200	stop %= MAX_CHILDREN;
	201	while (start != stop) {
	202	if (!(start & 3))
02d57da4	203	kill(live_child[start].pid, signo);
66e631de LT	204	start = (start + 1) % MAX_CHILDREN;
	205	}
	206	}
	207
02d57da4	208	static void check_max_connections(void)
a87e8be2	209	{
02d57da4	210	for (;;) {
eaa94919	211	int active;
66e631de	212	unsigned spawned, reaped, deleted;
eaa94919	213
66e631de	214	spawned = children_spawned;
66e631de LT	215	reaped = children_reaped;
	216	deleted = children_deleted;
	217
	218	while (deleted < reaped) {
	219	pid_t pid = dead_child[deleted % MAX_CHILDREN];
	220	remove_child(pid, deleted, spawned);
	221	deleted++;
	222	}
	223	children_deleted = deleted;
	224
	225	active = spawned - deleted;
02d57da4 LT	226	if (active <= max_connections)
02d57da4 LT	227	break;
66e631de	228
02d57da4 LT	229	/* Kill some unstarted connections with SIGTERM */
	230	kill_some_children(SIGTERM, deleted, spawned);
	231	if (active <= max_connections << 1)
	232	break;
	233
	234	/* If the SIGTERM thing isn't helping use SIGKILL */
	235	kill_some_children(SIGKILL, deleted, spawned);
	236	sleep(1);
	237	}
	238	}
	239
7fa09084	240	static void handle(int incoming, struct sockaddr *addr, int addrlen)
02d57da4 LT	241	{
02d57da4 LT	242	pid_t pid = fork();
f8ff0c06 PB	243	char addrbuf[256] = "";
f8ff0c06 PB	244	int port = -1;
02d57da4 LT	245
	246	if (pid) {
	247	unsigned idx;
	248
	249	close(incoming);
	250	if (pid < 0)
	251	return;
	252
	253	idx = children_spawned % MAX_CHILDREN;
	254	children_spawned++;
	255	add_child(idx, pid, addr, addrlen);
66e631de	256
02d57da4	257	check_max_connections();
a87e8be2 LT	258	return;
	259	}
	260
	261	dup2(incoming, 0);
	262	dup2(incoming, 1);
	263	close(incoming);
f8ff0c06 PB	264
	265	if (addr->sa_family == AF_INET) {
	266	struct sockaddr_in sin_addr = (void ) addr;
	267	inet_ntop(AF_INET, &sin_addr->sin_addr, addrbuf, sizeof(addrbuf));
	268	port = sin_addr->sin_port;
	269
	270	} else if (addr->sa_family == AF_INET6) {
	271	struct sockaddr_in6 sin6_addr = (void ) addr;
	272
	273	char *buf = addrbuf;
	274	buf++ = '['; buf = '\0'; /* stpcpy() is cool */
	275	inet_ntop(AF_INET6, &sin6_addr->sin6_addr, buf, sizeof(addrbuf) - 1);
	276	strcat(buf, "]");
	277
	278	port = sin6_addr->sin6_port;
	279	}
	280	lognotice("Connection from %s:%d", addrbuf, port);
	281
7d80694a	282	exit(execute());
a87e8be2 LT	283	}
a87e8be2 LT	284
eaa94919 LT	285	static void child_handler(int signo)
	286	{
	287	for (;;) {
66e631de LT	288	pid_t pid = waitpid(-1, NULL, WNOHANG);
	289
	290	if (pid > 0) {
	291	unsigned reaped = children_reaped;
	292	dead_child[reaped % MAX_CHILDREN] = pid;
	293	children_reaped = reaped + 1;
f8ff0c06 PB	294	/* XXX: Custom logging, since we don't wanna getpid() */
	295	if (verbose)
	296	fprintf(stderr, "[%d] Disconnected\n", pid);
eaa94919 LT	297	continue;
	298	}
	299	break;
	300	}
	301	}
	302
a87e8be2 LT	303	static int serve(int port)
a87e8be2 LT	304	{
df076bdb YH	305	struct addrinfo hints, ai0, ai;
	306	int gai;
	307	int socknum = 0, *socklist = NULL;
	308	int maxfd = -1;
	309	fd_set fds_init, fds;
	310	char pbuf[NI_MAXSERV];
a87e8be2	311
eaa94919	312	signal(SIGCHLD, child_handler);
df076bdb YH	313
	314	sprintf(pbuf, "%d", port);
	315	memset(&hints, 0, sizeof(hints));
	316	hints.ai_family = AF_UNSPEC;
	317	hints.ai_socktype = SOCK_STREAM;
	318	hints.ai_protocol = IPPROTO_TCP;
	319	hints.ai_flags = AI_PASSIVE;
	320
	321	gai = getaddrinfo(NULL, pbuf, &hints, &ai0);
	322	if (gai)
	323	die("getaddrinfo() failed: %s\n", gai_strerror(gai));
	324
	325	FD_ZERO(&fds_init);
	326
	327	for (ai = ai0; ai; ai = ai->ai_next) {
	328	int sockfd;
	329	int *newlist;
	330
	331	sockfd = socket(ai->ai_family, ai->ai_socktype, ai->ai_protocol);
	332	if (sockfd < 0)
	333	continue;
	334	if (sockfd >= FD_SETSIZE) {
	335	error("too large socket descriptor.");
	336	close(sockfd);
	337	continue;
	338	}
	339
	340	#ifdef IPV6_V6ONLY
	341	if (ai->ai_family == AF_INET6) {
	342	int on = 1;
	343	setsockopt(sockfd, IPPROTO_IPV6, IPV6_V6ONLY,
	344	&on, sizeof(on));
	345	/* Note: error is not fatal */
	346	}
	347	#endif
	348
	349	if (bind(sockfd, ai->ai_addr, ai->ai_addrlen) < 0) {
	350	close(sockfd);
	351	continue; /* not fatal */
	352	}
	353	if (listen(sockfd, 5) < 0) {
	354	close(sockfd);
	355	continue; /* not fatal */
	356	}
	357
	358	newlist = realloc(socklist, sizeof(int) * (socknum + 1));
	359	if (!newlist)
	360	die("memory allocation failed: %s", strerror(errno));
	361
	362	socklist = newlist;
	363	socklist[socknum++] = sockfd;
	364
	365	FD_SET(sockfd, &fds_init);
	366	if (maxfd < sockfd)
	367	maxfd = sockfd;
	368	}
	369
	370	freeaddrinfo(ai0);
	371
	372	if (socknum == 0)
	373	die("unable to allocate any listen sockets on port %u", port);
a87e8be2 LT	374
a87e8be2 LT	375	for (;;) {
df076bdb YH	376	int i;
	377	fds = fds_init;
	378
	379	if (select(maxfd + 1, &fds, NULL, NULL, NULL) < 0) {
1eef0b33 JH	380	if (errno != EINTR) {
	381	error("select failed, resuming: %s",
	382	strerror(errno));
	383	sleep(1);
	384	}
df076bdb YH	385	continue;
	386	}
	387
	388	for (i = 0; i < socknum; i++) {
	389	int sockfd = socklist[i];
	390
	391	if (FD_ISSET(sockfd, &fds)) {
	392	struct sockaddr_storage ss;
7fa09084	393	int sslen = sizeof(ss);
df076bdb YH	394	int incoming = accept(sockfd, (struct sockaddr *)&ss, &sslen);
	395	if (incoming < 0) {
	396	switch (errno) {
	397	case EAGAIN:
	398	case EINTR:
	399	case ECONNABORTED:
	400	continue;
	401	default:
	402	die("accept returned %s", strerror(errno));
	403	}
	404	}
	405	handle(incoming, (struct sockaddr *)&ss, sslen);
a87e8be2 LT	406	}
a87e8be2 LT	407	}
a87e8be2 LT	408	}
	409	}
	410
	411	int main(int argc, char **argv)
	412	{
	413	int port = DEFAULT_GIT_PORT;
e64e1b79	414	int inetd_mode = 0;
a87e8be2 LT	415	int i;
	416
	417	for (i = 1; i < argc; i++) {
	418	char *arg = argv[i];
	419
	420	if (!strncmp(arg, "--port=", 7)) {
	421	char *end;
	422	unsigned long n;
	423	n = strtoul(arg+7, &end, 0);
	424	if (arg[7] && !*end) {
	425	port = n;
	426	continue;
	427	}
	428	}
e64e1b79 LT	429
	430	if (!strcmp(arg, "--inetd")) {
	431	inetd_mode = 1;
	432	continue;
	433	}
f8ff0c06 PB	434	if (!strcmp(arg, "--verbose")) {
	435	verbose = 1;
	436	continue;
	437	}
e64e1b79	438
a87e8be2 LT	439	usage(daemon_usage);
	440	}
	441
7c3693f1 LD	442	if (inetd_mode) {
7c3693f1 LD	443	fclose(stderr); //FIXME: workaround
e64e1b79	444	return execute();
7c3693f1	445	}
e64e1b79	446
a87e8be2 LT	447	return serve(port);
a87e8be2 LT	448	}