/*
- * $Id: fd.cc,v 1.32 1999/01/19 02:24:24 wessels Exp $
+ * $Id: fd.cc,v 1.33 1999/01/19 17:41:02 wessels Exp $
*
* DEBUG: section 51 Filedescriptor Functions
* AUTHOR: Duane Wessels
RESERVED_FD, new);
RESERVED_FD = new;
}
-
-void
-fdTouchFL(int fd, const char *file, int line)
-{
- fde *F;
- if (fd < 0)
- return;
- F = &fd_table[fd];
- assert(F->flags.open);
- F->last.file = file;
- F->last.line = line;
-}
/*
- * $Id: protos.h,v 1.305 1999/01/19 02:24:29 wessels Exp $
+ * $Id: protos.h,v 1.306 1999/01/19 17:41:03 wessels Exp $
*
*
* SQUID Internet Object Cache http://squid.nlanr.net/Squid/
extern void fdDumpOpen(void);
extern int fdNFree(void);
extern void fdAdjustReserved(void);
-extern void fdTouchFL(int, const char *, int);
extern fileMap *file_map_create(int);
extern int file_map_allocate(fileMap *, int);
/*
- * $Id: squid.h,v 1.184 1999/01/18 22:23:39 wessels Exp $
+ * $Id: squid.h,v 1.185 1999/01/19 17:41:04 wessels Exp $
*
* AUTHOR: Duane Wessels
*
#define leakFree(p) p
#endif
-#define fdTouch(f) fdTouchFL(f,__FILE__,__LINE__)
-
#if defined(_SQUID_NEXT_) && !defined(S_ISDIR)
#define S_ISDIR(mode) (((mode) & (_S_IFMT)) == (_S_IFDIR))
#endif
/*
- * $Id: stat.cc,v 1.309 1999/01/19 02:24:31 wessels Exp $
+ * $Id: stat.cc,v 1.310 1999/01/19 17:41:05 wessels Exp $
*
* DEBUG: section 18 Cache Manager Statistics
* AUTHOR: Harvest Derived
f = &fd_table[i];
if (!f->flags.open)
continue;
- storeAppendPrintf(sentry, "%4d %-6.6s %4d %7d %7d %-21s %20s:%-5d %s\n",
+ storeAppendPrintf(sentry, "%4d %-6.6s %4d %7d %7d %-21s %s\n",
i,
fdTypeStr[f->type],
f->timeout_handler ? (int) (f->timeout - squid_curtime) / 60 : 0,
f->bytes_read,
f->bytes_written,
fdRemoteAddr(f),
- f->last.line ? f->last.file : null_string,
- f->last.line,
f->desc);
}
}
/*
- * $Id: store_client.cc,v 1.55 1999/01/18 22:23:44 wessels Exp $
+ * $Id: store_client.cc,v 1.56 1999/01/19 17:41:06 wessels Exp $
*
* DEBUG: section 20 Storage Manager Client-Side Interface
* AUTHOR: Duane Wessels
callback(sc->callback_data, sc->copy_buf, -1);
return;
}
- fdTouch(fd);
sc->swapin_fd = fd;
storeClientFileRead(sc);
}
#ifdef OPTIMISTIC_IO
sc->flags.disk_io_pending = 1;
#endif
- fdTouch(sc->swapin_fd);
if (mem->swap_hdr_sz == 0) {
file_read(sc->swapin_fd,
sc->copy_buf,
store_client *sc = data;
MemObject *mem = sc->entry->mem_obj;
STCB *callback = sc->callback;
- fdTouch(fd);
assert(sc->flags.disk_io_pending);
sc->flags.disk_io_pending = 0;
assert(sc->callback != NULL);
size_t body_sz;
size_t copy_sz;
tlv *tlv_list;
- fdTouch(fd);
assert(sc->flags.disk_io_pending);
sc->flags.disk_io_pending = 0;
assert(sc->callback != NULL);
callback(sc->callback_data, sc->copy_buf, len);
return;
}
- fdTouch(fd);
tlv_list = storeSwapMetaUnpack(buf, &swap_hdr_sz);
if (tlv_list == NULL) {
debug(20, 1) ("storeClientReadHeader: failed to unpack meta data\n");
callback(sc->callback_data, sc->copy_buf, -1);
return;
}
- fdTouch(fd);
/*
* XXX Here we should check the meta data and make sure we got
* the right object.
callback(sc->callback_data, sc->copy_buf, copy_sz);
return;
}
- fdTouch(fd);
/*
* we don't have what the client wants, but at least we now
* know the swap header size.
*S = sc->next;
mem->nclients--;
sc->flags.disk_io_pending = 0;
- fdTouch(sc->swapin_fd);
if (e->store_status == STORE_OK && e->swap_status != SWAPOUT_DONE)
storeCheckSwapOut(e);
if (sc->swapin_fd > -1) {
/*
- * $Id: store_swapin.cc,v 1.15 1999/01/18 22:23:44 wessels Exp $
+ * $Id: store_swapin.cc,v 1.16 1999/01/19 17:41:07 wessels Exp $
*
* DEBUG: section 20 Storage Manager Swapin Functions
* AUTHOR: Duane Wessels
xfree(ctrlp);
return;
}
- fdTouch(fd);
assert(mem != NULL);
assert(e->mem_status == NOT_IN_MEMORY);
assert(e->swap_status == SWAPOUT_WRITING || e->swap_status == SWAPOUT_DONE);
/*
- * $Id: store_swapout.cc,v 1.43 1999/01/18 22:23:45 wessels Exp $
+ * $Id: store_swapout.cc,v 1.44 1999/01/19 17:41:08 wessels Exp $
*
* DEBUG: section 20 Storage Manager Swapout Functions
* AUTHOR: Duane Wessels
StoreEntry *e = ctrlp->e;
MemObject *mem = e->mem_obj;
debug(20, 3) ("storeSwapOutHandle: '%s', len=%d\n", storeKeyText(e->key), (int) len);
- fdTouch(fdnotused);
if (flag < 0) {
debug(20, 1) ("storeSwapOutHandle: SwapOut failure (err code = %d).\n",
flag);
storeSwapOutFileClose(e);
return;
}
- fdTouch(fdnotused);
#if USE_ASYNC_IO
if (mem == NULL) {
debug(20, 1) ("storeSwapOutHandle: mem == NULL : Cancelling swapout\n");
storeCheckSwapOut(e);
return;
}
- fdTouch(fdnotused);
/* swapping complete */
debug(20, 5) ("storeSwapOutHandle: SwapOut complete: '%s' to %s.\n",
storeUrl(e), storeSwapFullPath(e->swap_file_number, NULL));
storeLog(STORE_LOG_SWAPOUT, e);
storeDirSwapLog(e, SWAP_LOG_ADD);
}
- fdTouch(fdnotused);
/* Note, we don't otherwise call storeReleaseRequest() here because
* storeCheckCachable() does it for is if necessary */
storeSwapOutFileClose(e);
debug(20, 3) ("storeCheckSwapOut: swapping out %d bytes from %d\n",
swap_buf_len, (int) mem->swapout.queue_offset);
mem->swapout.queue_offset += swap_buf_len - hdr_len;
- fdTouch(mem->swapout.fd);
file_write(mem->swapout.fd,
-1,
swap_buf,
int swap_hdr_sz = 0;
tlv *tlv_list;
char *buf;
- fdTouch(fd);
if (fd == -2 && errcode == -2) { /* Cancelled - Clean up */
xfree(ctrlp->swapfilename);
cbdataFree(ctrlp);
/*
- * $Id: structs.h,v 1.263 1999/01/19 05:24:49 wessels Exp $
+ * $Id: structs.h,v 1.264 1999/01/19 17:41:09 wessels Exp $
*
*
* SQUID Internet Object Cache http://squid.nlanr.net/Squid/
DEFER *defer_check; /* check if we should defer read */
void *defer_data;
CommWriteStateData *rwstate; /* State data for comm_write */
- struct {
- const char *file;
- int line;
- } last;
};
struct _fileMap {