sing_dbm.cc File Reference

#include "kernel/mod2.h"
#include <fcntl.h>
#include "Singular/tok.h"
#include "Singular/ipid.h"
#include "Singular/links/silink.h"
#include "Singular/links/sing_dbm.h"
#include "ndbm.h"

Go to the source code of this file.

Data Structures
struct	DBM_info

Functions
LINKAGE BOOLEAN	dbOpen (si_link l, short flag, leftv)
LINKAGE BOOLEAN	dbClose (si_link l)
LINKAGE leftv	dbRead2 (si_link l, leftv key)
LINKAGE leftv	dbRead1 (si_link l)
LINKAGE BOOLEAN	dbWrite (si_link l, leftv key)

Variables
STATIC_VAR datum	d_value

---

Data Structure Documentation

DBM_info

struct DBM_info

Definition at line 275 of file sing_dbm.cc.

Data Fields
DBM *	db
int	first

Function Documentation

dbClose()

LINKAGE BOOLEAN dbClose

(

si_link

l

)

Definition at line 318 of file sing_dbm.cc.

{
  DBM_info *db = (DBM_info *)l->data;
 
  dbm_close(db->db);
  omFreeSize((ADDRESS)db,(sizeof *db));
  l->data=NULL;
  SI_LINK_SET_CLOSE_P(l);
  return FALSE;

dbOpen()

LINKAGE BOOLEAN dbOpen	(	si_link	l,
		short	flag,
		leftv
	)

Definition at line 281 of file sing_dbm.cc.

{
  const char *mode = "r";
  DBM_info *db;
  int dbm_flags = O_RDONLY | O_CREAT;  // open database readonly as default
 
  if((l->mode!=NULL)
  && ((l->mode[0]=='w')||(l->mode[1]=='w')))
  {
    dbm_flags = O_RDWR | O_CREAT;
    mode = "rw";
    flag|=SI_LINK_WRITE|SI_LINK_READ;
  }
  else if(flag & SI_LINK_WRITE)
  {
    // request w- open, but mode is not "w" nor "rw" => fail
    return TRUE;
  }
  //if (((db = (DBM_info *)omAlloc(sizeof *db)) != NULL)
  //&&((db->db = dbm_open(l->name, dbm_flags, 0664 )) != NULL ))
  db = (DBM_info *)omAlloc(sizeof *db);
  if((db->db = dbm_open(l->name, dbm_flags, 0664 )) != NULL )
  {
    db->first=1;
    if(flag & SI_LINK_WRITE)
      SI_LINK_SET_RW_OPEN_P(l);
    else
      SI_LINK_SET_R_OPEN_P(l);
    l->data=(void *)(db);
    omFree(l->mode);
    l->mode=omStrDup(mode);
    return FALSE;
  }
  return TRUE;

dbRead1()

LINKAGE leftv dbRead1

(

si_link

l

)

Definition at line 377 of file sing_dbm.cc.

{
  return dbRead2(l,NULL);

dbRead2()

LINKAGE leftv dbRead2	(	si_link	l,
		leftv	key
	)

Definition at line 331 of file sing_dbm.cc.

{
  DBM_info *db = (DBM_info *)l->data;
  leftv v=NULL;
  datum d_key;
 
  if(key!=NULL)
  {
    if (key->Typ()==STRING_CMD)
    {
      d_key.dptr = (char*)key->Data();
      d_key.dsize = strlen(d_key.dptr)+1;
      d_value = dbm_fetch(db->db, d_key);
      v=(leftv)omAlloc0Bin(sleftv_bin);
      if (d_value.dptr!=NULL) v->data=omStrDup(d_value.dptr);
      else                    v->data=omStrDup("");
      v->rtyp=STRING_CMD;
    }
    else
    {
      WerrorS("read(`DBM link`,`string`) expected");
    }
  }
  else
  {
    if(db->first)
      d_value = dbm_firstkey((DBM *)db->db);
    else
      d_value = dbm_nextkey((DBM *)db->db);
 
    v=(leftv)omAlloc0Bin(sleftv_bin);
    v->rtyp=STRING_CMD;
    if (d_value.dptr!=NULL)
    {
      v->data=omStrDup(d_value.dptr);
      db->first = 0;
    }
    else
    {
      v->data=omStrDup("");
      db->first = 1;
    }
 
  }
  return v;

dbWrite()

LINKAGE BOOLEAN dbWrite	(	si_link	l,
		leftv	key
	)

Definition at line 382 of file sing_dbm.cc.

{
  DBM_info *db = (DBM_info *)l->data;
  BOOLEAN b=TRUE;
  register int ret;
 
  // database is opened
  if((key!=NULL) && (key->Typ()==STRING_CMD) )
  {
    if (key->next!=NULL)                   // have a second parameter ?
    {
      if(key->next->Typ()==STRING_CMD)     // replace (key,value)
      {
        datum d_key, d_value;
 
        d_key.dptr = (char *)key->Data();
        d_key.dsize = strlen(d_key.dptr)+1;
        d_value.dptr = (char *)key->next->Data();
        d_value.dsize = strlen(d_value.dptr)+1;
        ret  = dbm_store(db->db, d_key, d_value, DBM_REPLACE);
        if(!ret )
          b=FALSE;
        else
        {
          if(dbm_error(db->db))
          {
            Werror("DBM link I/O error. Is '%s' readonly?", l->name);
            dbm_clearerr(db->db);
          }
        }
      }
    }
    else
    {                               // delete (key)
      datum d_key;
 
      d_key.dptr = (char *)key->Data();
      d_key.dsize = strlen(d_key.dptr)+1;
      dbm_delete(db->db, d_key);
      b=FALSE;
    }
  }
  else
  {
    WerrorS("write(`DBM link`,`key string` [,`data string`]) expected");
  }
  return b;

Variable Documentation

d_value

STATIC_VAR datum d_value

Definition at line 330 of file sing_dbm.cc.