greg/stasis-aries-wal
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

use INVALID_LSN instead of hardcoded -1

Browse source
This commit is contained in:
Sears Russell 2009-10-12 22:26:32 +00:00
parent 5f55abfa23
commit 0e93a577c9
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/stasis/logger/logger2.c
View file

@ -59,7 +59,7 @@ static lsn_t stasis_log_write_common(stasis_log_t* log, TransactionLog * l, int
log->write_entry(log, e); log->write_entry(log, e);
pthread_mutex_lock(&l->mut); pthread_mutex_lock(&l->mut);
if(l->prevLSN == -1) { l->recLSN = e->LSN; } if(l->prevLSN == INVALID_LSN) { l->recLSN = e->LSN; }
l->prevLSN = e->LSN; l->prevLSN = e->LSN;
pthread_mutex_unlock(&l->mut); pthread_mutex_unlock(&l->mut);
@ -82,7 +82,7 @@ static lsn_t stasis_log_write_prepare(stasis_log_t* log, TransactionLog * l) {
log->write_entry(log, e); log->write_entry(log, e);
pthread_mutex_lock(&l->mut); pthread_mutex_lock(&l->mut);
if(l->prevLSN == -1) { l->recLSN = e->LSN; } if(l->prevLSN == INVALID_LSN) { l->recLSN = e->LSN; }
l->prevLSN = e->LSN; l->prevLSN = e->LSN;
pthread_mutex_unlock(&l->mut); pthread_mutex_unlock(&l->mut);
DEBUG("Log Common prepare XXX %d, LSN: %ld type: %ld (prevLSN %ld)\n", DEBUG("Log Common prepare XXX %d, LSN: %ld type: %ld (prevLSN %ld)\n",
@ -107,7 +107,7 @@ LogEntry * stasis_log_write_update(stasis_log_t* log, TransactionLog * l,
DEBUG("Log Update %d, LSN: %ld type: %ld (prevLSN %ld) (arg_size %ld)\n", e->xid, DEBUG("Log Update %d, LSN: %ld type: %ld (prevLSN %ld) (arg_size %ld)\n", e->xid,
(long int)e->LSN, (long int)e->type, (long int)e->prevLSN, (long int) arg_size); (long int)e->LSN, (long int)e->type, (long int)e->prevLSN, (long int) arg_size);
pthread_mutex_lock(&l->mut); pthread_mutex_lock(&l->mut);
if(l->prevLSN == -1) { l->recLSN = e->LSN; } if(l->prevLSN == INVALID_LSN) { l->recLSN = e->LSN; }
l->prevLSN = e->LSN; l->prevLSN = e->LSN;
pthread_mutex_unlock(&l->mut); pthread_mutex_unlock(&l->mut);
return e; return e;
@ -121,7 +121,7 @@ LogEntry * stasis_log_begin_nta(stasis_log_t* log, TransactionLog * l, unsigned
lsn_t stasis_log_end_nta(stasis_log_t* log, TransactionLog * l, LogEntry * e) { lsn_t stasis_log_end_nta(stasis_log_t* log, TransactionLog * l, LogEntry * e) {
log->write_entry(log, e); log->write_entry(log, e);
pthread_mutex_lock(&l->mut); pthread_mutex_lock(&l->mut);
if(l->prevLSN == -1) { l->recLSN = e->LSN; } if(l->prevLSN == INVALID_LSN) { l->recLSN = e->LSN; }
lsn_t ret = l->prevLSN = e->LSN; lsn_t ret = l->prevLSN = e->LSN;
pthread_mutex_unlock(&l->mut); pthread_mutex_unlock(&l->mut);
freeLogEntry(e); freeLogEntry(e);
@ -153,8 +153,8 @@ void stasis_log_begin_transaction(stasis_log_t* log, int xid, TransactionLog* tl
tl->xid = xid; tl->xid = xid;
DEBUG("Log Begin %d\n", xid); DEBUG("Log Begin %d\n", xid);
tl->prevLSN = -1; tl->prevLSN = INVALID_LSN;
tl->recLSN = -1; tl->recLSN = INVALID_LSN;
} }
lsn_t stasis_log_abort_transaction(stasis_log_t* log, TransactionLog * l) { lsn_t stasis_log_abort_transaction(stasis_log_t* log, TransactionLog * l) {