-/* $Id: ftp.cc,v 1.33 1996/04/10 20:53:45 wessels Exp $ */
+/* $Id: ftp.cc,v 1.34 1996/04/12 21:41:37 wessels Exp $ */
/*
* DEBUG: Section 9 ftp: FTP
comm_close(fd);
if (data) {
if (data->reply_hdr) {
- put_free_8k_page(data->reply_hdr, __FILE__, __LINE__);
+ put_free_8k_page(data->reply_hdr);
data->reply_hdr = NULL;
}
if (data->icp_page_ptr) {
- put_free_8k_page(data->icp_page_ptr, __FILE__, __LINE__);
+ put_free_8k_page(data->icp_page_ptr);
data->icp_page_ptr = NULL;
}
if (data->icp_rwd_ptr)
debug(11, 3, "ftpProcessReplyHeader: key '%s'\n", entry->key);
if (data->reply_hdr == NULL) {
- data->reply_hdr = get_free_8k_page(__FILE__, __LINE__);
+ data->reply_hdr = get_free_8k_page();
memset(data->reply_hdr, '\0', 8192);
}
if (data->reply_hdr_state == 0) {
storeSetPrivateKey(entry);
storeExpireNow(entry);
BIT_RESET(entry->flag, CACHABLE);
- storeReleaseRequest(entry, __FILE__, __LINE__);
+ storeReleaseRequest(entry);
break;
default:
/* These can be negative cached, make key public */
* by `ftpget'. */
} else {
BIT_RESET(entry->flag, CACHABLE);
- storeReleaseRequest(entry, __FILE__, __LINE__);
+ storeReleaseRequest(entry);
cached_error_entry(entry, ERR_READ_ERROR, xstrerror());
ftpCloseAndFree(fd, data);
}
debug(9, 1, "ftpReadReply: Didn't see magic marker, purging <URL:%s>.\n", entry->url);
entry->expires = cached_curtime + getNegativeTTL();
BIT_RESET(entry->flag, CACHABLE);
- storeReleaseRequest(entry, __FILE__, __LINE__);
+ storeReleaseRequest(entry);
} else if (!(entry->flag & DELETE_BEHIND)) {
entry->expires = cached_curtime + ttlSet(entry);
}
fd, size, errflag);
if (buf) {
- put_free_8k_page(buf, __FILE__, __LINE__); /* Allocated by ftpSendRequest. */
+ put_free_8k_page(buf); /* Allocated by ftpSendRequest. */
buf = NULL;
}
data->icp_page_ptr = NULL; /* So lifetime expire doesn't re-free */
debug(9, 5, "ftpSendRequest: FD %d\n", fd);
buflen = strlen(data->request) + 256;
- buf = (char *) get_free_8k_page(__FILE__, __LINE__);
+ buf = (char *) get_free_8k_page();
data->icp_page_ptr = buf;
memset(buf, '\0', buflen);
-/* $Id: gopher.cc,v 1.24 1996/04/11 04:47:22 wessels Exp $ */
+/* $Id: gopher.cc,v 1.25 1996/04/12 21:41:37 wessels Exp $ */
/*
* DEBUG: Section 10 gopher: GOPHER
{
if (fd > +0)
comm_close(fd);
- put_free_4k_page(data->buf, __FILE__, __LINE__);
+ put_free_4k_page(data->buf);
xfree(data);
}
debug(10, 4, "GopherReadReplyTimeout: Timeout on %d\n url: %s\n", fd, entry->url);
cached_error_entry(entry, ERR_READ_TIMEOUT, NULL);
if (data->icp_page_ptr)
- put_free_4k_page(data->icp_page_ptr, __FILE__, __LINE__);
+ put_free_4k_page(data->icp_page_ptr);
if (data->icp_rwd_ptr)
safe_free(data->icp_rwd_ptr);
gopherCloseAndFree(fd, data);
debug(10, 4, "gopherLifeTimeExpire: FD %d: <URL:%s>\n", fd, entry->url);
cached_error_entry(entry, ERR_LIFETIME_EXP, NULL);
if (data->icp_page_ptr)
- put_free_4k_page(data->icp_page_ptr, __FILE__, __LINE__);
+ put_free_4k_page(data->icp_page_ptr);
if (data->icp_rwd_ptr)
safe_free(data->icp_rwd_ptr);
comm_set_select_handler(fd,
return 0;
}
}
- buf = get_free_4k_page(__FILE__, __LINE__);
+ buf = get_free_4k_page();
errno = 0;
len = read(fd, buf, TEMP_BUF_SIZE - 1); /* leave one space for \0 in gopherToHTML */
debug(10, 5, "gopherReadReply: FD %d read len=%d\n", fd, len);
(PF) gopherReadReplyTimeout, (void *) data, getReadTimeout());
} else {
BIT_RESET(entry->flag, CACHABLE);
- storeReleaseRequest(entry, __FILE__, __LINE__);
+ storeReleaseRequest(entry);
cached_error_entry(entry, ERR_READ_ERROR, xstrerror());
gopherCloseAndFree(fd, data);
}
(void *) data,
getReadTimeout());
}
- put_free_4k_page(buf, __FILE__, __LINE__);
+ put_free_4k_page(buf);
return 0;
}
cached_error_entry(entry, ERR_CONNECT_FAIL, xstrerror());
gopherCloseAndFree(fd, data);
if (buf)
- put_free_4k_page(buf, __FILE__, __LINE__); /* Allocated by gopherSendRequest. */
+ put_free_4k_page(buf); /* Allocated by gopherSendRequest. */
return;
}
/*
comm_set_fd_lifetime(fd, -1); /* disable */
if (buf)
- put_free_4k_page(buf, __FILE__, __LINE__); /* Allocated by gopherSendRequest. */
+ put_free_4k_page(buf); /* Allocated by gopherSendRequest. */
data->icp_page_ptr = NULL;
data->icp_rwd_ptr = NULL;
}
{
int len;
static char query[MAX_URL];
- char *buf = get_free_4k_page(__FILE__, __LINE__);
+ char *buf = get_free_4k_page();
data->icp_page_ptr = buf;
GopherData *CreateGopherData()
{
GopherData *gd = (GopherData *) xcalloc(1, sizeof(GopherData));
- gd->buf = get_free_4k_page(__FILE__, __LINE__);
+ gd->buf = get_free_4k_page();
return (gd);
}
-/* $Id: http.cc,v 1.43 1996/04/12 21:22:55 wessels Exp $ */
+/* $Id: http.cc,v 1.44 1996/04/12 21:41:38 wessels Exp $ */
/*
* DEBUG: Section 11 http: HTTP
comm_close(fd);
if (data) {
if (data->reply_hdr) {
- put_free_8k_page(data->reply_hdr, __FILE__, __LINE__);
+ put_free_8k_page(data->reply_hdr);
data->reply_hdr = NULL;
}
if (data->icp_page_ptr) {
- put_free_8k_page(data->icp_page_ptr, __FILE__, __LINE__);
+ put_free_8k_page(data->icp_page_ptr);
data->icp_page_ptr = NULL;
}
if (data->icp_rwd_ptr)
debug(11, 3, "httpProcessReplyHeader: key '%s'\n", entry->key);
if (data->reply_hdr == NULL) {
- data->reply_hdr = get_free_8k_page(__FILE__, __LINE__);
+ data->reply_hdr = get_free_8k_page();
memset(data->reply_hdr, '\0', 8192);
}
if (data->reply_hdr_state == 0) {
storeSetPrivateKey(entry);
storeExpireNow(entry);
BIT_RESET(entry->flag, CACHABLE);
- storeReleaseRequest(entry, __FILE__, __LINE__);
+ storeReleaseRequest(entry);
break;
default:
/* These can be negative cached, make key public */
(PF) httpReadReplyTimeout, (void *) data, getReadTimeout());
} else {
BIT_RESET(entry->flag, CACHABLE);
- storeReleaseRequest(entry, __FILE__, __LINE__);
+ storeReleaseRequest(entry);
cached_error_entry(entry, ERR_READ_ERROR, xstrerror());
httpCloseAndFree(fd, data);
}
fd, size, errflag);
if (buf) {
- put_free_8k_page(buf, __FILE__, __LINE__); /* Allocated by httpSendRequest. */
+ put_free_8k_page(buf); /* Allocated by httpSendRequest. */
buf = NULL;
}
data->icp_page_ptr = NULL; /* So lifetime expire doesn't re-free */
}
/* Since we limit the URL read to a 4K page, I doubt that the
* mime header could be longer than an 8K page */
- buf = (char *) get_free_8k_page(__FILE__, __LINE__);
+ buf = (char *) get_free_8k_page();
data->icp_page_ptr = buf;
if (buflen > DISK_PAGE_SIZE) {
debug(11, 0, "Mime header length %d is breaking ICP code\n", buflen);
xbuf = xstrdup(data->req_hdr);
for (t = strtok(xbuf, crlf); t; t = strtok(NULL, crlf)) {
if (strncasecmp(t, "User-Agent:", 11) == 0) {
- ybuf = (char *) get_free_4k_page(__FILE__, __LINE__);
+ ybuf = (char *) get_free_4k_page();
memset(ybuf, '\0', SM_PAGE_SIZE);
sprintf(ybuf, "%s %s %s", t, HARVEST_PROXY_TEXT, version_string);
t = ybuf;
}
xfree(xbuf);
if (ybuf) {
- put_free_4k_page(ybuf, __FILE__, __LINE__);
+ put_free_4k_page(ybuf);
ybuf = NULL;
}
}
/* Add Forwarded: header */
- ybuf = get_free_4k_page(__FILE__, __LINE__);
+ ybuf = get_free_4k_page();
if (data->entry->mem_obj)
cfd = data->entry->mem_obj->fd_of_first_client;
if (cfd < 0) {
}
strcat(buf, ybuf);
len += strlen(ybuf);
- put_free_4k_page(ybuf, __FILE__, __LINE__);
+ put_free_4k_page(ybuf);
ybuf = NULL;
strcat(buf, crlf);
-/* $Id: stmem.cc,v 1.8 1996/04/05 00:59:27 wessels Exp $ */
+/* $Id: stmem.cc,v 1.9 1996/04/12 21:41:40 wessels Exp $ */
/*
* DEBUG: Section 19 stmem:
lastp = p;
p = p->next;
if (lastp) {
- put_free_4k_page(lastp->data, __FILE__, __LINE__);
+ put_free_4k_page(lastp->data);
safe_free(lastp);
}
}
if (p) {
- put_free_4k_page(p->data, __FILE__, __LINE__);
+ put_free_4k_page(p->data);
safe_free(p);
}
}
while (p != mem->tail) {
lastp = p;
p = p->next;
- put_free_4k_page(lastp->data, __FILE__, __LINE__);
+ put_free_4k_page(lastp->data);
safe_free(lastp);
}
if (p != NULL) {
- put_free_4k_page(p->data, __FILE__, __LINE__);
+ put_free_4k_page(p->data);
safe_free(p);
p = NULL;
}
lastp = p;
p = p->next;
current_offset += lastp->len;
- put_free_4k_page(lastp->data, __FILE__, __LINE__);
+ put_free_4k_page(lastp->data);
safe_free(lastp);
}
}
p = (mem_node) xcalloc(1, sizeof(Mem_Node));
p->next = NULL;
p->len = len_to_copy;
- p->data = get_free_4k_page(__FILE__, __LINE__);
+ p->data = get_free_4k_page();
memcpy(p->data, data, len_to_copy);
if (!mem->head) {
/* PBD 12/95: Memory allocator routines for saving and reallocating fixed
* size blocks rather than mallocing and freeing them */
-char *get_free_4k_page(file, line)
- char *file;
- int line;
+char *get_free_4k_page()
{
char *page = NULL;
sm_stats.total_pages_allocated++;
}
sm_stats.n_pages_in_use++;
- debug(19, 5, "get_free_4k_page: Giving out %p, count=%d %s:%d\n",
- page, sm_stats.n_pages_in_use, file, line);
if (page == NULL)
fatal_dump("get_free_4k_page: Null page pointer?");
return (page);
}
-void put_free_4k_page(page, file, line)
+void put_free_4k_page(page)
char *page;
- char *file;
- int line;
{
static stack_overflow_warning_toggle;
}
}
sm_stats.n_pages_in_use--;
- debug(19, 5, "put_free_4k_page: Putting back %p, count=%d %s:%d\n", page, sm_stats.n_pages_in_use, file, line);
/* Call push regardless if it's full, cause it's just going to release the
* page if stack is full */
push(&sm_stats.free_page_stack, page);
}
-char *get_free_8k_page(file, line)
- char *file;
- int line;
+char *get_free_8k_page()
{
char *page = NULL;
disk_stats.total_pages_allocated++;
}
disk_stats.n_pages_in_use++;
- debug(19, 5, "get_free_8k_page: Giving out %p, count=%d %s:%d\n",
- page, disk_stats.n_pages_in_use, file, line);
if (page == NULL)
fatal_dump("get_free_8k_page: Null page pointer?");
return (page);
}
-void put_free_8k_page(page, file, line)
+void put_free_8k_page(page)
char *page;
- char *file;
- int line;
{
static stack_overflow_warning_toggle;
}
}
disk_stats.n_pages_in_use--;
- debug(19, 5, "put_free_8k_page: Putting back %p, count=%d %s:%d\n", page, disk_stats.n_pages_in_use, file, line);
/* Call push regardless if it's full, cause it's just going to release the
* page if stack is full */
push(&disk_stats.free_page_stack, page);
-/* $Id: store.cc,v 1.48 1996/04/12 21:22:58 wessels Exp $ */
-#ident "$Id: store.cc,v 1.48 1996/04/12 21:22:58 wessels Exp $"
+/* $Id: store.cc,v 1.49 1996/04/12 21:41:42 wessels Exp $ */
+#ident "$Id: store.cc,v 1.49 1996/04/12 21:41:42 wessels Exp $"
/*
* DEBUG: Section 20 store
return status;
}
-void storeReleaseRequest(e, file, line)
+void storeReleaseRequest(e)
StoreEntry *e;
- char *file;
- int line;
{
if (e->flag & RELEASE_REQUEST)
return;
- debug(20, 3, "storeReleaseRequest: FROM %s:%d FOR '%s'\n",
- file, line, e->key ? e->key : e->url);
+ debug(20, 3, "storeReleaseRequest: FOR '%s'\n", e->key ? e->key : e->url);
e->flag |= RELEASE_REQUEST;
}
debug(20, 0, "storeSetPublicKey: Making old '%s' private.\n", newkey);
e2 = (StoreEntry *) table_entry;
storeSetPrivateKey(e2);
- storeReleaseRequest(e2, __FILE__, __LINE__);
+ storeReleaseRequest(e2);
}
if (e->key)
storeHashDelete(e);
BIT_RESET(e->flag, ENTRY_PRIVATE);
} else {
BIT_RESET(e->flag, CACHABLE);
- storeReleaseRequest(e, __FILE__, __LINE__);
+ storeReleaseRequest(e);
BIT_SET(e->flag, ENTRY_PRIVATE);
}
if (neighbors_do_private_keys || !BIT_TEST(flags, REQ_PUBLIC))
/* change its key, so it couldn't be found by other client */
storeSetPrivateKey(e);
BIT_SET(e->flag, DELETE_BEHIND);
- storeReleaseRequest(e, __FILE__, __LINE__);
+ storeReleaseRequest(e);
BIT_RESET(e->flag, CACHABLE);
storeExpireNow(e);
}
if ((flag < 0) && (flag != DISK_EOF)) {
debug(20, 0, "storeSwapInHandle: SwapIn failure (err code = %d).\n", flag);
- put_free_8k_page(e->mem_obj->e_swap_buf, __FILE__, __LINE__);
+ put_free_8k_page(e->mem_obj->e_swap_buf);
storeSetMemStatus(e, NOT_IN_MEMORY);
file_close(e->mem_obj->swap_fd);
swapInError(-1, e); /* Invokes storeAbort() and completes the I/O */
} else {
/* complete swapping in */
storeSetMemStatus(e, IN_MEMORY);
- put_free_8k_page(e->mem_obj->e_swap_buf, __FILE__, __LINE__);
+ put_free_8k_page(e->mem_obj->e_swap_buf);
file_close(e->mem_obj->swap_fd);
storeLog(STORE_LOG_SWAPIN, e);
debug(20, 5, "storeSwapInHandle: SwapIn complete: <URL:%s> from %s.\n",
storeSetMemStatus(e, SWAPPING_IN);
e->mem_obj->data = new_MemObjectData();
e->mem_obj->swap_offset = 0;
- e->mem_obj->e_swap_buf = get_free_8k_page(__FILE__, __LINE__);
+ e->mem_obj->e_swap_buf = get_free_8k_page();
/* start swapping daemon */
file_read(fd,
debug(20, 1, "storeSwapOutHandle: SwapOut failure (err code = %d).\n",
flag);
e->swap_status = NO_SWAP;
- put_free_8k_page(page_ptr, __FILE__, __LINE__);
+ put_free_8k_page(page_ptr);
file_close(fd);
- storeReleaseRequest(e, __FILE__, __LINE__);
+ storeReleaseRequest(e);
if (e->swap_file_number != -1) {
file_map_bit_reset(e->swap_file_number);
safeunlink(filename, 0); /* remove it */
storeLog(STORE_LOG_SWAPOUT, e);
debug(20, 5, "storeSwapOutHandle: SwapOut complete: <URL:%s> to %s.\n",
e->url, storeSwapFullPath(e->swap_file_number, NULL));
- put_free_8k_page(page_ptr, __FILE__, __LINE__);
+ put_free_8k_page(page_ptr);
sprintf(logmsg, "%s %s %d %d %d\n",
filename,
e->url,
}
e->swap_status = SWAPPING_OUT;
e->mem_obj->swap_offset = 0;
- e->mem_obj->e_swap_buf = get_free_8k_page(__FILE__, __LINE__);
+ e->mem_obj->e_swap_buf = get_free_8k_page();
e->mem_obj->e_swap_buf_len = 0;
storeCopy(e, 0, SWAP_BUF, e->mem_obj->e_swap_buf,
} else
return 1;
- storeReleaseRequest(e, __FILE__, __LINE__);
+ storeReleaseRequest(e);
BIT_RESET(e->flag, CACHABLE);
return 0;
}
if (storeEntryLocked(e)) {
storeExpireNow(e);
debug(20, 3, "storeRelease: Only setting RELEASE_REQUEST bit\n");
- storeReleaseRequest(e, __FILE__, __LINE__);
+ storeReleaseRequest(e);
return -1;
}
if (e->key != NULL) {
-/* $Id: wais.cc,v 1.23 1996/04/10 00:18:50 wessels Exp $ */
+/* $Id: wais.cc,v 1.24 1996/04/12 21:41:44 wessels Exp $ */
/*
* DEBUG: Section 24 wais
(PF) waisReadReplyTimeout, (void *) data, getReadTimeout());
} else {
BIT_RESET(entry->flag, CACHABLE);
- storeReleaseRequest(entry, __FILE__, __LINE__);
+ storeReleaseRequest(entry);
cached_error_entry(entry, ERR_READ_ERROR, xstrerror());
waisCloseAndFree(fd, data);
}