Main Page

Source Files

Class Hierarchy

Alphabetical List

Compound List

Compound Members

File Members

Related Pages

Search for

---

libsrc/bert.cxx File Reference

??? More...

#include "udanax.h"

Include dependency graph for bert.cxx:

Go to the source code of this file.

Classes
struct	bertentry
struct	conscell
Defines
#define	NUMBEROFBERTTABLE   1327
Functions
unsigned int	hashoftumbler (Tumbler *tp)
	???
int	checkforopen (Session *sess, Tumbler *tp, int type)
	???
void	logbertmodifiedforcrum (Session *sess, typecuc *crumptr)
	???
void	logbertmodified (Session *sess, Tumbler *tp)
	???
void	incrementopen (Session *sess, Tumbler *tp)
	???
void	addtoopen (Session *sess, Tumbler *tp, int created, int type)
	???
void	deleteversion (Tumbler *tp)
	???
bool	removefromopen (Session *sess, Tumbler *tp)
	???
void	closeberts (Session *sess)
	???
bool	doopen (Session *sess, IStreamAddr *tp, IStreamAddr *newtp, int type, int mode)
	???
bool	doclose (Session *sess, IStreamAddr *tp)
	???
Variables
const int	primes []
conscell *	berttable [NUMBEROFBERTTABLE]
char *	bertTypeNames [] = { "NOBERT", "READBERT", "WRITEBERT" }

---

Detailed Description

???

(to be defined)

Definition in file bert.cxx.

---

Define Documentation

#define NUMBEROFBERTTABLE   1327

Definition at line 124 of file bert.cxx. Referenced by closeberts(), and hashoftumbler().

---

Function Documentation

void addtoopen (  Session *  sess, Tumbler *  tp, int  created, int  type )  [static]

??? (to be defined) Parameters: sess  Input: User's session context Definition at line 285 of file bert.cxx. References assert, BERTCONSCELLTAG, berttable, BERTTAG, bertTypeNames, bertentry::count, bertentry::created, bertentry::documentid, dumptumbler(), eallocwithtag(), hash(), hashoftumbler(), L, bertentry::modified, conscell::next, NULL, bertentry::sess, conscell::stuff, tumblercopy(), and bertentry::type. Referenced by doopen(). : User's session context Tumbler *tp, int created, int type) { #ifndef DISTRIBUTION L("addtoopen: sess = %d type = %s created = %d tp = ", (int) sess, bertTypeNames[type], created); dumptumbler(tp); L("\n"); #endif int hash = hashoftumbler(tp); /* these eallocwithtags changed to malloc by hill zzzz */ bertentry *ptr; if ((ptr = (bertentry *) eallocwithtag(sizeof(bertentry), BERTTAG)) == NULL) assert(0); // out of memory tumblercopy(tp, &ptr->documentid); ptr->sess = sess; ptr->count = 1; ptr->created = created; ptr->modified = false; ptr->type = type; conscell *consp; if ((consp = (conscell *) eallocwithtag(sizeof(conscell), BERTCONSCELLTAG)) == NULL) assert(0); // out of memory consp->stuff = ptr; consp->next = berttable[hash]; berttable[hash] = consp; }

int checkforopen (  Session *  sess, Tumbler *  tp, int  type )

??? (to be defined) Parameters: sess  Input: User's session context Definition at line 176 of file bert.cxx. References berttable, bertentry::documentid, hashoftumbler(), isthisusersdocument(), conscell::next, NOBERTREQUIRED, READBERT, bertentry::sess, conscell::stuff, tumblereq(), bertentry::type, and WRITEBERT. Referenced by doopen(), and findorgl(). : User's session context Tumbler *tp, int type) { int foundnonread = false; if (type == NOBERTREQUIRED) return 1; /* Random > 0 */ conscell *p; for (p = berttable[hashoftumbler(tp)]; p && p->stuff; p = p->next) { bertentry *bert = p->stuff; if (tumblereq(tp, &bert->documentid)) { if (sess == bert->sess) { switch (bert->type) { case READBERT: return (type == READBERT) ? READBERT : /* WRITE */ -1; case WRITEBERT: return WRITEBERT; } } else { if (bert->type != READBERT) { foundnonread = true; } } } } if (!foundnonread && (type == READBERT || isthisusersdocument(sess, tp))) return 0; else return -1; }

void closeberts (  Session *  sess  )

