+++ /dev/null
-Copyright (c) 2006 Verdens Gang AS
-Copyright (c) 2006 Linpro AS
-All rights reserved.
-
-Redistribution and use in source and binary forms, with or without
-modification, are permitted provided that the following conditions
-are met:
-1. Redistributions of source code must retain the above copyright
- notice, this list of conditions and the following disclaimer.
-2. Redistributions in binary form must reproduce the above copyright
- notice, this list of conditions and the following disclaimer in the
- documentation and/or other materials provided with the distribution.
-
-THIS SOFTWARE IS PROVIDED BY AUTHOR AND CONTRIBUTORS ``AS IS'' AND
-ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
-IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
-ARE DISCLAIMED. IN NO EVENT SHALL AUTHOR OR CONTRIBUTORS BE LIABLE
-FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
-DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
-OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
-HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
-LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
-OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
-SUCH DAMAGE.
+++ /dev/null
-# $Id$
-
-bin_PROGRAMS = varnish
-
-varnish_SOURCES = \
- connection.c \
- listener.c \
- log.c \
- request.c \
- system-common.c \
- system-@target_os@.c \
- varnish.c
+++ /dev/null
-#!/bin/sh
-#
-# $Id$
-#
-
-aclocal
-autoheader
-automake --add-missing --copy --force --foreign
-autoconf
+++ /dev/null
-# $Id$
-
-AC_PREREQ(2.59)
-AC_COPYRIGHT([Copyright (c) 2006 Linpro AS])
-AC_REVISION([$Id$])
-AC_INIT([Varnish], [0.1], [varnish-dev@projects.linpro.no])
-AC_CONFIG_SRCDIR([varnish.c])
-AC_CONFIG_HEADER([config.h])
-
-AC_CANONICAL_SYSTEM
-AC_LANG(C)
-
-AM_INIT_AUTOMAKE(AC_PACKAGE_NAME, AC_PACKAGE_VERSION)
-
-# Compiler flags (assume GCC).
-# This section *must* come before AC_PROG_CC / AC_PROG_CPP.
-CFLAGS="${CFLAGS:--O2}"
-AC_ARG_ENABLE(wall,
- AS_HELP_STRING([--enable-wall],[use -Wall (default is NO)]),
- CFLAGS="${CFLAGS} -Wall")
-AC_ARG_ENABLE(pedantic,
- AS_HELP_STRING([--enable-pedantic],[enable pedantic warnings (default is NO)]),
- CFLAGS="${CFLAGS} -pedantic")
-AC_ARG_ENABLE(werror,
- AS_HELP_STRING([--enable-werror],[use -Werror (default is NO)]),
- CFLAGS="${CFLAGS} -Werror")
-
-# Checks for programs.
-AC_PROG_CC
-AC_PROG_CPP
-AC_PROG_INSTALL
-AC_PROG_MAKE_SET
-
-# Checks for libraries.
-
-# Checks for header files.
-AC_HEADER_STDC
-AC_HEADER_SYS_WAIT
-AC_HEADER_TIME
-AC_CHECK_HEADERS([sys/socket.h])
-AC_CHECK_HEADERS([netinet/in.h])
-AC_CHECK_HEADERS([stddef.h])
-AC_CHECK_HEADERS([stdlib.h])
-AC_CHECK_HEADERS([unistd.h])
-
-# Checks for typedefs, structures, and compiler characteristics.
-AC_C_CONST
-AC_CHECK_MEMBERS([struct sockaddr.sa_len],,,[
-#include <sys/types.h>
-#ifdef HAVE_SYS_SOCKET_H
-#include <sys/socket.h>
-#endif
-])
-
-# Checks for library functions.
-AC_TYPE_SIGNAL
-AC_TYPE_SIZE_T
-AC_FUNC_VPRINTF
-AC_CHECK_FUNCS([strerror])
-AC_FUNC_STRERROR_R
-AC_CHECK_FUNCS([socket])
-
-AC_CONFIG_FILES([
- Makefile
-])
-AC_OUTPUT
+++ /dev/null
-/*
- * $Id$
- */
-
-#include <sys/types.h>
-#include <sys/socket.h>
-
-#include <netinet/in.h>
-
-#include <stdlib.h>
-#include <unistd.h>
-
-#include "varnish.h"
-#include "log.h"
-#include "connection.h"
-
-struct connection {
- int sd;
- struct sockaddr_storage addr;
-};
-
-/*
- * Accepts a connection from the provided listening descriptor. Does not
- * loop to handle EINTR or other similar conditions.
- */
-connection_t *
-connection_accept(int ld)
-{
- connection_t *c;
- socklen_t len;
-
- if ((c = calloc(1, sizeof *c)) == NULL)
- return (NULL);
-
- len = sizeof c->addr;
- if ((c->sd = accept(ld, (struct sockaddr *)&c->addr, &len)) == -1) {
- free(c);
- return (NULL);
- }
- switch (c->addr.ss_family) {
-#if defined(AF_INET6)
- case AF_INET6: {
- struct sockaddr_in6 *addr =
- (struct sockaddr_in6 *)&c->addr;
- uint16_t *ip = (uint16_t *)&addr->sin6_addr;
-
- log_info("%s(): [%04x:%04x:%04x:%04x:%04x:%04x:%04x:%04x]:%u",
- __func__,
- ntohs(ip[0]), ntohs(ip[1]),
- ntohs(ip[2]), ntohs(ip[3]),
- ntohs(ip[4]), ntohs(ip[5]),
- ntohs(ip[6]), ntohs(ip[7]),
- ntohs(addr->sin6_port));
- break;
- }
-#endif
- case AF_INET: {
- struct sockaddr_in *addr =
- (struct sockaddr_in *)&c->addr;
- uint8_t *ip = (uint8_t *)&addr->sin_addr;
-
- log_info("%s(): %u.%u.%u.%u:%u",
- __func__,
- ip[0], ip[1], ip[2], ip[3],
- ntohs(addr->sin_port));
- break;
- }
- default:
- LOG_UNREACHABLE();
- }
- return (c);
-}
-
-void
-connection_destroy(struct connection *c)
-{
- close(c->sd);
- /* bzero(c, sizeof *c); */
- free(c);
-}
+++ /dev/null
-/*
- * $Id$
- */
-
-#ifndef CONNECTION_H_INCLUDED
-#define CONNECTION_H_INCLUDED
-
-typedef struct connection connection_t;
-
-connection_t *connection_accept(int ld);
-void connection_destroy(connection_t *c);
-
-#endif
+++ /dev/null
-/*
- * $Id$
- */
-
-#include <sys/types.h>
-#include <sys/socket.h>
-
-#include <netinet/in.h>
-
-#include <errno.h>
-#include <stddef.h>
-#include <stdlib.h>
-#include <unistd.h>
-
-#include "varnish.h"
-#include "connection.h"
-#include "listener.h"
-#include "log.h"
-
-struct listener {
- int sd;
- struct sockaddr_storage addr;
-};
-
-/*
- * Create a socket that listens on the specified port. We use an IPv6 TCP
- * socket and clear the IPV6_V6ONLY option to accept IPv4 connections on
- * the same socket.
- */
-struct listener *
-listener_create(int port)
-{
- struct listener *l;
- socklen_t addr_len;
- int zero = 0;
-
- l = calloc(1, sizeof *l);
- if (l == NULL) {
- log_syserr("calloc()");
- return (NULL);
- }
- l->sd = -1;
-#if defined(AF_INET6) && defined(IPV6_V6ONLY)
- if ((l->sd = socket(AF_INET6, SOCK_STREAM, 0)) > 0) {
- struct sockaddr_in6 *addr = (struct sockaddr_in6 *)&l->addr;
-#ifdef HAVE_STRUCT_SOCKADDR_SA_LEN
- addr->sin6_len =
-#endif
- addr_len = sizeof *addr;
- addr->sin6_family = AF_INET6;
- addr->sin6_port = htons(port);
- if (setsockopt(l->sd, IPPROTO_IPV6, IPV6_V6ONLY, &zero, sizeof zero) != 0) {
- log_syserr("setsockopt()");
- return (NULL);
- }
- } else if (errno != EPROTONOSUPPORT) {
- log_syserr("socket()");
- return (NULL);
- } else
-#endif
- if ((l->sd = socket(AF_INET, SOCK_STREAM, 0)) > 0) {
- struct sockaddr_in *addr = (struct sockaddr_in *)&l->addr;
-#ifdef HAVE_STRUCT_SOCKADDR_SA_LEN
- addr->sin_len =
-#endif
- addr_len = sizeof *addr;
- addr->sin_family = AF_INET;
- addr->sin_port = htons(port);
- } else {
- log_syserr("socket()");
- return (NULL);
- }
- if (bind(l->sd, (struct sockaddr *)&l->addr, addr_len) != 0) {
- log_syserr("bind()");
- return (NULL);
- }
- if (listen(l->sd, 16) != 0) {
- log_syserr("listen()");
- return (NULL);
- }
- return (l);
-}
-
-void
-listener_destroy(struct listener *l)
-{
- close(l->sd);
- /* bzero(l, sizeof *l); */
- free(l);
-}
-
-connection_t *
-listener_accept(struct listener *l)
-{
- connection_t *c;
-
- for (;;) {
- if ((c = connection_accept(l->sd)) != NULL)
- return (c);
- if (errno != EINTR) {
- log_syserr("accept()");
- free(c);
- return (NULL);
- }
- }
-}
+++ /dev/null
-/*
- * $Id$
- */
-
-#ifndef LISTENER_H_INCLUDED
-#define LISTENER_H_INCLUDED
-
-#include "connection.h"
-
-typedef struct listener listener_t;
-
-listener_t *listener_create(int port);
-void listener_destroy(listener_t *l);
-connection_t *listener_accept(listener_t *l);
-
-#endif
+++ /dev/null
-/*
- * $Id$
- */
-
-#include <sys/types.h>
-#include <sys/signal.h>
-#include <sys/time.h>
-
-#include <errno.h>
-#include <signal.h>
-#include <stdarg.h>
-#include <stdio.h>
-#include <string.h>
-#ifdef TIME_WITH_SYS_TIME
-#include <time.h>
-#endif
-#include <unistd.h>
-
-#include "varnish.h"
-#include "log.h"
-#include "system.h"
-
-static void
-timestamp(void)
-{
- struct timeval now;
-
- if (gettimeofday(&now, NULL) == -1)
- now.tv_sec = now.tv_usec = 0;
- fprintf(stderr, "%lu.%06lu [%lu] ",
- (unsigned long)now.tv_sec,
- (unsigned long)now.tv_usec,
- (unsigned long)sys.pid);
-}
-
-static void
-emit(const char *fmt, va_list ap)
-{
- timestamp();
- vfprintf(stderr, fmt, ap);
- fprintf(stderr, "\n");
-}
-
-static void
-sysemit(const char *fmt, va_list ap)
-{
- char errstr[64];
-
-#if defined(HAVE_STRERROR_R)
- strerror_r(errno, errstr, sizeof errstr);
-#else
- snprintf(errstr, sizeof errstr, "%s", strerror(errno));
-#endif
- timestamp();
- vfprintf(stderr, fmt, ap);
- fprintf(stderr, ": %s\n", errstr);
-}
-
-static void
-panic(void)
-{
- signal(SIGABRT, SIG_DFL);
- kill(getpid(), SIGABRT);
-}
-
-void
-log_info(const char *fmt, ...)
-{
- va_list ap;
-
- va_start(ap, fmt);
- emit(fmt, ap);
- va_end(ap);
-}
-
-void
-log_err(const char *fmt, ...)
-{
- va_list ap;
-
- va_start(ap, fmt);
- emit(fmt, ap);
- va_end(ap);
-}
-
-void
-log_syserr(const char *fmt, ...)
-{
- va_list ap;
-
- va_start(ap, fmt);
- sysemit(fmt, ap);
- va_end(ap);
-}
-
-void
-log_panic(const char *fmt, ...)
-{
- va_list ap;
-
- va_start(ap, fmt);
- emit(fmt, ap);
- va_end(ap);
- panic();
-}
-
-void
-log_syspanic(const char *fmt, ...)
-{
- va_list ap;
-
- va_start(ap, fmt);
- sysemit(fmt, ap);
- va_end(ap);
- panic();
-}
+++ /dev/null
-/*
- * $Id$
- */
-
-#ifndef LOG_H_INCLUDED
-#define LOG_H_INCLUDED
-
-
-void log_info(const char *fmt, ...);
-void log_err(const char *fmt, ...);
-void log_syserr(const char *fmt, ...);
-void log_panic(const char *fmt, ...);
-void log_syspanic(const char *fmt, ...);
-
-#define LOG_UNREACHABLE() \
- log_panic("%s(%d): %s(): unreachable code reached", \
- __FILE__, __LINE__, __func__)
-
-#endif
+++ /dev/null
-/*
- * $Id$
- */
-
-#include <stdlib.h>
-
-#include "varnish.h"
-#include "connection.h"
-#include "log.h"
-#include "request.h"
-
-struct request {
- connection_t *conn;
-};
-
-request_t *
-request_wait(connection_t *c, unsigned int timeout)
-{
- request_t *r;
-
- r = calloc(1, sizeof *r);
- if (r == NULL) {
- log_syserr("calloc()");
- return (NULL);
- }
-
- /* ... */
-
- return (r);
-}
-
-void
-request_destroy(request_t *r)
-{
- /* bzero(r, sizeof *r); */
- free(r);
-}
+++ /dev/null
-/*
- * $Id$
- */
-
-#ifndef REQUEST_H_INCLUDED
-#define REQUEST_H_INCLUDED
-
-typedef struct request request_t;
-
-request_t *request_wait(connection_t *c, unsigned int timeout);
-void request_destroy(request_t *r);
-
-#endif
+++ /dev/null
-/*
- * $Id$
- */
-
-#include <sys/types.h>
-
-#include <unistd.h>
-
-#include "varnish.h"
-#include "system.h"
-
-system_t sys;
-
-/*
- * gather system information at startup
- */
-void
-system_init(void)
-{
- sys.pid = getpid();
- system_init_ncpu();
-}
-
-/*
- * fork() wrapper, updates sys.pid
- */
-pid_t
-system_fork(void)
-{
- pid_t pid;
-
- if ((pid = fork()) == 0)
- sys.pid = getpid();
- return (pid);
-}
+++ /dev/null
-/*
- * $Id$
- */
-
-#include <sys/types.h>
-#include <sys/sysctl.h>
-
-#include "varnish.h"
-#include "log.h"
-#include "system.h"
-
-void
-system_init_ncpu(void)
-{
- size_t size;
-
- size = sizeof sys.ncpu;
- if (sysctlbyname("hw.ncpu", &sys.ncpu, &size, 0, 0) == -1)
- sys.ncpu = 1;
- log_info("%d cpu(s)", sys.ncpu);
-}
+++ /dev/null
-system-freebsd.c
\ No newline at end of file
+++ /dev/null
-system-freebsd.c
\ No newline at end of file
+++ /dev/null
-system-freebsd.c
\ No newline at end of file
+++ /dev/null
-/*
- * $Id$
- */
-
-#include <sys/types.h>
-
-#include <stdio.h>
-
-#include "varnish.h"
-#include "log.h"
-#include "system.h"
-
-void
-system_init_ncpu(void)
-{
- FILE *cpuinfo;
- char line[256];
- int n;
-
- sys.ncpu = 0;
- if ((cpuinfo = fopen("/proc/cpuinfo", "r")) == NULL)
- return;
- while (fgets(line, sizeof line, cpuinfo) != NULL) {
- if (sscanf(line, "processor : %d", &n) == 1)
- sys.ncpu++;
- }
- fclose(cpuinfo);
- if (sys.ncpu == 0)
- sys.ncpu = 1;
- log_info("%d cpu(s)", sys.ncpu);
-}
+++ /dev/null
-/*
- * $Id$
- */
-
-#ifndef SYSTEM_H_INCLUDED
-#define SYSTEM_H_INCLUDED
-
-typedef struct system system_t;
-
-struct system {
- int ncpu;
- pid_t pid;
-};
-
-extern system_t sys;
-
-void system_init_ncpu(void);
-void system_init(void);
-pid_t system_fork(void);
-
-#endif
+++ /dev/null
-/*
- * $Id$
- */
-
-#include <sys/wait.h>
-
-#include <errno.h>
-#include <stdio.h>
-#include <stdlib.h>
-#include <unistd.h>
-
-#include "varnish.h"
-#include "connection.h"
-#include "listener.h"
-#include "log.h"
-#include "request.h"
-#include "system.h"
-
-static void
-varnish_child(listener_t *l)
-{
- connection_t *c;
- request_t *r;
-
- while ((c = listener_accept(l)) != NULL) {
- r = request_wait(c, 0);
- /* ... */
- request_destroy(r);
- connection_destroy(c);
- }
- LOG_UNREACHABLE();
-}
-
-static void
-varnish(void)
-{
- listener_t *l;
- int i, status;
- pid_t pid;
-
- system_init();
- log_info("starting Varnish");
- l = listener_create(8080);
- for (i = 0; i < sys.ncpu; ++i) {
- switch ((pid = system_fork())) {
- case -1:
- log_panic("fork()");
- break;
- case 0:
- varnish_child(l);
- _exit(1);
- break;
- default:
- log_info("forked child %lu", (unsigned long)pid);
- break;
- }
- }
- for (;;) {
- if ((pid = wait(&status)) == -1) {
- if (errno == ECHILD)
- return;
- } else {
- log_info("child %lu exited", (unsigned long)pid);
- }
- }
-}
-
-static void
-usage(void)
-{
- fprintf(stderr, "usage: varnish\n");
- exit(1);
-}
-
-int
-main(int argc, char *argv[])
-{
- int o;
-
- while ((o = getopt(argc, argv, "")) != -1)
- switch (o) {
- default:
- usage();
- }
-
- argc -= optind;
- argv += optind;
-
- if (argc != 0)
- usage();
-
- varnish();
-
- exit(1);
-}
+++ /dev/null
-/*
- * $Id$
- */
-
-#ifndef VARNISH_H_INCLUDED
-#define VARNISH_H_INCLUDED
-
-#include "config.h"
-
-#endif
projects / varnish / commitdiff