/*
- * $Id: client_side.cc,v 1.96 1997/04/28 04:23:00 wessels Exp $
+ * $Id: client_side.cc,v 1.97 1997/04/28 05:32:40 wessels Exp $
*
* DEBUG: section 33 Client-side Routines
* AUTHOR: Duane Wessels
commSetSelect(fd,
COMM_SELECT_READ,
icpDetectClientClose,
- (void *) icpState,
+ icpState,
0);
}
icpProcessRequest(fd, icpState);
while (user != NULL) {
if (strlen(user) > 1 && strlen(passwd) > 1) {
debug(33, 6, "proxyAuthenticate: adding %s, %s to hash table\n", user, passwd);
- hash_insert(validated, xstrdup(user), (void *) xstrdup(passwd));
+ hash_insert(validated, xstrdup(user), xstrdup(passwd));
}
user = strtok(NULL, ":");
passwd = strtok(NULL, "\n");
}
debug(33, 5, "proxyAuthenticate: user %s validated\n", sent_user);
hash_delete(validated, sent_user);
- hash_insert(validated, xstrdup(sent_user), (void *) xstrdup(passwd));
+ hash_insert(validated, xstrdup(sent_user), xstrdup(passwd));
xfree(clear_userandpw);
return (sent_user);
icpState->entry = entry;
icpState->out_offset = 0;
/* Register with storage manager to receive updates when data comes in. */
- storeRegister(entry, fd, icpHandleIMSReply, (void *) icpState);
+ storeRegister(entry, fd, icpHandleIMSReply, icpState);
protoDispatch(fd, icpState->entry, icpState->request);
}
storeRegister(entry,
fd,
icpHandleIMSReply,
- (void *) icpState);
+ icpState);
return;
} else if (clientGetsOldEntry(entry, icpState->old_entry, icpState->request)) {
/* We initiated the IMS request, the client is not expecting
storeRegister(entry,
fd,
icpHandleIMSReply,
- (void *) icpState);
+ icpState);
return;
}
icpState->log_type = LOG_TCP_REFRESH_HIT;
strlen(msg),
30,
icpSendERRORComplete,
- (void *) icpState,
+ icpState,
NULL);
}
/*
- * $Id: comm.cc,v 1.141 1997/04/28 04:23:01 wessels Exp $
+ * $Id: comm.cc,v 1.142 1997/04/28 05:32:41 wessels Exp $
*
* DEBUG: section 5 Socket Functions
* AUTHOR: Harvest Derived
fd, xstrerror());
commSetSelect(fd,
COMM_SELECT_WRITE,
- (PF) commHandleWrite,
+ commHandleWrite,
state,
0);
} else {
/* Not done, reinstall the write handler and write some more */
commSetSelect(fd,
COMM_SELECT_WRITE,
- (PF) commHandleWrite,
+ commHandleWrite,
state,
0);
} else {
fd_table[fd].rwstate = state;
commSetSelect(fd,
COMM_SELECT_WRITE,
- (PF) commHandleWrite,
+ commHandleWrite,
fd_table[fd].rwstate,
0);
}
/*
- * $Id: disk.cc,v 1.58 1997/04/28 04:23:03 wessels Exp $
+ * $Id: disk.cc,v 1.59 1997/04/28 05:32:41 wessels Exp $
*
* DEBUG: section 6 Disk I/O Routines
* AUTHOR: Harvest Derived
}
ctrlp = xcalloc(1, sizeof(disk_ctrl_t));
ctrlp->fd = fd;
- ctrlp->data = (void *) entry;
+ ctrlp->data = entry;
#if USE_ASYNC_IO
aioWrite(fd,
entry->write_q->buf + entry->write_q->cur_offset,
entry->write_q->len - entry->write_q->cur_offset,
diskHandleWriteComplete,
- (void *) ctrlp);
+ ctrlp);
return DISK_OK;
#else
len = write(fd,
/* another block is queued */
commSetSelect(fd,
COMM_SELECT_WRITE,
- (PF) diskHandleWrite,
- (void *) entry,
+ diskHandleWrite,
+ entry,
0);
return DISK_OK;
}
#else
commSetSelect(fd,
COMM_SELECT_WRITE,
- (PF) diskHandleWrite,
- (void *) &file_table[fd],
+ diskHandleWrite,
+ &file_table[fd],
0);
#endif
file_table[fd].write_daemon = PRESENT;
disk_ctrl_t *ctrlp;
ctrlp = xcalloc(1, sizeof(disk_ctrl_t));
ctrlp->fd = fd;
- ctrlp->data = (void *) ctrl_dat;
+ ctrlp->data = ctrl_dat;
/* go to requested position. */
lseek(fd, ctrl_dat->offset, SEEK_SET);
file_table[fd].at_eof = NO;
ctrl_dat->buf + ctrl_dat->cur_len,
ctrl_dat->req_len - ctrl_dat->cur_len,
diskHandleReadComplete,
- (void *) ctrlp);
+ ctrlp);
return DISK_OK;
#else
len = read(fd,
if (errno == EAGAIN || errno == EWOULDBLOCK || errno == EINTR) {
commSetSelect(fd,
COMM_SELECT_READ,
- (PF) diskHandleRead,
- (void *) ctrl_dat,
+ diskHandleRead,
+ ctrl_dat,
0);
return DISK_OK;
}
if (ctrl_dat->cur_len < ctrl_dat->req_len) {
commSetSelect(fd,
COMM_SELECT_READ,
- (PF) diskHandleRead,
- (void *) ctrl_dat,
+ diskHandleRead,
+ ctrl_dat,
0);
return DISK_OK;
} else {
#else
commSetSelect(fd,
COMM_SELECT_READ,
- (PF) diskHandleRead,
- (void *) ctrl_dat,
+ diskHandleRead,
+ ctrl_dat,
0);
#endif
return DISK_OK;
disk_ctrl_t *ctrlp;
ctrlp = xcalloc(1, sizeof(disk_ctrl_t));
ctrlp->fd = fd;
- ctrlp->data = (void *) walk_dat;
+ ctrlp->data = walk_dat;
lseek(fd, walk_dat->offset, SEEK_SET);
file_table[fd].at_eof = NO;
aioRead(fd, walk_dat->buf,
DISK_LINE_LEN - 1,
diskHandleWalkComplete,
- (void *) ctrlp);
+ ctrlp);
return DISK_OK;
#else
len = read(fd, walk_dat->buf, DISK_LINE_LEN - 1);
if (len < 0) {
if (errno == EAGAIN || errno == EWOULDBLOCK || errno == EINTR) {
- commSetSelect(fd, COMM_SELECT_READ, (PF) diskHandleWalk,
- (void *) walk_dat, 0);
+ commSetSelect(fd, COMM_SELECT_READ, diskHandleWalk,
+ walk_dat, 0);
return DISK_OK;
}
debug(50, 1, "diskHandleWalk: FD %d: error readingd: %s\n",
walk_dat->offset += used_bytes;
/* reschedule it for next line. */
- commSetSelect(fd, COMM_SELECT_READ, (PF) diskHandleWalk,
- (void *) walk_dat,
+ commSetSelect(fd, COMM_SELECT_READ, diskHandleWalk,
+ walk_dat,
0);
return DISK_OK;
}
#if USE_ASYNC_IO
diskHandleWalk(fd, walk_dat);
#else
- commSetSelect(fd, COMM_SELECT_READ, (PF) diskHandleWalk,
- (void *) walk_dat,
+ commSetSelect(fd, COMM_SELECT_READ, diskHandleWalk,
+ walk_dat,
0);
#endif
return DISK_OK;
/*
- * $Id: ftp.cc,v 1.99 1997/04/28 04:23:08 wessels Exp $
+ * $Id: ftp.cc,v 1.100 1997/04/28 05:32:42 wessels Exp $
*
* DEBUG: section 9 File Transfer Protocol (FTP)
* AUTHOR: Harvest Derived
* when Gap is big enough. */
commSetSelect(fd,
COMM_SELECT_READ,
- (PF) ftpReadReply,
- (void *) data, 0);
+ ftpReadReply,
+ data, 0);
if (!BIT_TEST(entry->flag, READ_DEFERRED)) {
/* NOTE there is no read timeout handler to disable */
BIT_SET(entry->flag, READ_DEFERRED);
/* reinstall handlers */
/* XXX This may loop forever */
commSetSelect(fd, COMM_SELECT_READ,
- (PF) ftpReadReply, (void *) data, 0);
+ ftpReadReply, data, 0);
/* note there is no ftpReadReplyTimeout. Timeouts are handled
* by `ftpget'. */
} else {
ftpProcessReplyHeader(data, buf, len);
commSetSelect(fd,
COMM_SELECT_READ,
- (PF) ftpReadReply,
- (void *) data, 0);
+ ftpReadReply,
+ data, 0);
commSetSelect(fd,
COMM_SELECT_TIMEOUT,
- (PF) ftpLifetimeExpire,
- (void *) data,
+ ftpLifetimeExpire,
+ data,
Config.readTimeout);
}
return 0;
}
commSetSelect(ftpState->ftp_fd,
COMM_SELECT_READ,
- (PF) ftpReadReply,
- (void *) ftpState, 0);
+ ftpReadReply,
+ ftpState, 0);
commSetSelect(ftpState->ftp_fd,
COMM_SELECT_TIMEOUT,
- (PF) ftpLifetimeExpire,
- (void *) ftpState, Config.readTimeout);
+ ftpLifetimeExpire,
+ ftpState, Config.readTimeout);
}
static const char *
strlen(buf),
30,
ftpSendComplete,
- (void *) data,
+ data,
put_free_8k_page);
}
/* Pipe/socket created ok */
/* register close handler */
comm_add_close_handler(ftpData->ftp_fd,
- (PF) ftpStateFree,
- (void *) ftpData);
+ ftpStateFree,
+ ftpData);
/* Now connect ... */
commConnectStart(ftpData->ftp_fd,
localhost,
fd_note(fd, ftpData->entry->url);
commSetSelect(fd,
COMM_SELECT_WRITE,
- (PF) ftpSendRequest,
- (void *) data, 0);
+ ftpSendRequest,
+ data, 0);
comm_set_fd_lifetime(fd,
Config.lifetimeDefault);
commSetSelect(fd,
COMM_SELECT_LIFETIME,
- (PF) ftpLifetimeExpire,
- (void *) ftpData, 0);
+ ftpLifetimeExpire,
+ ftpData, 0);
if (opt_no_ipcache)
ipcacheInvalidate(ftpData->request->host);
}
return;
commSetSelect(ftpget_server_read,
COMM_SELECT_READ,
- (PF) NULL,
- (void *) NULL, 0);
+ NULL,
+ NULL, 0);
fdstat_close(ftpget_server_read);
close(ftpget_server_read);
fdstat_close(ftpget_server_write);
/* if ftpget -S goes away, this handler should get called */
commSetSelect(ftpget_to_squid[0],
COMM_SELECT_READ,
- (PF) ftpServerClosed,
- (void *) NULL, 0);
+ ftpServerClosed,
+ NULL, 0);
ftpget_server_write = squid_to_ftpget[1];
ftpget_server_read = ftpget_to_squid[0];
slp.tv_sec = 0;
/*
- * $Id: gopher.cc,v 1.73 1997/03/04 05:16:30 wessels Exp $
+ * $Id: gopher.cc,v 1.74 1997/04/28 05:32:43 wessels Exp $
*
* DEBUG: section 10 Gopher
* AUTHOR: Harvest Derived
* Gap is big enough. */
commSetSelect(fd,
COMM_SELECT_READ,
- (PF) gopherReadReply,
- (void *) data, 0);
+ gopherReadReply,
+ data, 0);
/* don't install read timeout until we are below the GAP */
commSetSelect(fd,
COMM_SELECT_TIMEOUT,
/* XXX This may loop forever */
commSetSelect(fd,
COMM_SELECT_READ,
- (PF) gopherReadReply,
- (void *) data, 0);
+ gopherReadReply,
+ data, 0);
commSetSelect(fd,
COMM_SELECT_TIMEOUT,
- (PF) gopherReadReplyTimeout,
- (void *) data,
+ gopherReadReplyTimeout,
+ data,
Config.readTimeout);
} else {
BIT_RESET(entry->flag, ENTRY_CACHABLE);
}
commSetSelect(fd,
COMM_SELECT_READ,
- (PF) gopherReadReply,
- (void *) data, 0);
+ gopherReadReply,
+ data, 0);
commSetSelect(fd,
COMM_SELECT_TIMEOUT,
- (PF) gopherReadReplyTimeout,
- (void *) data,
+ gopherReadReplyTimeout,
+ data,
Config.readTimeout);
}
put_free_4k_page(buf);
/* Schedule read reply. */
commSetSelect(fd,
COMM_SELECT_READ,
- (PF) gopherReadReply,
- (void *) gopherState, 0);
+ gopherReadReply,
+ gopherState, 0);
commSetSelect(fd,
COMM_SELECT_TIMEOUT,
- (PF) gopherReadReplyTimeout,
- (void *) gopherState,
+ gopherReadReplyTimeout,
+ gopherState,
Config.readTimeout);
comm_set_fd_lifetime(fd, 86400); /* extend lifetime */
strlen(buf),
30,
gopherSendComplete,
- (void *) data,
+ data,
put_free_4k_page);
if (BIT_TEST(data->entry->flag, ENTRY_CACHABLE))
storeSetPublicKey(data->entry); /* Make it public */
return;
}
comm_add_close_handler(sock,
- (PF) gopherStateFree,
- (void *) data);
+ gopherStateFree,
+ data);
/* check if IP is already in cache. It must be.
* It should be done before this route is called.
* Otherwise, we cannot check return code for connect. */
ipcacheInvalidate(gopherState->host);
commSetSelect(fd,
COMM_SELECT_LIFETIME,
- (PF) gopherLifetimeExpire,
- (void *) gopherState, 0);
+ gopherLifetimeExpire,
+ gopherState, 0);
commSetSelect(fd,
COMM_SELECT_WRITE,
- (PF) gopherSendRequest,
- (void *) gopherState, 0);
+ gopherSendRequest,
+ gopherState, 0);
}
/*
- * $Id: http.cc,v 1.154 1997/04/28 04:23:11 wessels Exp $
+ * $Id: http.cc,v 1.155 1997/04/28 05:32:43 wessels Exp $
*
* DEBUG: section 11 Hypertext Transfer Protocol (HTTP)
* AUTHOR: Harvest Derived
commSetSelect(fd,
COMM_SELECT_READ,
httpReadReply,
- (void *) httpState, 0);
+ httpState, 0);
/* disable read timeout until we are below the GAP */
commSetSelect(fd,
COMM_SELECT_TIMEOUT,
NULL,
- (void *) NULL,
- (time_t) 0);
+ NULL,
+ 0);
if (!BIT_TEST(entry->flag, READ_DEFERRED)) {
comm_set_fd_lifetime(fd, 3600); /* limit during deferring */
BIT_SET(entry->flag, READ_DEFERRED);
/* reinstall handlers */
/* XXX This may loop forever */
commSetSelect(fd, COMM_SELECT_READ,
- httpReadReply, (void *) httpState, 0);
+ httpReadReply, httpState, 0);
commSetSelect(fd, COMM_SELECT_TIMEOUT,
- httpReadReplyTimeout, (void *) httpState, Config.readTimeout);
+ httpReadReplyTimeout, httpState, Config.readTimeout);
} else {
BIT_RESET(entry->flag, ENTRY_CACHABLE);
storeReleaseRequest(entry);
commSetSelect(fd,
COMM_SELECT_TIMEOUT,
httpReadReplyTimeout,
- (void *) httpState,
+ httpState,
Config.readTimeout);
commSetSelect(fd,
COMM_SELECT_READ,
httpReadReply,
- (void *) httpState, 0);
+ httpState, 0);
}
}
commSetSelect(fd,
COMM_SELECT_READ,
httpReadReply,
- (void *) httpState, 0);
+ httpState, 0);
commSetSelect(fd,
COMM_SELECT_TIMEOUT,
httpReadReplyTimeout,
- (void *) httpState,
+ httpState,
Config.readTimeout);
comm_set_fd_lifetime(fd, 86400); /* extend lifetime */
}
/* register the handler to free HTTP state data when the FD closes */
comm_add_close_handler(httpState->fd,
httpStateFree,
- (void *) httpState);
+ httpState);
request->method = orig_request->method;
xstrncpy(request->host, e->host, SQUIDHOSTNAMELEN);
request->port = e->http_port;
ipcacheInvalidate(request->host);
fd_note(fd, entry->url);
commSetSelect(fd, COMM_SELECT_LIFETIME,
- httpLifetimeExpire, (void *) httpState, 0);
+ httpLifetimeExpire, httpState, 0);
commSetSelect(fd, COMM_SELECT_WRITE,
- httpSendRequest, (void *) httpState, 0);
+ httpSendRequest, httpState, 0);
}
}
httpState->fd = sock;
comm_add_close_handler(httpState->fd,
httpStateFree,
- (void *) httpState);
+ httpState);
httpState->ip_lookup_pending = 1;
ipcache_nbgethostbyname(request->host,
httpState->fd,
/*
- * $Id: icmp.cc,v 1.33 1997/04/28 04:23:12 wessels Exp $
+ * $Id: icmp.cc,v 1.34 1997/04/28 05:32:44 wessels Exp $
*
* DEBUG: section 37 ICMP Routines
* AUTHOR: Duane Wessels
static struct sockaddr_in F;
commSetSelect(icmp_sock,
COMM_SELECT_READ,
- (PF) icmpRecv,
- (void *) -1, 0);
+ icmpRecv,
+ -1, 0);
memset(&preply, '\0', sizeof(pingerReplyData));
n = recv(icmp_sock,
(char *) &preply,
*H = q;
commSetSelect(icmp_sock,
COMM_SELECT_WRITE,
- (PF) icmpSend,
- (void *) IcmpQueueHead, 0);
+ icmpSend,
+ IcmpQueueHead, 0);
}
static void
if (IcmpQueueHead) {
commSetSelect(fd,
COMM_SELECT_WRITE,
- (PF) icmpSend,
- (void *) IcmpQueueHead, 0);
+ icmpSend,
+ IcmpQueueHead, 0);
} else {
commSetSelect(fd,
COMM_SELECT_WRITE,
comm_close(child_sock);
commSetSelect(icmp_sock,
COMM_SELECT_READ,
- (PF) icmpRecv,
- (void *) -1, 0);
+ icmpRecv,
+ -1, 0);
comm_set_fd_lifetime(icmp_sock, -1);
debug(29, 0, "Pinger socket opened on FD %d\n", icmp_sock);
#endif
/*
- * $Id: ident.cc,v 1.25 1997/03/04 05:16:34 wessels Exp $
+ * $Id: ident.cc,v 1.26 1997/04/28 05:32:46 wessels Exp $
*
* DEBUG: section 30 Ident (RFC 931)
* AUTHOR: Duane Wessels
}
icpState->ident.fd = fd;
comm_add_close_handler(fd,
- (PF) identClose,
- (void *) icpState);
+ identClose,
+ icpState);
commConnectStart(fd,
inet_ntoa(icpState->peer.sin_addr),
IDENT_PORT,
strlen(reqbuf),
5, /* timeout */
identRequestComplete,
- (void *) icpState,
+ icpState,
NULL);
commSetSelect(fd,
COMM_SELECT_READ,
- (PF) identReadReply,
- (void *) icpState, 0);
+ identReadReply,
+ icpState, 0);
}
static void
/*
- * $Id: ipcache.cc,v 1.109 1997/04/28 04:23:15 wessels Exp $
+ * $Id: ipcache.cc,v 1.110 1997/04/28 05:32:47 wessels Exp $
*
* DEBUG: section 14 IP Cache
* AUTHOR: Harvest Derived
if (len < 0 && (errno == EWOULDBLOCK || errno == EAGAIN || errno == EINTR)) {
commSetSelect(fd,
COMM_SELECT_READ,
- (PF) ipcache_dnsHandleRead,
+ ipcache_dnsHandleRead,
dnsData, 0);
return;
}
/* reschedule */
commSetSelect(dnsData->inpipe,
COMM_SELECT_READ,
- (PF) ipcache_dnsHandleRead,
+ ipcache_dnsHandleRead,
dnsData, 0);
ipcacheNudgeQueue();
}
xfree);
commSetSelect(dns->outpipe,
COMM_SELECT_READ,
- (PF) ipcache_dnsHandleRead,
+ ipcache_dnsHandleRead,
dns, 0);
debug(14, 5, "ipcache_dnsDispatch: Request sent to DNS server #%d.\n",
dns->id);
/*
- * $Id: redirect.cc,v 1.35 1997/04/28 04:23:24 wessels Exp $
+ * $Id: redirect.cc,v 1.36 1997/04/28 05:32:48 wessels Exp $
*
* DEBUG: section 29 Redirector
* AUTHOR: Duane Wessels
/* reschedule */
commSetSelect(redirector->fd,
COMM_SELECT_READ,
- (PF) redirectHandleRead,
+ redirectHandleRead,
redirector, 0);
if ((t = strchr(redirector->inbuf, '\n'))) {
/* end of record found */
/* set handler for incoming result */
commSetSelect(redirect_child_table[k]->fd,
COMM_SELECT_READ,
- (PF) redirectHandleRead,
- (void *) redirect_child_table[k], 0);
+ redirectHandleRead,
+ redirect_child_table[k], 0);
debug(29, 3, "redirectOpenServers: 'redirect_server' %d started\n",
k);
}
/*
- * $Id: send-announce.cc,v 1.30 1997/03/04 05:16:40 wessels Exp $
+ * $Id: send-announce.cc,v 1.31 1997/04/28 05:32:48 wessels Exp $
*
* DEBUG: section 27 Cache Announcer
* AUTHOR: Duane Wessels
AppendUdp(qdata);
commSetSelect(theOutIcpConnection,
COMM_SELECT_WRITE,
- (PF) icpUdpReply,
- (void *) qdata, 0);
+ icpUdpReply,
+ qdata, 0);
}
/*
- * $Id: ssl.cc,v 1.44 1997/04/28 04:23:27 wessels Exp $
+ * $Id: ssl.cc,v 1.45 1997/04/28 05:32:49 wessels Exp $
*
* DEBUG: section 26 Secure Sockets Layer Proxy
* AUTHOR: Duane Wessels
/* remove the "unexpected" client close handler */
comm_remove_close_handler(sslState->client.fd,
sslClientClosed,
- (void *) sslState);
+ sslState);
comm_close(sslState->client.fd);
sslState->client.fd = -1;
}
commSetSelect(sslState->server.fd,
COMM_SELECT_READ,
sslReadServer,
- (void *) sslState, 0);
+ sslState, 0);
commSetSelect(sslState->server.fd,
COMM_SELECT_TIMEOUT,
sslReadTimeout,
- (void *) sslState,
+ sslState,
sslState->timeout);
} else {
sslClose(sslState);
commSetSelect(sslState->client.fd,
COMM_SELECT_WRITE,
sslWriteClient,
- (void *) sslState, 0);
+ sslState, 0);
}
}
commSetSelect(sslState->client.fd,
COMM_SELECT_READ,
sslReadClient,
- (void *) sslState, 0);
+ sslState, 0);
} else {
sslClose(sslState);
}
commSetSelect(sslState->server.fd,
COMM_SELECT_WRITE,
sslWriteServer,
- (void *) sslState, 0);
+ sslState, 0);
}
}
commSetSelect(sslState->server.fd,
COMM_SELECT_WRITE,
sslWriteServer,
- (void *) sslState, 0);
+ sslState, 0);
return;
}
debug(50, 2, "sslWriteServer: FD %d: write failure: %s.\n",
commSetSelect(sslState->client.fd,
COMM_SELECT_READ,
sslReadClient,
- (void *) sslState, 0);
+ sslState, 0);
commSetSelect(sslState->server.fd,
COMM_SELECT_TIMEOUT,
sslReadTimeout,
- (void *) sslState,
+ sslState,
sslState->timeout);
} else {
/* still have more to write */
commSetSelect(sslState->server.fd,
COMM_SELECT_WRITE,
sslWriteServer,
- (void *) sslState, 0);
+ sslState, 0);
}
}
commSetSelect(sslState->client.fd,
COMM_SELECT_WRITE,
sslWriteClient,
- (void *) sslState, 0);
+ sslState, 0);
return;
}
debug(50, 2, "sslWriteClient: FD %d: write failure: %s.\n",
commSetSelect(sslState->server.fd,
COMM_SELECT_READ,
sslReadServer,
- (void *) sslState, 0);
+ sslState, 0);
} else {
/* still have more to write */
commSetSelect(sslState->client.fd,
COMM_SELECT_WRITE,
sslWriteClient,
- (void *) sslState, 0);
+ sslState, 0);
}
}
commSetSelect(sslState->client.fd,
COMM_SELECT_WRITE,
sslWriteClient,
- (void *) sslState, 0);
+ sslState, 0);
commSetSelect(sslState->client.fd,
COMM_SELECT_READ,
sslReadClient,
- (void *) sslState, 0);
+ sslState, 0);
}
static void
strlen(buf),
30,
sslErrorComplete,
- (void *) sslState,
+ sslState,
xfree);
return;
}
commSetSelect(sslState->server.fd,
COMM_SELECT_LIFETIME,
sslLifetimeExpire,
- (void *) sslState, 0);
+ sslState, 0);
/* NOTE this changes the lifetime handler for the client side.
* It used to be asciiConnLifetimeHandle, but it does funny things
* like looking for read handlers and assuming it was still reading
commSetSelect(sslState->client.fd,
COMM_SELECT_LIFETIME,
sslLifetimeExpire,
- (void *) sslState, 0);
+ sslState, 0);
commConnectStart(fd,
sslState->host,
sslState->port,
strlen(buf),
30,
sslErrorComplete,
- (void *) sslState,
+ sslState,
xfree);
return;
}
sslState->client.buf = xmalloc(SQUID_TCP_SO_RCVBUF);
comm_add_close_handler(sslState->server.fd,
sslStateFree,
- (void *) sslState);
+ sslState);
comm_add_close_handler(sslState->client.fd,
sslClientClosed,
- (void *) sslState);
+ sslState);
peerSelect(request,
NULL,
sslPeerSelectComplete,
commSetSelect(sslState->server.fd,
COMM_SELECT_WRITE,
sslWriteServer,
- (void *) sslState, 0);
+ sslState, 0);
commSetSelect(sslState->server.fd,
COMM_SELECT_READ,
sslReadServer,
- (void *) sslState, 0);
+ sslState, 0);
}
static void
/*
- * $Id: stat.cc,v 1.133 1997/04/28 04:23:28 wessels Exp $
+ * $Id: stat.cc,v 1.134 1997/04/28 05:32:50 wessels Exp $
*
* DEBUG: section 18 Cache Manager Statistics
* AUTHOR: Harvest Derived
data->sentry = sentry;
storeAppendPrintf(sentry, "{\n");
file_walk(fd,
- (FILE_WALK_HD) logReadEndHandler,
- (void *) data,
- (FILE_WALK_LHD) logReadHandler,
- (void *) data);
+ logReadEndHandler,
+ data,
+ logReadHandler,
+ data);
return;
}
data->sentry = sentry;
data->fd = file_open(ConfigFile, NULL, O_RDONLY, NULL, NULL);
storeAppendPrintf(sentry, open_bracket);
- file_walk(data->fd, (FILE_WALK_HD) squidReadEndHandler, (void *) data,
- (FILE_WALK_LHD) squidReadHandler, (void *) data);
+ file_walk(data->fd, squidReadEndHandler, data,
+ squidReadHandler, data);
}
/*
- * $Id: store.cc,v 1.223 1997/04/28 05:11:47 wessels Exp $
+ * $Id: store.cc,v 1.224 1997/04/28 05:32:51 wessels Exp $
*
* DEBUG: section 20 Storeage Manager
* AUTHOR: Harvest Derived
mem->e_swap_buf,
SWAP_BUF,
mem->swap_offset,
- (FILE_READ_HD) storeSwapInHandle,
- (void *) e);
+ storeSwapInHandle,
+ e);
return 0;
}
/* complete swapping in */
mem->e_swap_buf,
SWAP_BUF,
mem->swap_offset,
- (FILE_READ_HD) storeSwapInHandle,
- (void *) e);
+ storeSwapInHandle,
+ e);
(ctrlp->callback) (ctrlp->callback_data, 0);
xfree(ctrlp->path);
xfree(ctrlp);
/*
- * $Id: tunnel.cc,v 1.44 1997/04/28 04:23:27 wessels Exp $
+ * $Id: tunnel.cc,v 1.45 1997/04/28 05:32:49 wessels Exp $
*
* DEBUG: section 26 Secure Sockets Layer Proxy
* AUTHOR: Duane Wessels
/* remove the "unexpected" client close handler */
comm_remove_close_handler(sslState->client.fd,
sslClientClosed,
- (void *) sslState);
+ sslState);
comm_close(sslState->client.fd);
sslState->client.fd = -1;
}
commSetSelect(sslState->server.fd,
COMM_SELECT_READ,
sslReadServer,
- (void *) sslState, 0);
+ sslState, 0);
commSetSelect(sslState->server.fd,
COMM_SELECT_TIMEOUT,
sslReadTimeout,
- (void *) sslState,
+ sslState,
sslState->timeout);
} else {
sslClose(sslState);
commSetSelect(sslState->client.fd,
COMM_SELECT_WRITE,
sslWriteClient,
- (void *) sslState, 0);
+ sslState, 0);
}
}
commSetSelect(sslState->client.fd,
COMM_SELECT_READ,
sslReadClient,
- (void *) sslState, 0);
+ sslState, 0);
} else {
sslClose(sslState);
}
commSetSelect(sslState->server.fd,
COMM_SELECT_WRITE,
sslWriteServer,
- (void *) sslState, 0);
+ sslState, 0);
}
}
commSetSelect(sslState->server.fd,
COMM_SELECT_WRITE,
sslWriteServer,
- (void *) sslState, 0);
+ sslState, 0);
return;
}
debug(50, 2, "sslWriteServer: FD %d: write failure: %s.\n",
commSetSelect(sslState->client.fd,
COMM_SELECT_READ,
sslReadClient,
- (void *) sslState, 0);
+ sslState, 0);
commSetSelect(sslState->server.fd,
COMM_SELECT_TIMEOUT,
sslReadTimeout,
- (void *) sslState,
+ sslState,
sslState->timeout);
} else {
/* still have more to write */
commSetSelect(sslState->server.fd,
COMM_SELECT_WRITE,
sslWriteServer,
- (void *) sslState, 0);
+ sslState, 0);
}
}
commSetSelect(sslState->client.fd,
COMM_SELECT_WRITE,
sslWriteClient,
- (void *) sslState, 0);
+ sslState, 0);
return;
}
debug(50, 2, "sslWriteClient: FD %d: write failure: %s.\n",
commSetSelect(sslState->server.fd,
COMM_SELECT_READ,
sslReadServer,
- (void *) sslState, 0);
+ sslState, 0);
} else {
/* still have more to write */
commSetSelect(sslState->client.fd,
COMM_SELECT_WRITE,
sslWriteClient,
- (void *) sslState, 0);
+ sslState, 0);
}
}
commSetSelect(sslState->client.fd,
COMM_SELECT_WRITE,
sslWriteClient,
- (void *) sslState, 0);
+ sslState, 0);
commSetSelect(sslState->client.fd,
COMM_SELECT_READ,
sslReadClient,
- (void *) sslState, 0);
+ sslState, 0);
}
static void
strlen(buf),
30,
sslErrorComplete,
- (void *) sslState,
+ sslState,
xfree);
return;
}
commSetSelect(sslState->server.fd,
COMM_SELECT_LIFETIME,
sslLifetimeExpire,
- (void *) sslState, 0);
+ sslState, 0);
/* NOTE this changes the lifetime handler for the client side.
* It used to be asciiConnLifetimeHandle, but it does funny things
* like looking for read handlers and assuming it was still reading
commSetSelect(sslState->client.fd,
COMM_SELECT_LIFETIME,
sslLifetimeExpire,
- (void *) sslState, 0);
+ sslState, 0);
commConnectStart(fd,
sslState->host,
sslState->port,
strlen(buf),
30,
sslErrorComplete,
- (void *) sslState,
+ sslState,
xfree);
return;
}
sslState->client.buf = xmalloc(SQUID_TCP_SO_RCVBUF);
comm_add_close_handler(sslState->server.fd,
sslStateFree,
- (void *) sslState);
+ sslState);
comm_add_close_handler(sslState->client.fd,
sslClientClosed,
- (void *) sslState);
+ sslState);
peerSelect(request,
NULL,
sslPeerSelectComplete,
commSetSelect(sslState->server.fd,
COMM_SELECT_WRITE,
sslWriteServer,
- (void *) sslState, 0);
+ sslState, 0);
commSetSelect(sslState->server.fd,
COMM_SELECT_READ,
sslReadServer,
- (void *) sslState, 0);
+ sslState, 0);
}
static void
/*
- * $Id: wais.cc,v 1.63 1997/04/28 04:23:34 wessels Exp $
+ * $Id: wais.cc,v 1.64 1997/04/28 05:32:52 wessels Exp $
*
* DEBUG: section 24 WAIS Relay
* AUTHOR: Harvest Derived
* when Gap is big enough. */
commSetSelect(fd,
COMM_SELECT_READ,
- (PF) waisReadReply,
- (void *) waisState, 0);
+ waisReadReply,
+ waisState, 0);
/* don't install read handler while we're above the gap */
commSetSelect(fd,
COMM_SELECT_TIMEOUT,
/* reinstall handlers */
/* XXX This may loop forever */
commSetSelect(fd, COMM_SELECT_READ,
- (PF) waisReadReply, (void *) waisState, 0);
+ waisReadReply, waisState, 0);
commSetSelect(fd, COMM_SELECT_TIMEOUT,
- (PF) waisReadReplyTimeout, (void *) waisState, Config.readTimeout);
+ waisReadReplyTimeout, waisState, Config.readTimeout);
} else {
BIT_RESET(entry->flag, ENTRY_CACHABLE);
storeReleaseRequest(entry);
storeAppend(entry, buf, len);
commSetSelect(fd,
COMM_SELECT_READ,
- (PF) waisReadReply,
- (void *) waisState, 0);
+ waisReadReply,
+ waisState, 0);
commSetSelect(fd,
COMM_SELECT_TIMEOUT,
- (PF) waisReadReplyTimeout,
- (void *) waisState,
+ waisReadReplyTimeout,
+ waisState,
Config.readTimeout);
}
}
/* Schedule read reply. */
commSetSelect(fd,
COMM_SELECT_READ,
- (PF) waisReadReply,
- (void *) waisState, 0);
+ waisReadReply,
+ waisState, 0);
commSetSelect(fd,
COMM_SELECT_TIMEOUT,
- (PF) waisReadReplyTimeout,
- (void *) waisState,
+ waisReadReplyTimeout,
+ waisState,
Config.readTimeout);
}
}
WaisStateData *waisState = (WaisStateData *) data;
comm_add_close_handler(waisState->fd,
- (PF) waisStateFree,
- (void *) waisState);
+ waisStateFree,
+ waisState);
waisState->ip_lookup_pending = 1;
ipcache_nbgethostbyname(waisState->relayhost,
waisState->fd,
ipcacheInvalidate(waisState->relayhost);
commSetSelect(fd,
COMM_SELECT_LIFETIME,
- (PF) waisLifetimeExpire,
- (void *) waisState, 0);
+ waisLifetimeExpire,
+ waisState, 0);
commSetSelect(fd,
COMM_SELECT_WRITE,
- (PF) waisSendRequest,
- (void *) waisState, 0);
+ waisSendRequest,
+ waisState, 0);
}