开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > 浏览器 > 查看源码
spool.c
资源名称：wwwoffle-2.5e.tgz　[点击查看]
上传用户：seven77cht
上传日期：2007-01-04
资源大小：486k
文件大小：33k
源码类别：

浏览器

开发平台：

Unix_Linux

spool.c：源码内容
  1. /***************************************
  2.   $Header: /home/amb/wwwoffle/RCS/spool.c 2.50 1999/11/27 16:02:28 amb Exp $
  4.   WWWOFFLE - World Wide Web Offline Explorer - Version 2.5c.
  5.   Handle all of the spooling of files in the spool directory.
  6.   ******************/ /******************
  7.   Written by Andrew M. Bishop
  9.   This file Copyright 1996,97,98,99 Andrew M. Bishop
  10.   It may be distributed under the GNU Public License, version 2, or
  11.   any higher version.  See section COPYING of the GNU Public license
  12.   for conditions under which this file may be redistributed.
  13.   ***************************************/
  16. #include <stdio.h>
  17. #include <stdlib.h>
  18. #include <string.h>
  20. #include <time.h>
  21. #include <utime.h>
  22. #include <sys/stat.h>
  23. #include <dirent.h>
  24. #include <unistd.h>
  25. #include <fcntl.h>
  26. #include <errno.h>
  27. #include <ctype.h>
  29. #include "wwwoffle.h"
  30. #include "misc.h"
  31. #include "errors.h"
  32. #include "config.h"
  35. /*+ Need this for Win32 to use binary mode +*/
  36. #ifndef O_BINARY
  37. #define O_BINARY 0
  38. #endif
  41. /*++++++++++++++++++++++++++++++++++++++
  42.   Open a file in the outgoing directory to write into / read from.
  44.   int OpenOutgoingSpoolFile Returns a file descriptor, or -1 on failure.
  46.   int rw Set to true to read, else false.
  47.   ++++++++++++++++++++++++++++++++++++++*/
  49. int OpenOutgoingSpoolFile(int rw)
  50. {
  51.  struct stat buf;
  52.  int fd=-1;
  53.  char name[16];
  55.  sprintf(name,"tmp.%ld",(long)getpid());
  57.  /* Create the outgoing directory if needed and change to it */
  59.  if(lstat("outgoing",&buf))
  60.    {
  61.     PrintMessage(Inform,"Directory 'outgoing' does not exist [%!s]; creating one.");
  62.     if(mkdir("outgoing",DirPerm))
  63.       {PrintMessage(Warning,"Cannot create directory 'outgoing' [%!s].");return(-1);}
  64.    }
  65.  else
  66.     if(!S_ISDIR(buf.st_mode))
  67.       {PrintMessage(Warning,"The file 'outgoing' is not a directory.");return(-1);}
  69.  if(chdir("outgoing"))
  70.    {PrintMessage(Warning,"Cannot change to directory 'outgoing' [%!s].");return(-1);}
  72.  /* Open the outgoing file */
  74.  if(rw)
  75.    {
  76.     struct dirent* ent;
  77.     DIR *dir=opendir(".");
  79.     if(!dir)
  80.       {PrintMessage(Warning,"Cannot open current directory 'outgoing' [%!s].");chdir("..");return(-1);}
  82.     ent=readdir(dir);  /* skip .  */
  83.     if(!ent)
  84.       {PrintMessage(Warning,"Cannot read current directory 'outgoing' [%!s].");closedir(dir);chdir("..");return(-1);}
  85.     ent=readdir(dir);  /* skip .. */
  87.     while((ent=readdir(dir)))
  88.        if(*ent->d_name=='O')
  89.          {
  90.           if(rename(ent->d_name,name))
  91.              PrintMessage(Inform,"Cannot rename file 'outgoing/%s' to 'outgoing/%s' [%!s]; race condition?",ent->d_name,name);
  92.           else
  93.             {
  94.              fd=open(name,O_RDONLY|O_BINARY);
  96.              if(fd==-1)
  97.                 PrintMessage(Inform,"Cannot open file 'outgoing/%s' [%!s]; race condition?",name);
  98.              else
  99.                {
  100.                 *ent->d_name='U';
  101.                 unlink(ent->d_name);
  102.                 unlink(name);
  103.                 break;
  104.                }
  105.             }
  106.          }
  107.     closedir(dir);
  108.    }
  109.  else
  110.    {
  111.     fd=open(name,O_WRONLY|O_CREAT|O_EXCL|O_BINARY,FilePerm);
  112.     if(fd==-1)
  113.        PrintMessage(Warning,"Cannot open file 'outgoing/%s' [%!s]",name);
  114.    }
  116.  /* Change dir back and tidy up. */
  118.  chdir("..");
  120.  return(fd);
  121. }
  124. /*++++++++++++++++++++++++++++++++++++++
  125.   Close an outgoing spool file and rename it to the hashed name.
  127.   int fd The file descriptor to close.
  129.   URL *Url The URL to close.
  130.   ++++++++++++++++++++++++++++++++++++++*/
  132. void CloseOutgoingSpoolFile(int fd,URL *Url)
  133. {
  134.  char oldname[16],*newname;
  135.  int ufd;
  137.  close(fd);
  139.  /* Change to the outgoing directory. */
  141.  if(chdir("outgoing"))
  142.    {PrintMessage(Warning,"Cannot change to directory 'outgoing' [%!s].");return;}
  144.  /* Create and rename the file */
  146.  sprintf(oldname,"tmp.%ld",(long)getpid());
  148.  newname=URLToFileName(Url);
  149.  *newname='U';
  151.  unlink(newname);
  152.  ufd=open(newname,O_WRONLY|O_CREAT|O_EXCL|O_BINARY,FilePerm);
  153.  if(ufd!=-1)
  154.    {
  155.     write_string(ufd,Url->file);
  156.     close(ufd);
  157.    }
  159.  *newname='O';
  160.  if(rename(oldname,newname))
  161.    {PrintMessage(Warning,"Cannot rename 'outgoing/%s' to 'outgoing/%s' [%!s].",oldname,newname);unlink(oldname);}
  163.  /* Change dir back and tidy up. */
  165.  chdir("..");
  167.  free(newname);
  168. }
  171. /*++++++++++++++++++++++++++++++++++++++
  172.   Check if a specified URL exists in the outgoing directory.
  174.   int ExistsOutgoingSpoolFile Returns a boolean.
  176.   URL *Url The URL to check for.
  177.   ++++++++++++++++++++++++++++++++++++++*/
  179. int ExistsOutgoingSpoolFile(URL *Url)
  180. {
  181.  struct stat buf;
  182.  char *name;
  183.  int exists=0;
  185.  if(chdir("outgoing"))
  186.    {PrintMessage(Warning,"Cannot change to directory 'outgoing' [%!s].");return(0);}
  188.  /* Stat the outgoing file */
  190.  name=URLToFileName(Url);
  191.  *name='O';
  193.  exists=!stat(name,&buf);
  195.  /* Change dir back and tidy up. */
  197.  chdir("..");
  199.  free(name);
  201.  return(exists);
  202. }
  205. /*++++++++++++++++++++++++++++++++++++++
  206.   Create a hash value from the request for a specified URL in the outgoing directory.
  208.   int HashOutgoingSpoolFile Returns a hash string or NULL in error.
  210.   URL *Url The URL to create the hash for.
  211.   ++++++++++++++++++++++++++++++++++++++*/
  213. char *HashOutgoingSpoolFile(URL *Url)
  214. {
  215.  char *name,*req,*hash;
  216.  int fd,r;
  218.  if(chdir("outgoing"))
  219.    {PrintMessage(Warning,"Cannot change to directory 'outgoing' [%!s].");return(NULL);}
  221.  /* Read the outgoing file */
  223.  name=URLToFileName(Url);
  224.  *name='O';
  226.  fd=open(name,O_RDONLY|O_BINARY);
  227.  if(fd==-1)
  228.    {PrintMessage(Warning,"Cannot open outgoing request to create hash [%!s].");free(name);chdir("..");return(NULL);}
  230.  req=(char*)malloc(256+1);
  232.  r=read(fd,req,256);
  233.  if(r==256)
  234.    {
  235.     int rr=0;
  236.     do
  237.       {
  238.        r+=rr;
  239.        req=(char*)realloc(req,r+256+1);
  240.       }
  241.     while((rr=read(fd,&req[r],256))>0);
  242.    }
  243.  else if(r==-1)
  244.    {PrintMessage(Warning,"Cannot read from outgoing request to create hash [%!s].");close(fd);free(name);free(req);chdir("..");return(NULL);}
  246.  req[r]=0;
  248.  close(fd);
  250.  hash=MakeHash(req);
  252.  /* Change dir back and tidy up. */
  254.  chdir("..");
  256.  free(name);
  257.  free(req);
  259.  return(hash);
  260. }
  263. /*++++++++++++++++++++++++++++++++++++++
  264.   Delete a specified URL request from the outgoing requests.
  266.   char *DeleteOutgoingSpoolFile Returns NULL if OK else error message.
  268.   URL *Url The URL to delete or NULL for all of them.
  269.   ++++++++++++++++++++++++++++++++++++++*/
  271. char *DeleteOutgoingSpoolFile(URL *Url)
  272. {
  273.  char *err=NULL;
  275.  /* Change to the outgoing directory. */
  277.  if(chdir("outgoing"))
  278.    {err=PrintMessage(Warning,"Cannot change to directory 'outgoing' [%!s].");return(err);}
  280.  /* Delete the file for the request or all of them. */
  282.  if(Url)
  283.    {
  284.     char *name;
  286.     name=URLToFileName(Url);
  287.     *name='O';
  289.     if(unlink(name))
  290.        err=PrintMessage(Warning,"Cannot unlink outgoing request 'outgoing/%s' [%!s].",name);
  292.     *name='U';
  293.     unlink(name);
  295.     free(name);
  296.    }
  297.  else
  298.    {
  299.     struct dirent* ent;
  300.     DIR *dir=opendir(".");
  302.     if(!dir)
  303.       {err=PrintMessage(Warning,"Cannot open current directory 'outgoing' [%!s].");chdir("..");return(err);}
  305.     ent=readdir(dir);  /* skip .  */
  306.     if(!ent)
  307.       {err=PrintMessage(Warning,"Cannot read current directory 'outgoing' [%!s].");closedir(dir);chdir("..");return(err);}
  308.     ent=readdir(dir);  /* skip .. */
  310.     while((ent=readdir(dir)))
  311.       {
  312.        if(unlink(ent->d_name))
  313.           err=PrintMessage(Warning,"Cannot unlink outgoing request 'outgoing/%s' [%!s].",ent->d_name);
  314.       }
  316.     closedir(dir);
  317.    }
  319.  /* Change dir back and tidy up. */
  321.  chdir("..");
  323.  return(err);
  324. }
  327. /*++++++++++++++++++++++++++++++++++++++
  328.   Open a file in a spool subdirectory to write into / read from.
  330.   int OpenWebpageSpoolFile Returns a file descriptor.
  332.   int rw Set to 1 to read, 0 to write.
  334.   URL *Url The URL to open.
  335.   ++++++++++++++++++++++++++++++++++++++*/
  337. int OpenWebpageSpoolFile(int rw,URL *Url)
  338. {
  339.  struct stat buf;
  340.  char *file;
  341.  int fd=-1;
  343.  /* Create the spool directory if needed and change to it. */
  345.  if(lstat(Url->proto,&buf))
  346.    {
  347.     PrintMessage(Inform,"Directory '%s' does not exist [%!s]; creating one.",Url->proto);
  348.     if(mkdir(Url->proto,DirPerm))
  349.       {PrintMessage(Warning,"Cannot create directory '%s' [%!s].",Url->proto);return(-1);}
  350.    }
  351.  else
  352.     if(!S_ISDIR(buf.st_mode))
  353.       {PrintMessage(Warning,"The file '%s' is not a directory.",Url->proto);return(-1);}
  355.  if(chdir(Url->proto))
  356.    {PrintMessage(Warning,"Cannot change to directory '%s' [%!s].",Url->proto);return(-1);}
  358.  if(lstat(Url->dir,&buf))
  359.    {
  360.     PrintMessage(Inform,"Directory '%s/%s' does not exist [%!s]; creating one.",Url->proto,Url->dir);
  361.     if(mkdir(Url->dir,DirPerm))
  362.       {PrintMessage(Warning,"Cannot create directory '%s/%s' [%!s].",Url->proto,Url->dir);chdir("..");return(-1);}
  363.    }
  364.  else
  365.     if(!S_ISDIR(buf.st_mode))
  366.       {PrintMessage(Warning,"The file '%s/%s' is not a directory.",Url->proto,Url->dir);chdir("..");return(-1);}
  368.  if(chdir(Url->dir))
  369.    {PrintMessage(Warning,"Cannot change to directory '%s/%s' [%!s].",Url->proto,Url->dir);chdir("..");return(-1);}
  371.  /* Open the file for the web page. */
  373.  file=URLToFileName(Url);
  375.  *file='D';
  376.  if(rw)
  377.     fd=open(file,O_RDONLY|O_BINARY);
  378.  else
  379.     fd=open(file,O_RDWR|O_CREAT|O_BINARY,FilePerm);
  381.  if(!rw && fd!=-1)
  382.    {
  383.     int ufd;
  385.     *file='U';
  386.     ufd=open(file,O_WRONLY|O_CREAT|O_TRUNC|O_BINARY,FilePerm);
  388.     if(ufd!=-1)
  389.       {
  390.        write_string(ufd,Url->file);
  391.        close(ufd);
  392.       }
  393.     else
  394.       {
  395.        close(fd);
  396.        fd=-1;
  397.       }
  398.    }
  400.  /* Change the modification time on the directory. */
  402.  if(!rw && fd!=-1)
  403.     utime(".",NULL);
  405.  chdir("..");
  407.  if(!rw && fd!=-1)
  408.     utime(".",NULL);
  410.  /* Change dir back and tidy up. */
  412.  chdir("..");
  414.  free(file);
  416.  return(fd);
  417. }
  420. /*++++++++++++++++++++++++++++++++++++++
  421.   Delete a file in a spool subdirectory.
  423.   char *DeleteWebpageSpoolFile Return NULL if OK else error message.
  425.   URL *Url The URL to delete.
  427.   int all If set then delete all pages from this host.
  428.   ++++++++++++++++++++++++++++++++++++++*/
  430. char *DeleteWebpageSpoolFile(URL *Url,int all)
  431. {
  432.  char *err=NULL;
  434.  /* Change to the spool directory. */
  436.  if(chdir(Url->proto))
  437.    {err=PrintMessage(Warning,"Cannot change to directory '%s' [%!s].",Url->proto);return(err);}
  439.  if(chdir(Url->dir))
  440.    {err=PrintMessage(Warning,"Cannot change to directory '%s/%s' [%!s].",Url->proto,Url->dir);chdir("..");return(err);}
  442.  /* Delete the file for the web page. */
  444.  if(all)
  445.    {
  446.     struct dirent* ent;
  447.     DIR *dir=opendir(".");
  449.     if(!dir)
  450.       {err=PrintMessage(Warning,"Cannot open current directory '%s/%s' [%!s].",Url->proto,Url->dir);chdir("../..");return(err);}
  452.     ent=readdir(dir);  /* skip .  */
  453.     if(!ent)
  454.       {err=PrintMessage(Warning,"Cannot read current directory '%s/%s' [%!s].",Url->proto,Url->dir);closedir(dir);chdir("../..");return(err);}
  455.     ent=readdir(dir);  /* skip .. */
  457.     while((ent=readdir(dir)))
  458.       {
  459.        if(*ent->d_name=='D')
  460.          {
  461.           char *delurl;
  463.           if((delurl=FileNameToURL(ent->d_name)))
  464.             {
  465.              URL *delUrl=SplitURL(delurl);
  467.              chdir("../..");
  469.              if(ExistsLastTimeSpoolFile(delUrl))
  470.                 DeleteLastTimeSpoolFile(delUrl);
  472.              chdir(Url->proto);
  473.              chdir(Url->dir);
  475.              free(delurl);
  476.              FreeURL(delUrl);
  477.             }
  478.          }
  480.        if(unlink(ent->d_name))
  481.           err=PrintMessage(Warning,"Cannot unlink cached file '%s/%s/%s' [%!s].",Url->proto,Url->dir,ent->d_name);
  482.       }
  484.     closedir(dir);
  486.     chdir("..");
  488.     if(rmdir(Url->dir))
  489.       err=PrintMessage(Warning,"Cannot delete what should be an empty directory '%s/%s' [%!s].",Url->proto,Url->dir);
  491.     chdir("..");
  492.    }
  493.  else
  494.    {
  495.     char *file=URLToFileName(Url);
  496.     struct stat buf;
  497.     int didstat=1;
  499.     if(stat(".",&buf))
  500.        PrintMessage(Warning,"Cannot stat directory '%s/%s' [%!s].",Url->proto,Url->dir);
  501.     else
  502.        didstat=1;
  504.     *file='D';
  505.     if(unlink(file))
  506.        err=PrintMessage(Warning,"Cannot unlink cached file '%s/%s/%s' [%!s].",Url->proto,Url->dir,file);
  508.     *file='U';
  509.     unlink(file);
  511.     free(file);
  513.     if(didstat)
  514.       {
  515.        struct utimbuf utbuf;
  517.        utbuf.actime=time(NULL);
  518.        utbuf.modtime=buf.st_mtime;
  519.        utime(".",&utbuf);
  520.       }
  522.     chdir("../..");
  524.     if(ExistsLastTimeSpoolFile(Url))
  525.        DeleteLastTimeSpoolFile(Url);
  526.    }
  528.  return(err);
  529. }
  532. /*++++++++++++++++++++++++++++++++++++++
  533.   Touch a file in a spool subdirectory.
  535.   URL *Url The URL to touch.
  537.   time_t when The time to set the access time to.
  538.   ++++++++++++++++++++++++++++++++++++++*/
  540. void TouchWebpageSpoolFile(URL *Url,time_t when)
  541. {
  542.  char *file;
  544.  /* Change to the spool directory. */
  546.  if(chdir(Url->proto))
  547.    {PrintMessage(Warning,"Cannot change to directory '%s' [%!s].",Url->proto);return;}
  549.  if(chdir(Url->dir))
  550.    {PrintMessage(Warning,"Cannot change to directory '%s/%s' [%!s].",Url->proto,Url->dir);chdir("..");return;}
  552.  /* Touch the file for the web page. */
  554.  file=URLToFileName(Url);
  556.  *file='D';
  558.  if(when)
  559.    {
  560.     struct stat buf;
  562.     if(stat(file,&buf))
  563.        utime(file,NULL);
  564.     else
  565.       {
  566.        struct utimbuf ubuf;
  568.        ubuf.actime=when;
  569.        ubuf.modtime=buf.st_mtime;
  571.        utime(file,&ubuf);
  572.       }
  573.    }
  574.  else
  575.     utime(file,NULL);
  577.  /* Change dir back and tidy up. */
  579.  chdir("../..");
  581.  free(file);
  582. }
  585. /*++++++++++++++++++++++++++++++++++++++
  586.   Check if a file in a spool subdirectory exists.
  588.   time_t ExistsWebpageSpoolFile Return a the time the page was last accessed if the page exists.
  590.   URL *Url The URL to check for.
  591.   ++++++++++++++++++++++++++++++++++++++*/
  593. time_t ExistsWebpageSpoolFile(URL *Url)
  594. {
  595.  struct stat buf;
  596.  char *file;
  598.  /* Change to the spool directory. */
  600.  if(chdir(Url->proto))
  601.     return(0);
  603.  if(chdir(Url->dir))
  604.    {chdir("..");return(0);}
  606.  /* Stat the file for the web page. */
  608.  file=URLToFileName(Url);
  609.  *file='D';
  611.  if(stat(file,&buf))
  612.     buf.st_atime=0;
  614.  /* Change dir back and tidy up. */
  616.  chdir("../..");
  618.  free(file);
  620.  return(buf.st_atime);
  621. }
  624. /*++++++++++++++++++++++++++++++++++++++
  625.   Create a backup copy of a file in a spool subdirectory.
  627.   URL *Url The URL to make a copy of.
  628.   ++++++++++++++++++++++++++++++++++++++*/
  630. void CreateBackupWebpageSpoolFile(URL *Url)
  631. {
  632.  struct stat buf;
  633.  char *bakfile,*orgfile;
  635.  /* Change to the spool directory. */
  637.  if(chdir(Url->proto))
  638.    {PrintMessage(Warning,"Cannot change to directory '%s' [%!s].",Url->proto);return;}
  640.  if(chdir(Url->dir))
  641.    {PrintMessage(Warning,"Cannot change to directory '%s/%s' [%!s].",Url->proto,Url->dir);chdir("..");return;}
  643.  /* Create the filenames and rename the files. */
  645.  orgfile=URLToFileName(Url);
  647.  bakfile=(char*)malloc(strlen(orgfile)+2);
  648.  strcpy(bakfile,orgfile);
  650.  *bakfile=*orgfile='D';
  651.  strcat(bakfile,"~");
  653.  if(!stat(bakfile,&buf))
  654.     PrintMessage(Inform,"Backup already exists for '%s'.",Url->name);
  655.  else
  656.    {
  657.     if(rename(orgfile,bakfile))
  658.        PrintMessage(Warning,"Cannot rename backup cached file '%s/%s/%s' to %s [%!s].",Url->proto,Url->dir,bakfile,orgfile);
  660.     *bakfile=*orgfile='U';
  661.     rename(orgfile,bakfile);
  662.    }
  664.  /* Change dir back and tidy up. */
  666.  chdir("../..");
  668.  free(bakfile);
  669.  free(orgfile);
  670. }
  673. /*++++++++++++++++++++++++++++++++++++++
  674.   Restore the backup copy of a file in a spool subdirectory.
  676.   URL *Url The URL to restore.
  677.   ++++++++++++++++++++++++++++++++++++++*/
  679. void RestoreBackupWebpageSpoolFile(URL *Url)
  680. {
  681.  struct stat buf;
  682.  char *bakfile,*orgfile;
  684.  /* Change to the spool directory. */
  686.  if(chdir(Url->proto))
  687.    {PrintMessage(Warning,"Cannot change to directory '%s' [%!s].",Url->proto);return;}
  689.  if(chdir(Url->dir))
  690.    {PrintMessage(Warning,"Cannot change to directory '%s/%s' [%!s].",Url->proto,Url->dir);chdir("..");return;}
  692.  /* Create the filenames and rename the files. */
  694.  orgfile=URLToFileName(Url);
  696.  bakfile=(char*)malloc(strlen(orgfile)+2);
  697.  strcpy(bakfile,orgfile);
  699.  *bakfile=*orgfile='D';
  700.  strcat(bakfile,"~");
  702.  if(!stat(bakfile,&buf))
  703.    {
  704.     if(rename(bakfile,orgfile))
  705.        PrintMessage(Warning,"Cannot rename backup cached file '%s/%s/%s' to %s [%!s].",Url->proto,Url->dir,bakfile,orgfile);
  707.     *bakfile=*orgfile='U';
  708.     rename(bakfile,orgfile);
  709.    }
  711.  /* Change dir back and tidy up. */
  713.  chdir("../..");
  715.  free(bakfile);
  716.  free(orgfile);
  717. }
  720. /*++++++++++++++++++++++++++++++++++++++
  721.   Delete a file in a spool subdirectory.
  723.   URL *Url The URL to delete.
  724.   ++++++++++++++++++++++++++++++++++++++*/
  726. void DeleteBackupWebpageSpoolFile(URL *Url)
  727. {
  728.  char *bakfile;
  730.  /* Change to the spool directory. */
  732.  if(chdir(Url->proto))
  733.    {PrintMessage(Warning,"Cannot change to directory '%s' [%!s].",Url->proto);return;}
  735.  if(chdir(Url->dir))
  736.    {PrintMessage(Warning,"Cannot change to directory '%s/%s' [%!s].",Url->proto,Url->dir);chdir("..");return;}
  738.  /* Delete the file for the backup web page. */
  740.  bakfile=URLToFileName(Url);
  742.  *bakfile='D';
  743.  strcat(bakfile,"~");
  745.  if(unlink(bakfile))
  746.     PrintMessage(Warning,"Cannot unlink backup cached file '%s/%s/%s' [%!s].",Url->proto,Url->dir,bakfile);
  748.  *bakfile='U';
  749.  unlink(bakfile);
  751.  /* Change dir back and tidy up. */
  753.  chdir("../..");
  755.  free(bakfile);
  756. }
  759. /*++++++++++++++++++++++++++++++++++++++
  760.   Create a lock file in a spool subdirectory.
  762.   URL *Url The URL to lock.
  763.   ++++++++++++++++++++++++++++++++++++++*/
  765. void CreateLockWebpageSpoolFile(URL *Url)
  766. {
  767.  struct stat buf;
  768.  char *lokfile,*orgfile;
  770.  /* Change to the spool directory. */
  772.  if(chdir(Url->proto))
  773.    {PrintMessage(Warning,"Cannot change to directory '%s' [%!s].",Url->proto);return;}
  775.  if(chdir(Url->dir))
  776.    {PrintMessage(Warning,"Cannot change to directory '%s/%s' [%!s].",Url->proto,Url->dir);chdir("..");return;}
  778.  /* Create the lock file for the web page. */
  780.  orgfile=URLToFileName(Url);
  782.  lokfile=(char*)malloc(strlen(orgfile)+2);
  783.  strcpy(lokfile,orgfile);
  785.  *lokfile='L';
  786.  *orgfile='D';
  788.  if(!stat(lokfile,&buf))
  789.     PrintMessage(Inform,"Lock file already exists for '%s'.",Url->name);
  790.  else
  791.    {
  792.     if(link(orgfile,lokfile))
  793.        PrintMessage(Warning,"Cannot make a lock file for '%s/%s/%s' [%!s].",Url->proto,Url->dir,orgfile);
  794.    }
  796.  /* Change dir back and tidy up. */
  798.  chdir("../..");
  800.  free(lokfile);
  801.  free(orgfile);
  802. }
  805. /*++++++++++++++++++++++++++++++++++++++
  806.   Check for the existance of a lock file in a spool subdirectory.
  808.   int ExistsLockWebpageSpoolFile Return a true value if the lock file exists.
  810.   URL *Url The URL to check for the lock file for.
  811.   ++++++++++++++++++++++++++++++++++++++*/
  813. int ExistsLockWebpageSpoolFile(URL *Url)
  814. {
  815.  struct stat buf;
  816.  char *file;
  817.  int exists=0;
  819.  if(chdir(Url->proto))
  820.     return(0);
  822.  if(chdir(Url->dir))
  823.    {chdir("..");return(0);}
  825.  /* Stat the file for the web page. */
  827.  file=URLToFileName(Url);
  828.  *file='L';
  830.  exists=!stat(file,&buf);
  832.  /* Change dir back and tidy up. */
  834.  chdir("../..");
  836.  free(file);
  838.  return(exists);
  839. }
  842. /*++++++++++++++++++++++++++++++++++++++
  843.   Delete a lock file in a spool subdirectory.
  845.   URL *Url The URL with the lock to delete.
  846.   ++++++++++++++++++++++++++++++++++++++*/
  848. void DeleteLockWebpageSpoolFile(URL *Url)
  849. {
  850.  char *lokfile;
  852.  /* Change to the spool directory */
  854.  if(chdir(Url->proto))
  855.    {PrintMessage(Warning,"Cannot change to directory '%s' [%!s].",Url->proto);return;}
  857.  if(chdir(Url->dir))
  858.    {PrintMessage(Warning,"Cannot change to directory '%s/%s' [%!s].",Url->proto,Url->dir);chdir("..");return;}
  860.  /* Delete the file for the backup web page. */
  862.  lokfile=URLToFileName(Url);
  864.  *lokfile='L';
  866.  if(unlink(lokfile))
  867.     PrintMessage(Inform,"Cannot unlink lock file '%s/%s/%s' [%!s].",Url->proto,Url->dir,lokfile);
  869.  /* Change dir back and tidy up. */
  871.  chdir("../..");
  873.  free(lokfile);
  874. }
  877. /*++++++++++++++++++++++++++++++++++++++
  878.   Create a file in the lasttime directory.
  880.   int CreateLastTimeSpoolFile Returns 1 if the file already exists.
  882.   URL *Url The URL to create.
  883.   ++++++++++++++++++++++++++++++++++++++*/
  885. int CreateLastTimeSpoolFile(URL *Url)
  886. {
  887.  struct stat buf;
  888.  char *file;
  889.  int exists=0;
  891.  if(NoLasttimeIndex)
  892.     return(1);
  894.  /* Change to the last time directory */
  896.  if(chdir("lasttime"))
  897.    {PrintMessage(Warning,"Cannot change to directory 'lasttime' [%!s].");return(0);}
  899.  /* Create the file. */
  901.  file=URLToFileName(Url);
  902.  *file='D';
  904.  if(stat(file,&buf)==-1)
  905.    {
  906.     char *name=(char*)malloc(strlen(Url->proto)+strlen(Url->dir)+strlen(file)+8);
  907.     sprintf(name,"../%s/%s/%s",Url->proto,Url->dir,file);
  909.     if(link(name,file))
  910.       {PrintMessage(Warning,"Cannot create file 'lasttime/%s' [%!s].",file);}
  911.     else
  912.       {
  913.        *file='U';
  914.        sprintf(name,"../%s/%s/%s",Url->proto,Url->dir,file);
  916.        if(link(name,file))
  917.          {PrintMessage(Warning,"Cannot create file 'lasttime/%s' [%!s].",file);}
  918.       }
  920.     free(name);
  921.    }
  922.  else
  923.     exists=1;
  925.  /* Change dir back and tidy up. */
  927.  chdir("..");
  929.  free(file);
  931.  return(exists);
  932. }
  935. /*++++++++++++++++++++++++++++++++++++++
  936.   Determine if a particular URL exists in the last time spool directory.
  938.   int ExistsLastTimeSpoolFile Returns 1 if the URL exists.
  940.   URL *Url The URL to look for.
  941.   ++++++++++++++++++++++++++++++++++++++*/
  943. int ExistsLastTimeSpoolFile(URL *Url)
  944. {
  945.  struct stat buf;
  946.  int i,retval=0;
  947.  char *name=URLToFileName(Url);
  949.  *name='D';
  951.  for(i=0;i<=NUM_PREVTIME_DIR;i++)
  952.    {
  953.     char lasttime[40];
  955.     if(i)
  956.        sprintf(lasttime,"prevtime%d/%s",i,name);
  957.     else
  958.        sprintf(lasttime,"lasttime/%s",name);
  960.     if(!stat(lasttime,&buf))
  961.       {retval=1;break;}
  962.    }
  964.  free(name);
  966.  return(retval);
  967. }
  970. /*++++++++++++++++++++++++++++++++++++++
  971.   Delete a specified URL from the lasttime directory.
  973.   char *DeleteLastTimeSpoolFile Returns NULL if OK else error message.
  975.   URL *Url The URL to delete or NULL for all of them.
  976.   ++++++++++++++++++++++++++++++++++++++*/
  978. char *DeleteLastTimeSpoolFile(URL *Url)
  979. {
  980.  struct stat buf;
  981.  char *err=NULL;
  982.  int i;
  983.  char *name=URLToFileName(Url);
  985.  for(i=0;i<=NUM_PREVTIME_DIR;i++)
  986.    {
  987.     char lasttime[16];
  989.     if(i)
  990.        sprintf(lasttime,"prevtime%d",i);
  991.     else
  992.        strcpy(lasttime,"lasttime");
  994.     /* Change to the last time directory */
  996.     if(chdir(lasttime))
  997.       {PrintMessage(Warning,"Cannot change to directory '%s' [%!s].",lasttime);}
  998.     else
  999.       {
  1000.        *name='D';
  1002.        if(!stat(name,&buf))
  1003.          {
  1004.           if(unlink(name))
  1005.              err=PrintMessage(Warning,"Cannot unlink lasttime request '%s/%s' [%!s].",lasttime,name);
  1007.           *name='U';
  1008.           unlink(name);
  1009.          }
  1011.        chdir("..");
  1012.       }
  1013.    }
  1015.  free(name);
  1017.  return(err);
  1018. }
  1021. /*++++++++++++++++++++++++++++++++++++++
  1022.   Cycle the URLs from the lasttime directory down to the prevtime directories.
  1023.   ++++++++++++++++++++++++++++++++++++++*/
  1025. void CycleLastTimeSpoolFile(void)
  1026. {
  1027.  char lasttime[16],prevlasttime[16];
  1028.  struct stat buf;
  1029.  int i;
  1031.  /* Cycle the directories */
  1033.  for(i=NUM_PREVTIME_DIR;i>=0;i--)
  1034.    {
  1035.     if(i)
  1036.        sprintf(lasttime,"prevtime%d",i);
  1037.     else
  1038.        strcpy(lasttime,"lasttime");
  1040.     /* Create it if it does not exist. */
  1042.     if(lstat(lasttime,&buf))
  1043.       {
  1044.        PrintMessage(Inform,"Directory '%s' does not exist [%!s]; creating one.",lasttime);
  1045.        if(mkdir(lasttime,DirPerm))
  1046.           PrintMessage(Warning,"Cannot create directory '%s' [%!s].",lasttime);
  1047.       }
  1048.     else
  1049.        if(!S_ISDIR(buf.st_mode))
  1050.           PrintMessage(Warning,"The file '%s' is not a directory.",lasttime);
  1052.     /* Delete the contents of the oldest one, rename the newer ones. */
  1054.     if(i==NUM_PREVTIME_DIR)
  1055.       {
  1056.        DIR *dir;
  1057.        struct dirent* ent;
  1059.        if(chdir(lasttime))
  1060.          {PrintMessage(Warning,"Cannot change to directory '%s' [%!s].",lasttime);continue;}
  1062.        dir=opendir(".");
  1064.        if(!dir)
  1065.          {PrintMessage(Warning,"Cannot open current directory '%s' [%!s].",lasttime);chdir("..");continue;}
  1067.        ent=readdir(dir);  /* skip .  */
  1068.        if(!ent)
  1069.          {PrintMessage(Warning,"Cannot read current directory '%s' [%!s].",lasttime);closedir(dir);chdir("..");continue;}
  1070.        ent=readdir(dir);  /* skip .. */
  1072.        while((ent=readdir(dir)))
  1073.           if(unlink(ent->d_name))
  1074.              PrintMessage(Warning,"Cannot unlink previous time page '%s/%s' [%!s].",lasttime,ent->d_name);
  1076.        closedir(dir);
  1078.        chdir("..");
  1080.        if(rmdir(lasttime))
  1081.           PrintMessage(Warning,"Cannot unlink previous time directory '%s' [%!s].",lasttime);
  1082.       }
  1083.     else
  1084.        if(rename(lasttime,prevlasttime))
  1085.           PrintMessage(Warning,"Cannot rename previous time directory '%s' to '%s' [%!s].",lasttime,prevlasttime);
  1087.     strcpy(prevlasttime,lasttime);
  1088.    }
  1090.  if(mkdir("lasttime",DirPerm))
  1091.     PrintMessage(Warning,"Cannot create directory 'lasttime' [%!s].");
  1092. }
  1095. /*++++++++++++++++++++++++++++++++++++++
  1096.   Open a file in the monitor directory to write into.
  1098.   int CreateMonitorSpoolFile Returns a file descriptor, or -1 on failure.
  1100.   URL *Url The URL of the file to monitor.
  1102.   char MofY[13] A mask indicating the months of the year allowed.
  1104.   char DofM[32] A mask indicating the days of the month allowed.
  1106.   char DofW[8] A mask indicating the days of the week allowed.
  1108.   char HofD[25] A mask indicating the hours of the day allowed.
  1109.   ++++++++++++++++++++++++++++++++++++++*/
  1111. int CreateMonitorSpoolFile(URL *Url,char MofY[13],char DofM[32],char DofW[8],char HofD[25])
  1112. {
  1113.  struct stat buf;
  1114.  int fd=-1;
  1115.  char *file;
  1117.  /* Create the monitor directory if needed and change to it */
  1119.  if(lstat("monitor",&buf))
  1120.    {
  1121.     PrintMessage(Inform,"Directory 'monitor' does not exist [%!s]; creating one.");
  1122.     if(mkdir("monitor",DirPerm))
  1123.       {PrintMessage(Warning,"Cannot create directory 'monitor' [%!s].");return(-1);}
  1124.    }
  1125.  else
  1126.     if(!S_ISDIR(buf.st_mode))
  1127.       {PrintMessage(Warning,"The file 'monitor' is not a directory.");return(-1);}
  1129.  if(chdir("monitor"))
  1130.    {PrintMessage(Warning,"Cannot change to directory 'monitor' [%!s].");return(-1);}
  1132.  /* Open the monitor file */
  1134.  file=URLToFileName(Url);
  1136.  *file='O';
  1138.  fd=open(file,O_WRONLY|O_CREAT|O_TRUNC|O_BINARY,FilePerm);
  1140.  if(fd==-1)
  1141.    {PrintMessage(Warning,"Cannot create file 'monitor/%s' [%!s].",file);}
  1142.  else
  1143.    {
  1144.     int ufd,mfd;
  1146.     *file='U';
  1147.     ufd=open(file,O_WRONLY|O_CREAT|O_TRUNC|O_BINARY,FilePerm);
  1149.     if(ufd!=-1)
  1150.       {
  1151.        write_string(ufd,Url->file);
  1152.        close(ufd);
  1153.       }
  1154.     else
  1155.       {
  1156.        close(fd);
  1157.        fd=-1;
  1158.       }
  1160.     *file='M';
  1161.     mfd=open(file,O_WRONLY|O_CREAT|O_TRUNC|O_BINARY,FilePerm);
  1163.     if(mfd!=-1)
  1164.       {
  1165.        write_formatted(mfd,"%sn",MofY);
  1166.        write_formatted(mfd,"%sn",DofM);
  1167.        write_formatted(mfd,"%sn",DofW);
  1168.        write_formatted(mfd,"%sn",HofD);
  1169.        close(mfd);
  1170.       }
  1171.     else
  1172.       {
  1173.        close(fd);
  1174.        fd=-1;
  1175.       }
  1176.    }
  1178.  /* Change dir back and tidy up. */
  1180.  chdir("..");
  1182.  free(file);
  1184.  return(fd);
  1185. }
  1187. /*++++++++++++++++++++++++++++++++++++++
  1188.   Read a file containing the time to be monitored.
  1190.   long ReadMonitorTimesSpoolFile Returns the timestamp of the file.
  1192.   URL *Url The URL to read from.
  1194.   char MofY[13] Returns a mask indicating the months of the year allowed.
  1196.   char DofM[32] Returns a mask indicating the days of the month allowed.
  1198.   char DofW[8] Returns a mask indicating the days of the week allowed.
  1200.   char HofD[25] Returns a mask indicating the hours of the day allowed.
  1201.   ++++++++++++++++++++++++++++++++++++++*/
  1203. long ReadMonitorTimesSpoolFile(URL *Url,char MofY[13],char DofM[32],char DofW[8],char HofD[25])
  1204. {
  1205.  time_t atime,mtime;
  1206.  struct stat buf;
  1207.  int mfd;
  1208.  char *file;
  1210.  strcpy(MofY,"111111111111");
  1211.  strcpy(DofM,"1111111111111111111111111111111");
  1212.  strcpy(DofW,"1111111");
  1213.  strcpy(HofD,"100000000000000000000000");
  1215.  /* Change to the monitor directory. */
  1217.  if(chdir("monitor"))
  1218.    {PrintMessage(Warning,"Cannot change to directory 'monitor' [%!s].");return(0);}
  1220.  file=URLToFileName(Url);
  1222.  /* Check for 'O*' file. */
  1224.  *file='O';
  1225.  if(lstat(file,&buf))
  1226.     atime=0,mtime=time(NULL);
  1227.  else
  1228.     atime=buf.st_atime,mtime=buf.st_mtime;
  1230.  /* Check for 'M*' file for the old format. */
  1232.  *file='M';
  1233.  if(lstat(file,&buf) || buf.st_size<8)
  1234.    {
  1235.     int interval=7;
  1237.     mfd=open(file,O_RDONLY|O_BINARY);
  1238.     if(mfd)
  1239.       {
  1240.        char str[8];
  1241.        if(read(mfd,str,8)>0)
  1242.           interval=atoi(str);
  1243.        if(interval<0)
  1244.           interval=0;
  1245.        close(mfd);
  1246.       }
  1248.     strcpy(MofY,"111111111111");
  1249.     if(interval==7)
  1250.       {
  1251.        strcpy(DofM,"1111111111111111111111111111111");
  1252.        strcpy(DofW,"0000000"); DofW[(4+mtime/(3600*24))%7]='1';
  1253.       }
  1254.     else
  1255.       {
  1256.        int i;
  1257.        if(interval)
  1258.          {strcpy(DofM,"0000000000000000000000000000000"); for(i=0;i<31;i+=interval) DofM[i]='1';}
  1259.        else
  1260.           strcpy(DofM,"1111111111111111111111111111111");
  1261.        strcpy(DofW,"1111111");
  1262.       }
  1263.     if(interval)
  1264.       {strcpy(HofD,"000000000000000000000000"); HofD[(mtime/3600)%24]='1';}
  1265.     else
  1266.        strcpy(HofD,"111111111111111111111111");
  1268.     chdir("..");
  1269.     return(atime);
  1270.    }
  1272.  /* Assume that the file is in the new format. */
  1274.  mfd=open(file,O_RDONLY|O_BINARY);
  1275.  if(mfd)
  1276.    {
  1277.     char line[80];
  1278.     line[78]=0;
  1280.     if(read(mfd,line,80)!=78 ||
  1281.        sscanf(line,"%12s %31s %7s %24s",MofY,DofM,DofW,HofD)!=4 ||
  1282.        strlen(MofY)!=12 || strlen(DofM)!=31 || strlen(DofW)!=7 || strlen(HofD)!=24)
  1283.       {
  1284.        strcpy(MofY,"111111111111");
  1285.        strcpy(DofM,"1111111111111111111111111111111");
  1286.        strcpy(DofW,"1111111");
  1287.        strcpy(HofD,"100000000000000000000000");
  1288.       }
  1290.     close(mfd);
  1291.    }
  1293.  chdir("..");
  1294.  return(atime);
  1295. }
  1298. /*++++++++++++++++++++++++++++++++++++++
  1299.   Delete a specified URL from the monitor directory.
  1301.   char *DeleteMonitorSpoolFile Returns NULL if OK else error message.
  1303.   URL *Url The URL to delete or NULL for all of them.
  1304.   ++++++++++++++++++++++++++++++++++++++*/
  1306. char *DeleteMonitorSpoolFile(URL *Url)
  1307. {
  1308.  char *err=NULL;
  1309.  char *name;
  1311.  /* Change to the monitor directory. */
  1313.  if(chdir("monitor"))
  1314.    {err=PrintMessage(Warning,"Cannot change to directory 'monitor' [%!s].");return(err);}
  1316.  /* Delete the file for the request. */
  1318.  if(Url)
  1319.    {
  1320.     name=URLToFileName(Url);
  1321.     *name='O';
  1323.     if(unlink(name))
  1324.        err=PrintMessage(Warning,"Cannot unlink monitor request 'monitor/%s' [%!s].",name);
  1326.     *name='U';
  1327.     unlink(name);
  1329.     *name='M';
  1330.     unlink(name);
  1332.     free(name);
  1333.    }
  1334.  else
  1335.    {
  1336.     struct dirent* ent;
  1337.     DIR *dir=opendir(".");
  1339.     if(!dir)
  1340.       {err=PrintMessage(Warning,"Cannot open current directory 'monitor' [%!s].");chdir("..");return(err);}
  1342.     ent=readdir(dir);  /* skip .  */
  1343.     if(!ent)
  1344.       {err=PrintMessage(Warning,"Cannot read current directory 'monitor' [%!s].");closedir(dir);chdir("..");return(err);}
  1345.     ent=readdir(dir);  /* skip .. */
  1347.     while((ent=readdir(dir)))
  1348.       {
  1349.        if(unlink(ent->d_name))
  1350.           err=PrintMessage(Warning,"Cannot unlink outgoing request 'monitor/%s' [%!s].",ent->d_name);
  1351.       }
  1353.     closedir(dir);
  1354.    }
  1356.  /* Change dir back and tidy up. */
  1358.  chdir("..");
  1360.  return(err);
  1361. }
  1364. /*++++++++++++++++++++++++++++++++++++++
  1365.   Create a temporary spool file.
  1367.   int CreateTempSpoolFile Returns the file descriptor.
  1368.   ++++++++++++++++++++++++++++++++++++++*/
  1370. int CreateTempSpoolFile(void)
  1371. {
  1372.  char name[16];
  1373.  struct stat buf;
  1374.  int fd;
  1376.  /* Create the outgoing directory if needed and change to it */
  1378.  if(lstat("temp",&buf))
  1379.    {
  1380.     PrintMessage(Inform,"Directory 'temp' does not exist [%!s]; creating one.");
  1381.     if(mkdir("temp",DirPerm))
  1382.       {PrintMessage(Warning,"Cannot create directory 'temp' [%!s].");return(-1);}
  1383.    }
  1384.  else
  1385.     if(!S_ISDIR(buf.st_mode))
  1386.       {PrintMessage(Warning,"The file 'temp' is not a directory.");return(-1);}
  1388.  /* Open the file */
  1390.  sprintf(name,"temp/tmp.%ld",(long)getpid());
  1392.  fd=open(name,O_RDWR|O_CREAT|O_TRUNC|O_BINARY,FilePerm);
  1394.  if(fd==-1)
  1395.     PrintMessage(Warning,"Cannot create temporary file '%s' [%!s].",name);
  1397.  return(fd);
  1398. }
  1401. /*++++++++++++++++++++++++++++++++++++++
  1402.   Close and delete the temporary spool file.
  1404.   int fd The file descriptor.
  1405.   ++++++++++++++++++++++++++++++++++++++*/
  1407. void CloseTempSpoolFile(int fd)
  1408. {
  1409.  char name[16];
  1411.  sprintf(name,"temp/tmp.%ld",(long)getpid());
  1412.  if(unlink(name)==-1)
  1413.     PrintMessage(Warning,"Cannot unlink temporary file '%s' [%!s].",name);
  1415.  close(fd);
  1416. }
  1419. /*++++++++++++++++++++++++++++++++++++++
  1420.   Convert a filename to a URL.
  1422.   char *FileNameToURL Returns the URL.
  1424.   char *file The file name.
  1425.   ++++++++++++++++++++++++++++++++++++++*/
  1427. char *FileNameToURL(char *file)
  1428. {
  1429.  char *path,*copy;
  1430.  int ufd,r;
  1432.  if(!file || !*file)
  1433.     return(NULL);
  1435.  copy=(char*)malloc(strlen(file)+1);
  1436.  strcpy(copy,file);
  1438.  path=(char*)malloc(256+1);
  1440.  *copy='U';
  1442.  ufd=open(copy,O_RDONLY|O_BINARY);
  1444.  if(ufd==-1)
  1445.    {
  1446.     free(copy);
  1447.     free(path);
  1448.     return(NULL);
  1449.    }
  1451.  r=read(ufd,path,256);
  1453.  if(r==256)
  1454.    {
  1455.     int rr=0;
  1456.     do
  1457.       {
  1458.        r+=rr;
  1459.        path=(char*)realloc(path,r+256+1);
  1460.       }
  1461.     while((rr=read(ufd,&path[r],256))>0);
  1462.    }
  1463.  else if(r==-1)
  1464.    {
  1465.     close(ufd);
  1466.     free(copy);
  1467.     free(path);
  1468.     return(NULL);
  1469.    }
  1471.  path[r]=0;
  1473.  close(ufd);
  1475.  free(copy);
  1477.  return(path);
  1478. }
  1481. /*++++++++++++++++++++++++++++++++++++++
  1482.   Convert a URL to a filename
  1484.   char *URLToFileName Returns the filename.
  1486.   URL *Url The URL to convert to a filename.
  1487.   ++++++++++++++++++++++++++++++++++++++*/
  1489. char *URLToFileName(URL *Url)
  1490. {
  1491.  char *hash;
  1492.  char *file;
  1494.  hash=MakeHash(Url->file);
  1496.  file=(char*)malloc(strlen(hash)+3);
  1498.  sprintf(file,"X%s",hash);
  1500.  return(file);
  1501. }