DeleteLogsCode.C

Go to the documentation of this file.

// Copyright (C) 2001, Compaq Computer Corporation
// 
// This file is part of Vesta.
// 
// Vesta is free software; you can redistribute it and/or
// modify it under the terms of the GNU Lesser General Public
// License as published by the Free Software Foundation; either
// version 2.1 of the License, or (at your option) any later version.
// 
// Vesta is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
// Lesser General Public License for more details.
// 
// You should have received a copy of the GNU Lesser General Public
// License along with Vesta; if not, write to the Free Software
// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

// Last modified on Thu Nov  8 12:48:54 EST 2001 by ken@xorian.net
//      modified on Fri Sep 13 14:45:45 PDT 1996 by heydon

/* This is old code that was written to delete the old "weededMPKs" log and
   checkpoint files before Tim implemented "VestaLog::prune". It was called
   from "CacheS::ResetWeededMPKs" by the lines:

        thread th;
        th.fork_and_detach(CacheS_DeleteOldLogs,
          (void *)(&Config_WeededLogPath));

   These lines appeared just after the line:

        this->weededMPKsLog->checkpointEnd();
*/

static void CacheS_DeleteOldLogs2(const Text &dirName, int version)
  throw (FS::Failure)
{
    DIR *dp = opendir(dirName.cchars());
    if (dp == (DIR *)NULL)
        throw (FS::Failure("opendir", dirName));
    struct dirent *ent;
    try {
        Text fullDirName(dirName); fullDirName += "/";
        for (ent = readdir(dp); ent != NULL; ent = readdir(dp)) {
            char *nm = ent->d_name;
            for (int i = 0, v = 0;
                 (i < ent->d_namlen) && ('0' <= *nm) && (*nm <= '9');
                 i++, nm++) {
                v *= 10; v += (*nm - '0');
            }
            if (i > 0 && i < ent->d_namlen && *(nm++) == '.') {
                if ((!strcmp(nm, "log") && v < version) ||
                    (!strcmp(nm, "ckp") && v <= version)) {
                    // delete this file
                    Text fname(fullDirName);
                    fname += Text(ent->d_name);
                    try {
                        FS::Delete(fname);
                    } catch (FS::Failure) { /*SKIP*/ }
                }
            }
        }
    }
    catch (...) {
        if (closedir(dp) < 0)
            throw (FS::Failure("closedir", dirName));
        throw;
    }
    if (closedir(dp) < 0)
        throw (FS::Failure("closedir", dirName));
}

static void* CacheS_DeleteOldLogs(void *arg) throw ()
{
    Text *dirName = (Text *)arg;
    try {
        int version = CacheS_ReadLogVersion(*dirName);
        CacheS_DeleteOldLogs2(*dirName, version);
    } catch (FS::Error) { /*SKIP*/ }
    return NULL;
}

---