#ifdef HAVE_CVT
-# define ap_ecvt ecvt
-# define ap_fcvt fcvt
-# define ap_gcvt gcvt
+#define ap_ecvt ecvt
+#define ap_fcvt fcvt
+#define ap_gcvt gcvt
#else
#define NDIG 80
static char *
- ap_cvt(double arg, int ndigits, int *decpt, int *sign, int eflag)
+ap_cvt(double arg, int ndigits, int *decpt, int *sign, int eflag)
{
register int r2;
double fi, fj;
}
while (p1 < &buf[NDIG])
*p++ = *p1++;
- }
- else if (arg > 0) {
+ } else if (arg > 0) {
while ((fj = arg * 10) < 1) {
arg = fj;
r2--;
}
static char *
- ap_ecvt(double arg, int ndigits, int *decpt, int *sign)
+ap_ecvt(double arg, int ndigits, int *decpt, int *sign)
{
return (ap_cvt(arg, ndigits, decpt, sign, 1));
}
static char *
- ap_fcvt(double arg, int ndigits, int *decpt, int *sign)
+ap_fcvt(double arg, int ndigits, int *decpt, int *sign)
{
return (ap_cvt(arg, ndigits, decpt, sign, 0));
}
*/
static char *
- ap_gcvt(double number, int ndigit, char *buf)
+ap_gcvt(double number, int ndigit, char *buf)
{
int sign, decpt;
register char *p1, *p2;
if (decpt < 0) {
decpt = -decpt;
*p2++ = '-';
- }
- else
+ } else
*p2++ = '+';
if (decpt / 100 > 0)
*p2++ = decpt / 100 + '0';
if (decpt / 10 > 0)
*p2++ = (decpt % 100) / 10 + '0';
*p2++ = decpt % 10 + '0';
- }
- else {
+ } else {
if (decpt <= 0) {
if (*p1 != '0')
*p2++ = '.';
#define INT_NULL ((int *)0)
#define WIDE_INT long
-typedef WIDE_INT wide_int;
-typedef unsigned WIDE_INT u_wide_int;
-typedef int bool_int;
+typedef WIDE_INT wide_int;
+typedef unsigned WIDE_INT u_wide_int;
+typedef int bool_int;
#define S_NULL "(null)"
#define S_NULL_LEN 6
* is declared as buf[ 100 ], buf_end should be &buf[ 100 ])
*/
static char *
- conv_10(register wide_int num, register bool_int is_unsigned,
- register bool_int * is_negative, char *buf_end, register int *len)
+conv_10(register wide_int num, register bool_int is_unsigned,
+ register bool_int * is_negative, char *buf_end, register int *len)
{
register char *p = buf_end;
register u_wide_int magnitude;
if (is_unsigned) {
magnitude = (u_wide_int) num;
*is_negative = FALSE;
- }
- else {
+ } else {
*is_negative = (num < 0);
/*
wide_int t = num + 1;
magnitude = ((u_wide_int) - t) + 1;
- }
- else
+ } else
magnitude = (u_wide_int) num;
}
do {
register u_wide_int new_magnitude = magnitude / 10;
- *--p = (char)(magnitude - new_magnitude * 10 + '0');
+ *--p = (char) (magnitude - new_magnitude * 10 + '0');
magnitude = new_magnitude;
}
while (magnitude);
* in buf).
*/
static char *
- conv_fp(register char format, register double num,
-boolean_e add_dp, int precision, bool_int * is_negative, char *buf, int *len)
+conv_fp(register char format, register double num,
+ boolean_e add_dp, int precision, bool_int * is_negative, char *buf, int *len)
{
register char *s = buf;
register char *p;
*is_negative = FALSE;
return (buf);
}
-
if (format == 'f')
if (decimal_point <= 0) {
*s++ = '0';
*s++ = '.';
while (decimal_point++ < 0)
*s++ = '0';
- }
- else if (add_dp)
+ } else if (add_dp)
*s++ = '.';
- }
- else {
+ } else {
while (decimal_point-- > 0)
*s++ = *p++;
if (precision > 0 || add_dp)
*s++ = '.';
- }
- else {
+ } else {
*s++ = *p++;
if (precision > 0 || add_dp)
*s++ = '.';
decimal_point--;
if (decimal_point != 0) {
p = conv_10((wide_int) decimal_point, FALSE, &exponent_is_negative,
- &temp[EXPONENT_LENGTH], &t_len);
+ &temp[EXPONENT_LENGTH], &t_len);
*s++ = exponent_is_negative ? '-' : '+';
/*
*s++ = '0';
while (t_len--)
*s++ = *p++;
- }
- else {
+ } else {
*s++ = '+';
*s++ = '0';
*s++ = '0';
}
}
-
*len = s - buf;
return (buf);
}
* is declared as buf[ 100 ], buf_end should be &buf[ 100 ])
*/
static char *
- conv_p2(register u_wide_int num, register int nbits,
- char format, char *buf_end, register int *len)
+conv_p2(register u_wide_int num, register int nbits,
+ char format, char *buf_end, register int *len)
{
register int mask = (1 << nbits) - 1;
register char *p = buf_end;
/*
* Do format conversion placing the output in buffer
*/
-static int format_converter(register buffy * odp, const char *fmt,
- va_list ap)
+static int
+format_converter(register buffy * odp, const char *fmt,
+ va_list ap)
{
register char *sp;
register char *bep;
while (*fmt) {
if (*fmt != '%') {
INS_CHAR(*fmt, sp, bep, cc);
- }
- else {
+ } else {
/*
* Default variable settings
*/
if (isdigit(*fmt)) {
STR_TO_DEC(fmt, min_width);
adjust_width = YES;
- }
- else if (*fmt == '*') {
+ } else if (*fmt == '*') {
min_width = va_arg(ap, int);
fmt++;
adjust_width = YES;
adjust = LEFT;
min_width = -min_width;
}
- }
- else
+ } else
adjust_width = NO;
/*
fmt++;
if (isdigit(*fmt)) {
STR_TO_DEC(fmt, precision);
- }
- else if (*fmt == '*') {
+ } else if (*fmt == '*') {
precision = va_arg(ap, int);
fmt++;
if (precision < 0)
precision = 0;
- }
- else
+ } else
precision = 0;
- }
- else
+ } else
adjust_precision = NO;
- }
- else
+ } else
adjust_precision = adjust_width = NO;
/*
if (*fmt == 'l') {
is_long = YES;
fmt++;
- }
- else
+ } else
is_long = NO;
/*
i_num = (wide_int) va_arg(ap, int);
};
s = conv_10(i_num, (*fmt) == 'u', &is_negative,
- &num_buf[NUM_BUF_SIZE], &s_len);
+ &num_buf[NUM_BUF_SIZE], &s_len);
FIX_PRECISION(adjust_precision, precision, s, s_len);
if (*fmt != 'u') {
else
ui_num = (u_wide_int) va_arg(ap, unsigned int);
s = conv_p2(ui_num, 3, *fmt,
- &num_buf[NUM_BUF_SIZE], &s_len);
+ &num_buf[NUM_BUF_SIZE], &s_len);
FIX_PRECISION(adjust_precision, precision, s, s_len);
if (alternate_form && *s != '0') {
*--s = '0';
else
ui_num = (u_wide_int) va_arg(ap, unsigned int);
s = conv_p2(ui_num, 4, *fmt,
- &num_buf[NUM_BUF_SIZE], &s_len);
+ &num_buf[NUM_BUF_SIZE], &s_len);
FIX_PRECISION(adjust_precision, precision, s, s_len);
if (alternate_form && i_num != 0) {
*--s = *fmt; /* 'x' or 'X' */
s_len = strlen(s);
if (adjust_precision && precision < s_len)
s_len = precision;
- }
- else {
+ } else {
s = S_NULL;
s_len = S_NULL_LEN;
}
fp_num = va_arg(ap, double);
s = conv_fp(*fmt, fp_num, alternate_form,
- (adjust_precision == NO) ? FLOAT_DIGITS : precision,
- &is_negative, &num_buf[1], &s_len);
+ (adjust_precision == NO) ? FLOAT_DIGITS : precision,
+ &is_negative, &num_buf[1], &s_len);
if (is_negative)
prefix_char = '-';
else if (print_sign)
if (sizeof(char *) <= sizeof(u_wide_int))
s = conv_p2(ui_num, 4, 'x',
- &num_buf[NUM_BUF_SIZE], &s_len);
+ &num_buf[NUM_BUF_SIZE], &s_len);
else {
s = "%p";
s_len = 2;
*--s = prefix_char;
s_len++;
}
-
if (adjust_width && adjust == RIGHT && min_width > s_len) {
if (pad_char == '0' && prefix_char != NUL) {
INS_CHAR(*s, sp, bep, cc)
}
PAD(min_width, s_len, pad_char);
}
-
/*
* Print the string s.
*/
/*
* This is the general purpose conversion function.
*/
-static void strx_printv(int *ccp, char *buf, size_t len, const char *format,
- va_list ap)
+static void
+strx_printv(int *ccp, char *buf, size_t len, const char *format,
+ va_list ap)
{
buffy od;
int cc;
}
-int snprintf(char *buf, size_t len, const char *format,...)
+int
+snprintf(char *buf, size_t len, const char *format,...)
{
int cc;
va_list ap;
}
-int vsnprintf(char *buf, size_t len, const char *format,
- va_list ap)
+int
+vsnprintf(char *buf, size_t len, const char *format,
+ va_list ap)
{
int cc;
return (cc);
}
-#endif /* HAVE_SNPRINTF */
+#endif /* HAVE_SNPRINTF */
/*
- * $Id: util.c,v 1.32 1997/10/17 05:27:56 wessels Exp $
+ * $Id: util.c,v 1.33 1997/10/20 22:59:42 wessels Exp $
*
* DEBUG:
* AUTHOR: Harvest Derived
{
static char xbstrerror_buf[BUFSIZ];
if (err < 0 || err >= sys_nerr)
- return ("Unknown");
+ return ("Unknown");
sprintf(xbstrerror_buf, "(%d) %s", err, strerror(err));
return xbstrerror_buf;
}
+
/*
- * $Id: client.cc,v 1.31 1997/10/17 00:00:31 wessels Exp $
+ * $Id: client.cc,v 1.32 1997/10/20 22:59:43 wessels Exp $
*
* DEBUG: section 0 WWW Client
* AUTHOR: Harvest Derived
/*
- * $Id: client_side.cc,v 1.128 1997/10/17 23:31:10 wessels Exp $
+ * $Id: client_side.cc,v 1.129 1997/10/20 22:59:43 wessels Exp $
*
* DEBUG: section 33 Client-side Routines
* AUTHOR: Duane Wessels
}
http->old_entry = NULL; /* done with old_entry */
/* use clientCacheHit() here as the callback because we might
- be swapping in from disk, and the file might not really be
- there */
+ * be swapping in from disk, and the file might not really be
+ * there */
storeClientCopy(entry,
http->out.offset,
http->out.offset,
/*
- * $Id: disk.cc,v 1.81 1997/10/17 20:20:17 wessels Exp $
+ * $Id: disk.cc,v 1.82 1997/10/20 22:59:44 wessels Exp $
*
* DEBUG: section 6 Disk I/O Routines
* AUTHOR: Harvest Derived
FILE_WALK_LHD *line_handler;
void *line_data;
} dwalk_ctrl;
+
#endif
static AIOCB diskHandleWriteComplete;
ctrlp);
#else
if (F->disk.offset != ctrl_dat->offset) {
- debug(6,1)("diskHandleRead: seeking to offset %d\n",
- (int) ctrl_dat->offset);
+ debug(6, 1) ("diskHandleRead: seeking to offset %d\n",
+ (int) ctrl_dat->offset);
lseek(fd, ctrl_dat->offset, SEEK_SET); /* XXX ignore return? */
}
len = read(fd, ctrl_dat->buf, ctrl_dat->req_len);
safe_free(ctrl_dat);
return;
}
- ctrl_dat->handler(fd,
- ctrl_dat->buf,
- len,
- DISK_OK,
- ctrl_dat->client_data);
- safe_free(ctrl_dat);
+ ctrl_dat->handler(fd,
+ ctrl_dat->buf,
+ len,
+ DISK_OK,
+ ctrl_dat->client_data);
+ safe_free(ctrl_dat);
}
/*
- * $Id: errorpage.cc,v 1.78 1997/10/20 19:06:25 wessels Exp $
+ * $Id: errorpage.cc,v 1.79 1997/10/20 22:59:45 wessels Exp $
*
* DEBUG: section 4 Error Generation
* AUTHOR: Duane Wessels
{
char *buf;
int len;
- debug(4,3)("errorSend: FD %d, err=%p\n", fd, err);
+ debug(4, 3) ("errorSend: FD %d, err=%p\n", fd, err);
assert(fd >= 0);
buf = errorBuildBuf(err, &len);
cbdataAdd(err);
errorSendComplete(int fd, char *buf, int size, int errflag, void *data)
{
ErrorState *err = data;
- debug(4,3)("errorSendComplete: FD %d, size=%d\n", fd, size);
+ debug(4, 3) ("errorSendComplete: FD %d, size=%d\n", fd, size);
if (err->callback)
err->callback(fd, err->callback_data, size);
cbdataUnlock(err);
/*
- * $Id: main.cc,v 1.174 1997/10/20 22:31:36 kostas Exp $
+ * $Id: main.cc,v 1.175 1997/10/20 22:59:47 wessels Exp $
*
* DEBUG: section 1 Startup and Main Loop
* AUTHOR: Harvest Derived
}
}
#ifdef SQUID_SNMP
- if (Config.Port.snmp) {
- enter_suid();
- fd = comm_open(SOCK_STREAM,
- 0,
- Config.Addrs.snmp_incoming,
- SQUID_SNMP_PORT,
- COMM_NONBLOCKING,
- "SNMP Socket");
- leave_suid();
- if (fd < 0)
- continue;
- comm_listen(fd);
- commSetSelect(fd, COMM_SELECT_READ, snmpAccept, NULL, 0);
- debug(1, 1) ("Accepting SNMP connections on port %d, FD %d.\n",
- (int) SQUID_SNMP_PORT , fd);
+ if (Config.Port.snmp) {
+ enter_suid();
+ fd = comm_open(SOCK_STREAM,
+ 0,
+ Config.Addrs.snmp_incoming,
+ SQUID_SNMP_PORT,
+ COMM_NONBLOCKING,
+ "SNMP Socket");
+ leave_suid();
+ if (fd < 0)
+ continue;
+ comm_listen(fd);
+ commSetSelect(fd, COMM_SELECT_READ, snmpAccept, NULL, 0);
+ debug(1, 1) ("Accepting SNMP connections on port %d, FD %d.\n",
+ (int) SQUID_SNMP_PORT, fd);
}
#endif /* SQUID_SNMP */
/*
- * $Id: store.cc,v 1.297 1997/10/20 22:49:25 wessels Exp $
+ * $Id: store.cc,v 1.298 1997/10/20 22:59:48 wessels Exp $
*
* DEBUG: section 20 Storeage Manager
* AUTHOR: Harvest Derived
if (sc == NULL)
return 0;
if (e->store_status == STORE_OK && e->swap_status != SWAPOUT_DONE)
- storeCheckSwapOut(e);
+ storeCheckSwapOut(e);
sc->seen_offset = 0;
sc->copy_offset = 0;
if (sc->swapin_fd > -1)
if (!storeCheckCachable(e)) {
storeReleaseRequest(e);
} else {
- e->swap_status = SWAPOUT_DONE;
- storeLog(STORE_LOG_SWAPOUT, e);
- storeDirSwapLog(e);
+ e->swap_status = SWAPOUT_DONE;
+ storeLog(STORE_LOG_SWAPOUT, e);
+ storeDirSwapLog(e);
}
HTTPCacheInfo->proto_newobject(HTTPCacheInfo,
mem->request->protocol,
if (e->swap_status == SWAPOUT_NONE) {
assert(mem->swapout.fd == -1);
if (storeCheckCachable(e))
- storeSwapOutStart(e);
+ storeSwapOutStart(e);
/* else ENTRY_CACHABLE will be cleared and we'll never get
- here again */
+ * here again */
return;
}
if (e->swap_status == SWAPOUT_OPENING)
MemObject *mem = sc->mem;
debug(20, 3) ("storeClientCopyHandleRead: FD %d, len %d\n", fd, len);
if (len > 0 && sc->copy_offset == 0)
- httpParseReplyHeaders(buf, mem->reply);
+ httpParseReplyHeaders(buf, mem->reply);
sc->callback(sc->callback_data, sc->copy_buf, len);
}
struct in_addr udp_incoming;
#ifdef SQUID_SNMP
struct in_addr snmp_incoming;
-#endif /* SQUID_SNMP */
+#endif /* SQUID_SNMP */
struct in_addr udp_outgoing;
struct in_addr client_netmask;
} Addrs;
char *copy_buf;
STCB *callback;
void *callback_data;
- MemObject *mem; /* ptr to the parent structure, argh! */
+ MemObject *mem; /* ptr to the parent structure, argh! */
short swapin_fd;
};
+
#define FD_SETSIZE 1024
#include <stdio.h>
char *
mkrfc850(t)
- time_t *t;
+ time_t *t;
{
static char buf[128];
struct tm *gmt = gmtime(t);
nfds--;
if (fd == maxfd) {
while (FD[fd].cb == NULL)
- fd--;
+ fd--;
maxfd = fd;
}
}
void
-fd_open(int fd, CB *cb, void *data)
+fd_open(int fd, CB * cb, void *data)
{
FD[fd].cb = cb;
FD[fd].data = data;
void
sig_intr(int sig)
{
- fd_close(0);
- printf ("\rWaiting for open connections to finish...\n");
- signal(sig, SIG_DFL);
+ fd_close(0);
+ printf("\rWaiting for open connections to finish...\n");
+ signal(sig, SIG_DFL);
}
-void
+void
read_reply(int fd, void *data)
{
- static char buf[READ_BUF_SZ];
- if (read(fd, buf, READ_BUF_SZ) <= 0) {
- fd_close(fd);
- reqpersec++;
- nrequests++;
- }
+ static char buf[READ_BUF_SZ];
+ if (read(fd, buf, READ_BUF_SZ) <= 0) {
+ fd_close(fd);
+ reqpersec++;
+ nrequests++;
+ }
}
int
request(url)
- char *url;
+ char *url;
{
int s;
char buf[4096];
S.sin_family = AF_INET;
S.sin_port = htons(proxy_port);
S.sin_addr.s_addr = inet_addr(proxy_addr);
- if (connect(s, (struct sockaddr *) & S, sizeof(S)) < 0) {
+ if (connect(s, (struct sockaddr *) &S, sizeof(S)) < 0) {
close(s);
perror("connect");
return -1;
return -1;
}
/*
- if (fcntl(s, F_SETFL, O_NDELAY) < 0)
- perror("fcntl O_NDELAY");
-*/
+ * if (fcntl(s, F_SETFL, O_NDELAY) < 0)
+ * perror("fcntl O_NDELAY");
+ */
return s;
}
*t = '\0';
s = request(buf);
if (s < 0) {
- max_connections = nfds-1;
+ max_connections = nfds - 1;
printf("NOTE: max_connections set at %d\n", max_connections);
}
fd_open(s, read_reply, NULL);
void
usage(void)
{
- fprintf(stderr, "usage: %s: -p port -h host -n max\n", progname);
+ fprintf(stderr, "usage: %s: -p port -h host -n max\n", progname);
}
-int
+int
main(argc, argv)
- int argc;
- char *argv[];
+ int argc;
+ char *argv[];
{
int i;
int c;
gettimeofday(&start, NULL);
last = start;
while ((c = getopt(argc, argv, "p:h:n:i")) != -1) {
- switch (c) {
+ switch (c) {
case 'p':
- proxy_port = atoi(optarg);
- break;
+ proxy_port = atoi(optarg);
+ break;
case 'h':
- proxy_addr = strdup(optarg);
- break;
+ proxy_addr = strdup(optarg);
+ break;
case 'n':
- max_connections = atoi(optarg);
- break;
+ max_connections = atoi(optarg);
+ break;
case 'i':
- opt_ims = 1;
- break;
+ opt_ims = 1;
+ break;
default:
- usage();
- return 1;
- }
+ usage();
+ return 1;
+ }
}
fd_open(0, read_url, NULL);
signal(SIGINT, sig_intr);
}
if (select(maxfd + 1, &R, NULL, NULL, &to) < 0) {
if (errno != EINTR)
- perror("select");
+ perror("select");
continue;
}
for (i = 0; i <= maxfd; i++) {
}
gettimeofday(&now, NULL);
if (now.tv_sec > last.tv_sec) {
- last = now;
- dt = (int) (now.tv_sec - start.tv_sec);
- printf ("T+ %6d: %9d req (%+4d), %4d conn, %3d/sec avg\n",
- dt,
- nrequests,
- reqpersec,
- nfds,
- (int) (nrequests / dt));
- reqpersec = 0;
+ last = now;
+ dt = (int) (now.tv_sec - start.tv_sec);
+ printf("T+ %6d: %9d req (%+4d), %4d conn, %3d/sec avg\n",
+ dt,
+ nrequests,
+ reqpersec,
+ nfds,
+ (int) (nrequests / dt));
+ reqpersec = 0;
}
}
return 0;