view src/lock.c @ 54:125d79c9e586 noffle

[svn] * src/client.c, src/configfile.c, src/content.c, src/control.c, src/database.c, src/dynamicstring.c, src/fetch.c, src/fetchlist.c, src/group.c, src/itemlist.c, src/lock.c, src/log.c, src/noffle.c, src/online.c, src/outgoing.c, src/over.c, src/post.c, src/protocol.c, src/pseudo.c, src/request.c, src/server.c, src/util.c: Added portable.h #include. * src/client.h, src/database.h, src/fetch.c, src/group.h, src/lock.c, src/outgoing.c, src/over.c, src/over.h, src/pseudo.c, src/server.c, src/util.c, src/util.h: Added some #ifdefs to correctly include either time.h or sys/time.h or both, depending on which are found. * src/noffle.c: Changed the return-type of the signal-handlers bugReport() and logSignal() to RETSIGTYPE, which is either void or int, depending on the system you compile on (autoconf #defines the RETSIGTYPE).
author uh1763
date Tue, 09 May 2000 23:28:38 +0100
parents 2842f50feb55
children 3c71e28c8eef
line wrap: on
line source

/*
  lock.c

  $Id: lock.c 60 2000-05-09 22:28:38Z uh1763 $
*/

#if HAVE_CONFIG_H
#include <config.h>
#endif

#include <stdio.h>
#include "lock.h"
#include <errno.h>
#include <ctype.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>

#if TIME_WITH_SYS_TIME
#include <sys/time.h>
#include <time.h>
#else
#if HAVE_SYS_TIME_H
#include <sys/time.h>
#else
#include <time.h>
#endif
#endif

#include <unistd.h>
#include "configfile.h"
#include "log.h"
#include "database.h"
#include "group.h"
#include "request.h"
#include "portable.h"

struct Lock
{
    int lockFd;
    Str lockFile;
} lock = { -1, "" };


#ifdef DEBUG
static Bool
testLock( void )
{
    return ( lock.lockFd != -1 );    
}
#endif

static Bool
waitLock( void )
{
    int fd;
    struct flock l;

    ASSERT( ! testLock() );
    Log_dbg( "Waiting for lock ..." );
    snprintf( lock.lockFile, MAXCHAR, "%s/lock/global", Cfg_spoolDir() );
    if ( ( fd = open( lock.lockFile, O_WRONLY | O_CREAT, 0644 ) ) < 0 )
    {
        Log_err( "Cannot open %s (%s)", lock.lockFile, strerror( errno ) );
        return FALSE;
    }
    l.l_type = F_WRLCK;
    l.l_start = 0;
    l.l_whence = SEEK_SET;
    l.l_len = 0;
    if ( fcntl( fd, F_SETLKW, &l ) < 0 )
    {
        Log_err( "Cannot lock %s: %s", lock.lockFile, strerror( errno ) );
        return FALSE;
    }
    lock.lockFd = fd;
    Log_dbg( "Lock successful" );
    return TRUE;
}

static void
releaseLock( void )
{
    struct flock l;

    ASSERT( testLock() );    
    l.l_type = F_UNLCK;
    l.l_start = 0;
    l.l_whence = SEEK_SET;
    l.l_len = 0;
    if ( fcntl( lock.lockFd, F_SETLK, &l ) < 0 )
        Log_err( "Cannot release %s: %s", lock.lockFile,
                 strerror( errno ) );
    close( lock.lockFd );
    lock.lockFd = -1;
    Log_dbg( "Releasing lock" );
}


/* Open all databases and set global lock. */
Bool
Lock_openDatabases( void )
{
  if ( ! waitLock() )
    {
      Log_err( "Could not get write lock" );
      return FALSE;
    }
  if ( ! Db_open() )
    {
      Log_err( "Could not open database" );
      releaseLock();
      return FALSE;
    }
  if ( ! Grp_open() )
    {
      Log_err( "Could not open groupinfo" );
      Db_close();
      releaseLock();
      return FALSE;
    }
  if ( ! Req_open() )
    {
      Log_err( "Could not initialize request database" );
      Grp_close();
      Db_close();
      releaseLock();
      return FALSE;
    }

  return TRUE;
}


/* Close all databases and release global lock. */
void
Lock_closeDatabases( void )
{
  Grp_close();
  Db_close();
  Req_close();
  releaseLock();
}