-/* $Id: ftp.cc,v 1.25 1996/04/09 23:27:55 wessels Exp $ */
+/* $Id: ftp.cc,v 1.26 1996/04/09 23:28:32 wessels Exp $ */
/*
* DEBUG: Section 9 ftp: FTP
* by `ftpget'. */
} else {
BIT_RESET(entry->flag, CACHABLE);
- storeReleaseRequest(entry, __FILE__,__LINE__);
+ storeReleaseRequest(entry, __FILE__, __LINE__);
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, __FILE__, __LINE__);
} else if (!(entry->flag & DELETE_BEHIND)) {
entry->expires = cached_curtime + ttlSet(entry);
}
ftpSendComplete,
(void *) data);
if (!BIT_TEST(data->entry->flag, ENTRY_PRIVATE))
- storeSetPublicKey(data->entry); /* Make it public */
+ storeSetPublicKey(data->entry); /* Make it public */
}
void ftpConnInProgress(fd, data)
-/* $Id: http.cc,v 1.33 1996/04/09 23:27:56 wessels Exp $ */
+/* $Id: http.cc,v 1.34 1996/04/09 23:28:33 wessels Exp $ */
/*
* DEBUG: Section 11 http: HTTP
else
t = t2 ? t2 : t1;
if (!t)
- return; /* headers not complete */
+ return; /* headers not complete */
t += (t == t1 ? 4 : 2);
*t = '\0';
reply = entry->mem_obj->reply;
while (*s == '\r')
*s-- = '\0';
if (!strncasecmp(t, "HTTP", 4)) {
- sscanf (t+1, "%lf", &reply->version);
+ sscanf(t + 1, "%lf", &reply->version);
if ((t = strchr(t, ' '))) {
t++;
reply->code = atoi(t);
} else if (!strncasecmp(t, "Content-type:", 13)) {
if ((t = strchr(t, ' '))) {
t++;
- strncpy(reply->content_type, t, HTTP_REPLY_FIELD_SZ-1);
+ strncpy(reply->content_type, t, HTTP_REPLY_FIELD_SZ - 1);
}
} else if (!strncasecmp(t, "Content-length:", 15)) {
if ((t = strchr(t, ' '))) {
} else if (!strncasecmp(t, "Date:", 5)) {
if ((t = strchr(t, ' '))) {
t++;
- strncpy(reply->date, t, HTTP_REPLY_FIELD_SZ-1);
+ strncpy(reply->date, t, HTTP_REPLY_FIELD_SZ - 1);
}
} else if (!strncasecmp(t, "Expires:", 8)) {
if ((t = strchr(t, ' '))) {
t++;
- strncpy(reply->expires, t, HTTP_REPLY_FIELD_SZ-1);
+ strncpy(reply->expires, t, HTTP_REPLY_FIELD_SZ - 1);
}
} else if (!strncasecmp(t, "Last-Modified:", 14)) {
if ((t = strchr(t, ' '))) {
t++;
- strncpy(reply->last_modified, t, HTTP_REPLY_FIELD_SZ-1);
+ strncpy(reply->last_modified, t, HTTP_REPLY_FIELD_SZ - 1);
}
}
t = strtok(NULL, "\n");
storeSetPrivateKey(entry);
storeExpireNow(entry);
BIT_RESET(entry->flag, CACHABLE);
- storeReleaseRequest(entry, __FILE__,__LINE__);
+ storeReleaseRequest(entry, __FILE__, __LINE__);
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, __FILE__, __LINE__);
cached_error_entry(entry, ERR_READ_ERROR, xstrerror());
httpCloseAndFree(fd, data);
}
-/* $Id: store.cc,v 1.35 1996/04/09 23:27:59 wessels Exp $ */
-#ident "$Id: store.cc,v 1.35 1996/04/09 23:27:59 wessels Exp $"
+/* $Id: store.cc,v 1.36 1996/04/09 23:28:36 wessels Exp $ */
+#ident "$Id: store.cc,v 1.36 1996/04/09 23:28:36 wessels Exp $"
/*
* DEBUG: Section 20 store
#define STORE_LOG_SWAPOUT 2
#define STORE_LOG_RELEASE 3
-static char *storeLogTags[] = {
- "CREATE",
- "SWAPIN",
- "SWAPOUT",
- "RELEASE"
+static char *storeLogTags[] =
+{
+ "CREATE",
+ "SWAPIN",
+ "SWAPOUT",
+ "RELEASE"
};
/* Now, this table is inaccessible to outsider. They have to use a method
{
MemObject *m = NULL;
m = (MemObject *) xcalloc(1, sizeof(MemObject));
- m->reply = (struct _http_reply *) xcalloc (1, sizeof(struct _http_reply));
+ m->reply = (struct _http_reply *) xcalloc(1, sizeof(struct _http_reply));
meta_data.store_in_mem_objects++;
debug(20, 3, "new_MemObject: returning %p\n", m);
return m;
destroy_StoreEntry(e);
}
-static char *time_describe (t)
- time_t t;
+static char *time_describe(t)
+ time_t t;
{
- static char buf[128];
+ static char buf[128];
- if (t < 60) {
- sprintf (buf, "%ds", (int) t);
- } else if (t < 3600) {
- sprintf(buf, "%dm", (int) t/60);
- } else if (t < 86400) {
- sprintf(buf, "%dh", (int) t/3600);
- } else if (t < 604800) {
- sprintf(buf, "%dD", (int) t/86400);
- } else if (t < 2592000) {
- sprintf(buf, "%dW", (int) t/604800);
- } else if (t < 31536000) {
- sprintf(buf, "%dM", (int) t/2592000);
- } else {
- sprintf(buf, "%dY", (int) t/31536000);
- }
- return buf;
+ if (t < 60) {
+ sprintf(buf, "%ds", (int) t);
+ } else if (t < 3600) {
+ sprintf(buf, "%dm", (int) t / 60);
+ } else if (t < 86400) {
+ sprintf(buf, "%dh", (int) t / 3600);
+ } else if (t < 604800) {
+ sprintf(buf, "%dD", (int) t / 86400);
+ } else if (t < 2592000) {
+ sprintf(buf, "%dW", (int) t / 604800);
+ } else if (t < 31536000) {
+ sprintf(buf, "%dM", (int) t / 2592000);
+ } else {
+ sprintf(buf, "%dY", (int) t / 31536000);
+ }
+ return buf;
}
static void storeLog(tag, e)
return status;
}
-void storeReleaseRequest (e, file, line)
- StoreEntry *e;
- char *file;
- int line;
+void storeReleaseRequest(e, file, line)
+ StoreEntry *e;
+ char *file;
+ int line;
{
- debug(20,1,"storeReleaseRequest: FROM %s:%d FOR '%s'\n",
- file, line, e->key ? e->key : e->url);
- BIT_SET(e->flag, RELEASE_REQUEST);
+ debug(20, 1, "storeReleaseRequest: FROM %s:%d FOR '%s'\n",
+ file, line, e->key ? e->key : e->url);
+ BIT_SET(e->flag, RELEASE_REQUEST);
}
/* unlock object, return -1 if object get released after unlock
debug(20, 0, "storeSetPublicKey: Making old '%s' private.\n", newkey);
e2 = (StoreEntry *) table_entry;
storeSetPrivateKey(e2);
- storeReleaseRequest(e2, __FILE__,__LINE__);
+ storeReleaseRequest(e2, __FILE__, __LINE__);
}
if (e->key)
storeHashDelete(e);
BIT_RESET(e->flag, ENTRY_PRIVATE);
} else {
BIT_RESET(e->flag, CACHABLE);
- storeReleaseRequest(e, __FILE__,__LINE__);
+ storeReleaseRequest(e, __FILE__, __LINE__);
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, __FILE__, __LINE__);
BIT_RESET(e->flag, CACHABLE);
storeExpireNow(e);
}
e->swap_status = NO_SWAP;
put_free_8k_page(page_ptr, __FILE__, __LINE__);
file_close(fd);
- storeReleaseRequest(e, __FILE__,__LINE__);
+ storeReleaseRequest(e, __FILE__, __LINE__);
if (e->swap_file_number != -1) {
file_map_bit_reset(e->swap_file_number);
safeunlink(filename, 0); /* remove it */
} else
return 1;
- storeReleaseRequest(e, __FILE__,__LINE__);
+ storeReleaseRequest(e, __FILE__, __LINE__);
BIT_RESET(e->flag, CACHABLE);
return 0;
}
storeExpireNow(e);
debug(20, 3, "storeRelease: Only setting RELEASE_REQUEST bit\n");
if (!BIT_TEST(e->flag, RELEASE_REQUEST))
- storeReleaseRequest(e, __FILE__,__LINE__);
+ storeReleaseRequest(e, __FILE__, __LINE__);
return -1;
}
if (e->key != NULL) {
e->object_len);
if (hptr)
storeHashDelete(hptr);
- storeLog(STORE_LOG_RELEASE,e);
+ storeLog(STORE_LOG_RELEASE, e);
storeFreeEntry(e);
return 0;
}
fatal_dump("storeEntryValidLength: NULL mem_obj");
hdr_sz = e->mem_obj->reply->hdr_sz;
- content_length = e->mem_obj->reply->content_length;
+ content_length = e->mem_obj->reply->content_length;
debug(20, 3, "storeEntryValidLength: Checking '%s'\n", e->key);
debug(20, 5, "storeEntryValidLength: object_len = %d\n", e->object_len);
{
int dir_created;
- storelog_fd = file_open("store.log", NULL, O_WRONLY|O_APPEND|O_CREAT);
+ storelog_fd = file_open("store.log", NULL, O_WRONLY | O_APPEND | O_CREAT);
storeSanityCheck();
file_map_create(MAX_SWAP_FILE);