??? (to be defined) Parameters: sess  Input: User's session context Definition at line 401 of file bert.cxx. References berttable, bertentry::created, deleteversion(), bertentry::documentid, efree(), L, bertentry::modified, conscell::next, NULL, NUMBEROFBERTTABLE, bertentry::sess, and conscell::stuff. Referenced by quitxanadu(), and xanadu(). : User's session context { #ifndef DISTRIBUTION L("closeberts: sess = 0x%08lX\n", (int) sess); #endif conscell *oldptr = NULL; int i; for (i = 0; i < NUMBEROFBERTTABLE; i++) { conscell *p; for (p = berttable[i]; p && p->stuff; p = p->next) { bertentry *bert = p->stuff; if (bert->sess == sess) { int status = bert->modified && bert->created; if (status) deleteversion(&bert->documentid); efree((char *)p->stuff); conscell *temp; if (oldptr == NULL) { temp = berttable[i]; berttable[i] = berttable[i]->next; efree((char *) temp); return; } else { temp = oldptr->next; oldptr->next = p->next; efree((char *) temp); return; } } oldptr = p; } } }

void deleteversion (  Tumbler *  tp  )  [static]

??? (to be defined) Definition at line 330 of file bert.cxx. References dumptumbler(), and L. Referenced by closeberts(), and removefromopen(). { #ifndef DISTRIBUTION L("deleteversion: tp = "); dumptumbler(tp); L("\n"); #endif }

bool doclose (  Session *  sess, IStreamAddr *  tp )

??? (to be defined) Parameters: sess  Input: User's session context Definition at line 548 of file bert.cxx. References dumptumbler(), ERR_CLOSE_WO_OPEN, Session::errorcode, L, and removefromopen(). Referenced by docreatenewversion(), and myclose(). : User's session context IStreamAddr *tp) { #ifndef DISTRIBUTION L("doclose: sess = %d tp = ", (int) sess); dumptumbler(tp); L("\n"); #endif if (!removefromopen(sess, tp)) { sess->errorcode = ERR_CLOSE_WO_OPEN; // Attempted close of a document that was never opened return false; } return true; /* for now, so as to not upset front-end */ }

bool doopen (  Session *  sess, IStreamAddr *  tp, IStreamAddr *  newtp, int  type, int  mode )

??? (to be defined) Parameters: sess  Input: User's session context Definition at line 465 of file bert.cxx. References Session::account, addtoopen(), assert, BERTMODECOPY, BERTMODECOPYIF, BERTMODEONLY, checkforopen(), docreatenewversion(), ERR_OPEN_COPY, Session::errorcode, incrementopen(), L, NOBERTREQUIRED, tumblercopy(), and WRITEBERT. Referenced by docreatenewversion(), and myopen(). : User's session context IStreamAddr *tp, IStreamAddr *newtp, int type, int mode) { L("Entered doopen()\n"); if (type == NOBERTREQUIRED) return true; L("type != NOBERTREQUIRED\n"); if (mode == BERTMODECOPY) { L("mode == BERTMODECOPY, trying to copy document\n"); if (docreatenewversion(sess, tp, &sess->account, newtp)) { addtoopen(sess, newtp, true, type); return true; } else { sess->errorcode = ERR_OPEN_COPY; // Attempt to make a copy to open failed return false; } } L("about to call checkforopen()\n"); int openState = checkforopen(sess, tp, type); L("returned from call to checkforopen(), openState = %d\n", openState); if (openState == 0) { L("already open in R/O, just trying to inc open count\n"); addtoopen(sess, tp, false, type); tumblercopy(tp, newtp); return true; } switch (mode) { case BERTMODECOPYIF: if (openState == -1) { // Document not already open if (docreatenewversion(sess, tp, &sess->account, newtp)) { addtoopen(sess, newtp, true, type); } else { sess->errorcode = ERR_OPEN_COPY; // Attempt to make a copy to open failed return false; } } else if (type != WRITEBERT && openState != WRITEBERT) { // Open another Shared Read-Open Reference incrementopen(sess, tp); tumblercopy(tp, newtp); } else { // Document is already open, Open a new copy docreatenewversion(sess, tp, &sess->account, newtp); addtoopen(sess, newtp, true, type); } return true; case BERTMODEONLY: if (openState == -1 || type == WRITEBERT || openState == WRITEBERT) { return false; } else { incrementopen(sess, tp); tumblercopy(tp, newtp); return true; } default: assert(0); // DEFAULT CASE IN DOOPEN return false; } }

unsigned int hashoftumbler (  Tumbler *  tp  )  [static]

??? (to be defined) Definition at line 142 of file bert.cxx. References Tumbler::exp, Tumbler::mantissa, NPLACES, NUMBEROFBERTTABLE, and primes. Referenced by addtoopen(), checkforopen(), incrementopen(), logbertmodified(), and removefromopen(). { unsigned int ret = tp->exp; for (int i = 0; i < NPLACES; i++) ret += (unsigned int) tp->mantissa[i] * primes[i]; return ret % NUMBEROFBERTTABLE; }

void incrementopen (  Session *  sess, Tumbler *  tp )  [static]

??? (to be defined) Parameters: sess  Input: User's session context Definition at line 259 of file bert.cxx. References berttable, bertentry::count, bertentry::documentid, dumptumbler(), hashoftumbler(), L, conscell::next, bertentry::sess, conscell::stuff, and tumblereq(). Referenced by doopen(). : User's session context Tumbler *tp) { #ifndef DISTRIBUTION L("incrementopen: sess = %d tp = ", (int) sess); dumptumbler(tp); L("\n"); #endif conscell *p; for (p = berttable[ hashoftumbler(tp) ]; p && p->stuff; p = p->next) { bertentry *bert = (bertentry *) p->stuff; if (bert->sess == sess && tumblereq(tp, &bert->documentid)) bert->count += 1; } }

void logbertmodified (  Session *  sess, Tumbler *  tp )

??? (to be defined) Parameters: sess  Input: User's session context Definition at line 235 of file bert.cxx. References berttable, bertentry::documentid, hashoftumbler(), bertentry::modified, conscell::next, bertentry::sess, conscell::stuff, and tumblereq(). Referenced by deletevspanpm(), insertpm(), and rearrangepm(). : User's session context Tumbler *tp) { /* L("logbertmodified sess= %d bert= ", (int) sess);dumptumbler(tp); L("\n"); */ conscell *p; for (p = berttable[ hashoftumbler(tp) ]; p && p->stuff; p = p->next) { bertentry *bert = (bertentry *) p->stuff; if (bert->sess == sess && tumblereq(tp, &bert->documentid)) { bert->modified = true; return; } } }

void logbertmodifiedforcrum (  Session *  sess, typecuc *  crumptr )

??? (to be defined) Parameters: sess  Input: User's session context Definition at line 220 of file bert.cxx. : User's session context typecuc *crumptr) { /* logbertmodified(xxx); */ }

bool removefromopen (  Session *  sess, Tumbler *  tp )  [static]

??? (to be defined) Parameters: sess  Input: User's session context Definition at line 348 of file bert.cxx. References berttable, bertentry::count, bertentry::created, deleteversion(), bertentry::documentid, dumptumbler(), efree(), hash(), hashoftumbler(), L, bertentry::modified, conscell::next, NULL, bertentry::sess, conscell::stuff, and tumblereq(). Referenced by doclose(). : User's session context Tumbler *tp) { #ifndef DISTRIBUTION L("removefromopen: sess = %d tp = ", (int) sess); dumptumbler(tp); L("\n"); #endif int hash = hashoftumbler(tp); conscell *oldptr = NULL; conscell *p; for (p = berttable[hash]; p && p->stuff; p = p->next) { bertentry *bert = p->stuff; if (bert->sess == sess && tumblereq(tp, &bert->documentid)) { if (--bert->count) return true; /* status = bert->modified && bert->created ; */ int status = bert->created && !bert->modified; if (status) deleteversion(tp); efree((char *) p->stuff); conscell *temp; if (oldptr == NULL) { temp = berttable[hash]; berttable[hash] = berttable[hash]->next; efree((char *)temp); return true; } else { temp = oldptr->next; oldptr->next = p->next; efree((char *)temp); return true; } } oldptr = p; } return false; }

---

Variable Documentation

conscell* berttable[NUMBEROFBERTTABLE] [static]

Definition at line 126 of file bert.cxx. Referenced by addtoopen(), checkforopen(), closeberts(), incrementopen(), logbertmodified(), and removefromopen().

char* bertTypeNames[] = { "NOBERT", "READBERT", "WRITEBERT" } [static]

Definition at line 130 of file bert.cxx. Referenced by addtoopen().

const int primes[] [static]

Initial value: { 3, 7, 11, 17, 37, 41, 59, 71, 97, 103, 113, 131, 151, 137, 277, 421, 433, 567, 643, 743 } Definition at line 119 of file bert.cxx. Referenced by hashoftumbler().

---