All headers now live in the header directory. (stasis/, not src/stasis)
This commit is contained in:
parent
904d120ea4
commit
afbd89e3ff
95 changed files with 102 additions and 98 deletions
|
@ -1,7 +1,7 @@
|
||||||
#include <stasis/transactional.h>
|
#include <stasis/transactional.h>
|
||||||
#include <stasis/multiplexer.h>
|
#include <stasis/multiplexer.h>
|
||||||
#include <stasis/graph.h>
|
#include <stasis/graph.h>
|
||||||
#include "../src/stasis/logger/logMemory.h"
|
#include <stasis/logger/logMemory.h>
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
|
|
|
@ -3,7 +3,7 @@
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
#include <stasis/transactional.h>
|
#include <stasis/transactional.h>
|
||||||
#include <unistd.h>
|
#include <unistd.h>
|
||||||
#include "../src/stasis/page/raw.h"
|
#include <stasis/page/raw.h>
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
|
|
||||||
int main(int argc, char** argv) {
|
int main(int argc, char** argv) {
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
#include <stasis/transactional.h>
|
#include <stasis/transactional.h>
|
||||||
#include "page/raw.h"
|
#include <stasis/page/raw.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -61,12 +61,12 @@ terms specified in this license.
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
#include <stasis/common.h>
|
#include <stasis/common.h>
|
||||||
#include "latches.h"
|
#include <stasis/latches.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
|
|
||||||
#include <stasis/bufferManager.h>
|
#include <stasis/bufferManager.h>
|
||||||
#include "bufferManager/pageArray.h"
|
#include <stasis/bufferManager/pageArray.h>
|
||||||
#include "bufferManager/bufferHash.h"
|
#include <stasis/bufferManager/bufferHash.h>
|
||||||
#include <stasis/bufferPool.h>
|
#include <stasis/bufferPool.h>
|
||||||
|
|
||||||
#include <stasis/lockManager.h>
|
#include <stasis/lockManager.h>
|
||||||
|
@ -74,7 +74,7 @@ terms specified in this license.
|
||||||
#include <stasis/pageHandle.h>
|
#include <stasis/pageHandle.h>
|
||||||
|
|
||||||
#include <stasis/lhtable.h>
|
#include <stasis/lhtable.h>
|
||||||
#include "page.h"
|
#include <stasis/page.h>
|
||||||
|
|
||||||
#undef loadPage
|
#undef loadPage
|
||||||
#undef releasePage
|
#undef releasePage
|
||||||
|
|
|
@ -54,7 +54,7 @@ terms specified in this license.
|
||||||
#include <stasis/bufferPool.h>
|
#include <stasis/bufferPool.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
#include <stasis/truncation.h>
|
#include <stasis/truncation.h>
|
||||||
#include "page.h"
|
#include <stasis/page.h>
|
||||||
/* TODO: Combine with buffer size... */
|
/* TODO: Combine with buffer size... */
|
||||||
static int nextPage = 0;
|
static int nextPage = 0;
|
||||||
static pthread_mutex_t pageMallocMutex;
|
static pthread_mutex_t pageMallocMutex;
|
||||||
|
|
|
@ -3,7 +3,7 @@
|
||||||
#include <config.h>
|
#include <config.h>
|
||||||
#include <stasis/common.h>
|
#include <stasis/common.h>
|
||||||
|
|
||||||
#include "latches.h"
|
#include <stasis/latches.h>
|
||||||
|
|
||||||
#include <pbl/pbl.h>
|
#include <pbl/pbl.h>
|
||||||
#include <errno.h>
|
#include <errno.h>
|
||||||
|
|
|
@ -2,7 +2,7 @@
|
||||||
#include <stasis/crc32.h>
|
#include <stasis/crc32.h>
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
#include "logger/logMemory.h"
|
#include <stasis/logger/logMemory.h>
|
||||||
|
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
|
|
|
@ -2,7 +2,7 @@
|
||||||
#include <alloca.h>
|
#include <alloca.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
#include "page.h"
|
#include <stasis/page.h>
|
||||||
#include <stasis/crc32.h>
|
#include <stasis/crc32.h>
|
||||||
|
|
||||||
int numOut = 0;
|
int numOut = 0;
|
||||||
|
|
|
@ -1,5 +1,5 @@
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
#include "io.h"
|
#include <stasis/io.h>
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
/** @file
|
/** @file
|
||||||
|
|
||||||
|
|
|
@ -4,7 +4,7 @@
|
||||||
|
|
||||||
#include <stasis/operations.h>
|
#include <stasis/operations.h>
|
||||||
#include <stasis/arrayCollection.h>
|
#include <stasis/arrayCollection.h>
|
||||||
#include "logger/logMemory.h"
|
#include <stasis/logger/logMemory.h>
|
||||||
|
|
||||||
static lladdIterator_def_t iterators[MAX_ITERATOR_TYPES];
|
static lladdIterator_def_t iterators[MAX_ITERATOR_TYPES];
|
||||||
|
|
||||||
|
|
|
@ -5,7 +5,7 @@
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
#include "latches.h"
|
#include <stasis/latches.h>
|
||||||
|
|
||||||
#define FILL_FACTOR (0.5)
|
#define FILL_FACTOR (0.5)
|
||||||
|
|
||||||
|
|
|
@ -47,7 +47,7 @@ terms specified in this license.
|
||||||
#include <config.h>
|
#include <config.h>
|
||||||
#include <stasis/common.h>
|
#include <stasis/common.h>
|
||||||
|
|
||||||
#include "linkedlist.h"
|
#include <stasis/linkedlist.h>
|
||||||
|
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
|
|
||||||
|
|
|
@ -3,7 +3,7 @@
|
||||||
#include <stasis/compensations.h>
|
#include <stasis/compensations.h>
|
||||||
#include <sys/time.h>
|
#include <sys/time.h>
|
||||||
#include <time.h>
|
#include <time.h>
|
||||||
#include "latches.h"
|
#include <stasis/latches.h>
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
#include <errno.h>
|
#include <errno.h>
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
|
|
|
@ -1,5 +1,5 @@
|
||||||
#include "inMemoryLog.h"
|
#include <stasis/logger/inMemoryLog.h>
|
||||||
#include "../latches.h"
|
#include <stasis/latches.h>
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
static rwl * flushedLSN_lock;
|
static rwl * flushedLSN_lock;
|
||||||
|
|
|
@ -45,7 +45,7 @@ terms specified in this license.
|
||||||
|
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
|
|
||||||
#include "../page.h" // For stasis_record_type_to_size()
|
#include <stasis/page.h> // For stasis_record_type_to_size()
|
||||||
#include <stasis/logger/logger2.h> // needed for LoggerSizeOfInternalLogEntry()
|
#include <stasis/logger/logger2.h> // needed for LoggerSizeOfInternalLogEntry()
|
||||||
#include <stasis/logger/logEntry.h>
|
#include <stasis/logger/logEntry.h>
|
||||||
#include <stasis/crc32.h>
|
#include <stasis/crc32.h>
|
||||||
|
|
|
@ -44,7 +44,7 @@ terms specified in this license.
|
||||||
|
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
|
|
||||||
#include "logHandle.h"
|
#include <stasis/logger/logHandle.h>
|
||||||
|
|
||||||
/**
|
/**
|
||||||
Sets the next and prev field of h, but does not set h.file_offset.
|
Sets the next and prev field of h, but does not set h.file_offset.
|
||||||
|
|
|
@ -5,7 +5,7 @@
|
||||||
|
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
#include "logMemory.h"
|
#include <stasis/logger/logMemory.h>
|
||||||
#include <errno.h>
|
#include <errno.h>
|
||||||
#include <stasis/compensations.h>
|
#include <stasis/compensations.h>
|
||||||
|
|
||||||
|
|
|
@ -57,8 +57,8 @@ terms specified in this license.
|
||||||
#include <stasis/common.h>
|
#include <stasis/common.h>
|
||||||
|
|
||||||
#include <stasis/crc32.h>
|
#include <stasis/crc32.h>
|
||||||
#include "logWriter.h"
|
#include <stasis/logger/logWriter.h>
|
||||||
#include "logHandle.h"
|
#include <stasis/logger/logHandle.h>
|
||||||
#include <stasis/latches.h>
|
#include <stasis/latches.h>
|
||||||
#include <stasis/io.h>
|
#include <stasis/io.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
|
|
|
@ -55,9 +55,9 @@ terms specified in this license.
|
||||||
|
|
||||||
#include <stasis/logger/logger2.h>
|
#include <stasis/logger/logger2.h>
|
||||||
|
|
||||||
#include "logWriter.h"
|
#include <stasis/logger/logWriter.h>
|
||||||
#include "inMemoryLog.h"
|
#include <stasis/logger/inMemoryLog.h>
|
||||||
#include "../page.h"
|
#include <stasis/page.h>
|
||||||
|
|
||||||
#ifdef USE_LOGGER
|
#ifdef USE_LOGGER
|
||||||
int loggerType = USE_LOGGER;
|
int loggerType = USE_LOGGER;
|
||||||
|
|
|
@ -3,7 +3,7 @@
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
#include <stasis/operations/linearHashNTA.h>
|
#include <stasis/operations/linearHashNTA.h>
|
||||||
|
|
||||||
#include "logger/logMemory.h"
|
#include <stasis/logger/logMemory.h>
|
||||||
|
|
||||||
lladdMultiplexer_t * lladdMultiplexer_alloc(int xid, lladdIterator_t * it,
|
lladdMultiplexer_t * lladdMultiplexer_alloc(int xid, lladdIterator_t * it,
|
||||||
void (*multiplexer)(byte * key,
|
void (*multiplexer)(byte * key,
|
||||||
|
|
|
@ -50,7 +50,7 @@ terms specified in this license.
|
||||||
#include <stasis/logger/logger2.h>
|
#include <stasis/logger/logger2.h>
|
||||||
#include <stasis/bufferManager.h>
|
#include <stasis/bufferManager.h>
|
||||||
|
|
||||||
#include "page.h"
|
#include <stasis/page.h>
|
||||||
|
|
||||||
|
|
||||||
Operation operationsTable[MAX_OPERATIONS];
|
Operation operationsTable[MAX_OPERATIONS];
|
||||||
|
|
|
@ -6,8 +6,8 @@
|
||||||
#include <stasis/transactional.h>
|
#include <stasis/transactional.h>
|
||||||
#include <stasis/bufferManager.h>
|
#include <stasis/bufferManager.h>
|
||||||
#include <stasis/allocationPolicy.h>
|
#include <stasis/allocationPolicy.h>
|
||||||
#include "../blobManager.h"
|
#include <stasis/blobManager.h>
|
||||||
#include "../page.h"
|
#include <stasis/page.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
//try{
|
//try{
|
||||||
/**
|
/**
|
||||||
|
|
|
@ -2,7 +2,7 @@
|
||||||
#include <config.h>
|
#include <config.h>
|
||||||
#include <stasis/common.h>
|
#include <stasis/common.h>
|
||||||
|
|
||||||
#include "../page.h"
|
#include <stasis/page.h>
|
||||||
#include <stasis/operations/pageOperations.h>
|
#include <stasis/operations/pageOperations.h>
|
||||||
#include <stasis/operations/arrayList.h>
|
#include <stasis/operations/arrayList.h>
|
||||||
#include <stasis/transactional.h>
|
#include <stasis/transactional.h>
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
#define __USE_GNU
|
#define __USE_GNU
|
||||||
#define _GNU_SOURCE
|
#define _GNU_SOURCE
|
||||||
#include "../latches.h"
|
#include <stasis/latches.h>
|
||||||
#include <stasis/transactional.h>
|
#include <stasis/transactional.h>
|
||||||
#include <stasis/hash.h>
|
#include <stasis/hash.h>
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
|
@ -9,7 +9,7 @@
|
||||||
#include <stasis/operations/noop.h>
|
#include <stasis/operations/noop.h>
|
||||||
#include <stasis/fifo.h>
|
#include <stasis/fifo.h>
|
||||||
#include <stasis/multiplexer.h>
|
#include <stasis/multiplexer.h>
|
||||||
#include "../logger/logMemory.h"
|
#include <stasis/logger/logMemory.h>
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
|
|
||||||
int HelloWorld(){
|
int HelloWorld(){
|
||||||
|
|
|
@ -46,7 +46,7 @@ terms specified in this license.
|
||||||
*********************************************/
|
*********************************************/
|
||||||
|
|
||||||
#include <stasis/operations.h>
|
#include <stasis/operations.h>
|
||||||
#include "../page.h"
|
#include <stasis/page.h>
|
||||||
|
|
||||||
static int operate(int xid, Page * p, lsn_t lsn, recordid r, const void *d) {
|
static int operate(int xid, Page * p, lsn_t lsn, recordid r, const void *d) {
|
||||||
int i;
|
int i;
|
||||||
|
|
|
@ -46,7 +46,7 @@ terms specified in this license.
|
||||||
**********************************************/
|
**********************************************/
|
||||||
|
|
||||||
#include <stasis/operations.h>
|
#include <stasis/operations.h>
|
||||||
#include "../page.h"
|
#include <stasis/page.h>
|
||||||
|
|
||||||
static int operate(int xid, Page * p, lsn_t lsn, recordid r, const void *d) {
|
static int operate(int xid, Page * p, lsn_t lsn, recordid r, const void *d) {
|
||||||
int i;
|
int i;
|
||||||
|
|
|
@ -46,7 +46,7 @@ terms specified in this license.
|
||||||
**********************************************/
|
**********************************************/
|
||||||
|
|
||||||
#include <stasis/operations.h>
|
#include <stasis/operations.h>
|
||||||
#include "../page.h"
|
#include <stasis/page.h>
|
||||||
|
|
||||||
static int operate(int xid, Page *p, lsn_t lsn, recordid rid, const void *dat) {
|
static int operate(int xid, Page *p, lsn_t lsn, recordid rid, const void *dat) {
|
||||||
stasis_record_write(xid, p, lsn, rid, dat);
|
stasis_record_write(xid, p, lsn, rid, dat);
|
||||||
|
|
|
@ -4,7 +4,7 @@
|
||||||
#include <limits.h>
|
#include <limits.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
#include "../page.h"
|
#include <stasis/page.h>
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
#define __USE_GNU
|
#define __USE_GNU
|
||||||
#define _GNU_SOURCE
|
#define _GNU_SOURCE
|
||||||
#include "../latches.h"
|
#include <stasis/latches.h>
|
||||||
#include <stasis/transactional.h>
|
#include <stasis/transactional.h>
|
||||||
#include <stasis/hash.h>
|
#include <stasis/hash.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
|
@ -8,7 +8,7 @@
|
||||||
// The next two #includes are for deprecated code.
|
// The next two #includes are for deprecated code.
|
||||||
#include <stasis/fifo.h>
|
#include <stasis/fifo.h>
|
||||||
#include <stasis/multiplexer.h>
|
#include <stasis/multiplexer.h>
|
||||||
#include "../logger/logMemory.h"
|
#include <stasis/logger/logMemory.h>
|
||||||
/**
|
/**
|
||||||
re-entrant implementation of a linear hash hable, using nested top actions.
|
re-entrant implementation of a linear hash hable, using nested top actions.
|
||||||
|
|
||||||
|
|
|
@ -1,7 +1,7 @@
|
||||||
#define __USE_GNU
|
#define __USE_GNU
|
||||||
#define _GNU_SOURCE
|
#define _GNU_SOURCE
|
||||||
#include "../latches.h"
|
|
||||||
|
|
||||||
|
#include <stasis/latches.h>
|
||||||
#include <stasis/transactional.h>
|
#include <stasis/transactional.h>
|
||||||
#include <stasis/hash.h>
|
#include <stasis/hash.h>
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
|
|
|
@ -5,7 +5,7 @@
|
||||||
#include <stasis/constants.h>
|
#include <stasis/constants.h>
|
||||||
// XXX including fixed.h breaks page api encapsulation; we need a "last slot"
|
// XXX including fixed.h breaks page api encapsulation; we need a "last slot"
|
||||||
// call.
|
// call.
|
||||||
#include "../page/fixed.h"
|
#include <stasis/page/fixed.h>
|
||||||
#include <pthread.h>
|
#include <pthread.h>
|
||||||
|
|
||||||
static lsm_comparator_t comparators[MAX_LSM_COMPARATORS];
|
static lsm_comparator_t comparators[MAX_LSM_COMPARATORS];
|
||||||
|
|
|
@ -2,7 +2,7 @@
|
||||||
#include <stasis/hash.h>
|
#include <stasis/hash.h>
|
||||||
#include <limits.h>
|
#include <limits.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
#include "../latches.h"
|
#include <stasis/latches.h>
|
||||||
/**
|
/**
|
||||||
|
|
||||||
A from-scratch implementation of linear hashing. Uses the
|
A from-scratch implementation of linear hashing. Uses the
|
||||||
|
|
|
@ -51,7 +51,7 @@ terms specified in this license.
|
||||||
#include <pbl/pbl.h>
|
#include <pbl/pbl.h>
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
#include "../latches.h"
|
#include <stasis/latches.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
/** @todo Remove extern declaration of transactional_2_mutex from nestedTopActions.c */
|
/** @todo Remove extern declaration of transactional_2_mutex from nestedTopActions.c */
|
||||||
extern pthread_mutex_t transactional_2_mutex;
|
extern pthread_mutex_t transactional_2_mutex;
|
||||||
|
|
|
@ -46,7 +46,7 @@ terms specified in this license.
|
||||||
**********************************************/
|
**********************************************/
|
||||||
|
|
||||||
#include <stasis/operations.h>
|
#include <stasis/operations.h>
|
||||||
#include "../page.h"
|
#include <stasis/page.h>
|
||||||
|
|
||||||
int noop(int xid, Page *p, lsn_t lsn, recordid rid, const void *dat) {
|
int noop(int xid, Page *p, lsn_t lsn, recordid rid, const void *dat) {
|
||||||
/* If p is null, then this is a logical no-op that spans pages, so do nothing.
|
/* If p is null, then this is a logical no-op that spans pages, so do nothing.
|
||||||
|
|
|
@ -2,7 +2,7 @@
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
|
|
||||||
#include "config.h"
|
#include "config.h"
|
||||||
#include "../page.h"
|
#include <stasis/page.h>
|
||||||
#include <stasis/operations/pageOperations.h>
|
#include <stasis/operations/pageOperations.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
#include <alloca.h>
|
#include <alloca.h>
|
||||||
|
|
|
@ -1,5 +1,5 @@
|
||||||
#include "config.h"
|
#include "config.h"
|
||||||
#include "../page.h"
|
#include <stasis/page.h>
|
||||||
#include <stasis/operations.h>
|
#include <stasis/operations.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
|
|
||||||
|
|
|
@ -46,7 +46,7 @@ terms specified in this license.
|
||||||
**********************************************/
|
**********************************************/
|
||||||
|
|
||||||
#include <stasis/operations.h>
|
#include <stasis/operations.h>
|
||||||
#include "../page.h"
|
#include <stasis/page.h>
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
static int operate(int xid, Page *p, lsn_t lsn, recordid rid, const void *dat) {
|
static int operate(int xid, Page *p, lsn_t lsn, recordid rid, const void *dat) {
|
||||||
|
|
|
@ -74,20 +74,20 @@ terms specified in this license.
|
||||||
|
|
||||||
#include <config.h>
|
#include <config.h>
|
||||||
#include <stasis/common.h>
|
#include <stasis/common.h>
|
||||||
#include "latches.h"
|
#include <stasis/latches.h>
|
||||||
#include "page.h"
|
#include <stasis/page.h>
|
||||||
|
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
|
|
||||||
#include <stasis/constants.h>
|
#include <stasis/constants.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
#include "blobManager.h"
|
#include <stasis/blobManager.h>
|
||||||
#include <stasis/lockManager.h>
|
#include <stasis/lockManager.h>
|
||||||
#include <stasis/compensations.h>
|
#include <stasis/compensations.h>
|
||||||
#include "page/slotted.h"
|
#include <stasis/page/slotted.h>
|
||||||
#include "page/fixed.h"
|
#include <stasis/page/fixed.h>
|
||||||
#include "page/indirect.h"
|
#include <stasis/page/indirect.h>
|
||||||
#include <stasis/operations/arrayList.h>
|
#include <stasis/operations/arrayList.h>
|
||||||
#include <stasis/bufferPool.h>
|
#include <stasis/bufferPool.h>
|
||||||
#include <stasis/truncation.h>
|
#include <stasis/truncation.h>
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
#include "../page.h"
|
#include <stasis/page.h>
|
||||||
#include "fixed.h"
|
#include <stasis/page/fixed.h>
|
||||||
/** @todo should page implementations provide readLSN / writeLSN??? */
|
/** @todo should page implementations provide readLSN / writeLSN??? */
|
||||||
#include <stasis/truncation.h>
|
#include <stasis/truncation.h>
|
||||||
|
|
||||||
|
|
|
@ -1,10 +1,10 @@
|
||||||
#include "indirect.h"
|
#include <stasis/page.h>
|
||||||
#include "slotted.h"
|
#include <stasis/page/indirect.h>
|
||||||
|
#include <stasis/page/slotted.h>
|
||||||
#include <math.h>
|
#include <math.h>
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
#include "../blobManager.h"
|
#include <stasis/blobManager.h>
|
||||||
#include "../page.h"
|
|
||||||
|
|
||||||
#include <stasis/operations.h>
|
#include <stasis/operations.h>
|
||||||
|
|
||||||
|
|
|
@ -1,8 +1,8 @@
|
||||||
/** $Id$ */
|
/** $Id$ */
|
||||||
|
|
||||||
#include "config.h"
|
#include "config.h"
|
||||||
#include "../page.h"
|
#include <stasis/page.h>
|
||||||
#include "slotted.h"
|
#include <stasis/page/slotted.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
/** @todo should page implementations provide readLSN / writeLSN??? */
|
/** @todo should page implementations provide readLSN / writeLSN??? */
|
||||||
#include <stasis/truncation.h>
|
#include <stasis/truncation.h>
|
||||||
|
|
|
@ -8,7 +8,7 @@
|
||||||
#include <config.h>
|
#include <config.h>
|
||||||
#include <stasis/common.h>
|
#include <stasis/common.h>
|
||||||
|
|
||||||
#include "page.h"
|
#include <stasis/page.h>
|
||||||
#include <stasis/pageCache.h>
|
#include <stasis/pageCache.h>
|
||||||
#include <stasis/bufferManager.h>
|
#include <stasis/bufferManager.h>
|
||||||
|
|
||||||
|
|
|
@ -4,10 +4,10 @@
|
||||||
|
|
||||||
*/
|
*/
|
||||||
#include "config.h"
|
#include "config.h"
|
||||||
#include "page.h"
|
#include <stasis/page.h>
|
||||||
#include <stasis/bufferManager.h>
|
#include <stasis/bufferManager.h>
|
||||||
|
|
||||||
#include "pageFile.h"
|
#include <stasis/pageFile.h>
|
||||||
#include <stasis/pageHandle.h>
|
#include <stasis/pageHandle.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
#include <stasis/logger/logger2.h>
|
#include <stasis/logger/logger2.h>
|
||||||
|
|
|
@ -7,7 +7,7 @@
|
||||||
#include <stasis/logger/logger2.h>
|
#include <stasis/logger/logger2.h>
|
||||||
#include <stasis/truncation.h>
|
#include <stasis/truncation.h>
|
||||||
|
|
||||||
#include "page.h"
|
#include <stasis/page.h>
|
||||||
|
|
||||||
void (*pageWrite)(Page * dat);
|
void (*pageWrite)(Page * dat);
|
||||||
void (*pageRead)(Page * ret);
|
void (*pageRead)(Page * ret);
|
||||||
|
|
|
@ -19,10 +19,10 @@
|
||||||
/** @todo Add better log iterator guard support and remove this include.*/
|
/** @todo Add better log iterator guard support and remove this include.*/
|
||||||
#include <stasis/operations/prepare.h>
|
#include <stasis/operations/prepare.h>
|
||||||
|
|
||||||
#include "logger/logHandle.h"
|
#include <stasis/logger/logHandle.h>
|
||||||
/** @todo Get rid of linkedlist.[ch] */
|
/** @todo Get rid of linkedlist.[ch] */
|
||||||
#include "linkedlist.h"
|
#include <stasis/linkedlist.h>
|
||||||
#include "page.h" // Needed for pageReadLSN.
|
#include <stasis/page.h> // Needed for pageReadLSN.
|
||||||
|
|
||||||
|
|
||||||
static pblHashTable_t * transactionLSN;
|
static pblHashTable_t * transactionLSN;
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
#include <config.h>
|
#include <config.h>
|
||||||
#include <stasis/common.h>
|
#include <stasis/common.h>
|
||||||
#include "latches.h"
|
#include <stasis/latches.h>
|
||||||
|
|
||||||
#include <math.h>
|
#include <math.h>
|
||||||
|
|
||||||
|
|
|
@ -4,16 +4,16 @@
|
||||||
#include <fcntl.h>
|
#include <fcntl.h>
|
||||||
|
|
||||||
#include <stasis/common.h>
|
#include <stasis/common.h>
|
||||||
#include "latches.h"
|
#include <stasis/latches.h>
|
||||||
#include <stasis/transactional.h>
|
#include <stasis/transactional.h>
|
||||||
#include <stasis/recovery.h>
|
#include <stasis/recovery.h>
|
||||||
#include <stasis/bufferManager.h>
|
#include <stasis/bufferManager.h>
|
||||||
#include <stasis/consumer.h>
|
#include <stasis/consumer.h>
|
||||||
#include <stasis/lockManager.h>
|
#include <stasis/lockManager.h>
|
||||||
#include <stasis/compensations.h>
|
#include <stasis/compensations.h>
|
||||||
#include "pageFile.h"
|
#include <stasis/pageFile.h>
|
||||||
#include <stasis/pageHandle.h>
|
#include <stasis/pageHandle.h>
|
||||||
#include "page.h"
|
#include <stasis/page.h>
|
||||||
#include <stasis/logger/logger2.h>
|
#include <stasis/logger/logger2.h>
|
||||||
#include <stasis/truncation.h>
|
#include <stasis/truncation.h>
|
||||||
#include <stasis/io/handle.h>
|
#include <stasis/io/handle.h>
|
||||||
|
|
|
@ -2,7 +2,7 @@
|
||||||
#include <stasis/truncation.h>
|
#include <stasis/truncation.h>
|
||||||
#include <pbl/pbl.h>
|
#include <pbl/pbl.h>
|
||||||
#include <stasis/logger/logger2.h>
|
#include <stasis/logger/logger2.h>
|
||||||
#include "page.h"
|
#include <stasis/page.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
|
|
||||||
static int initialized = 0;
|
static int initialized = 0;
|
||||||
|
|
|
@ -2,7 +2,7 @@
|
||||||
#define __BLOB_MANAGER_H
|
#define __BLOB_MANAGER_H
|
||||||
|
|
||||||
#include <stasis/common.h>
|
#include <stasis/common.h>
|
||||||
#include "page.h"
|
#include <stasis/page.h>
|
||||||
BEGIN_C_DECLS
|
BEGIN_C_DECLS
|
||||||
|
|
||||||
/**
|
/**
|
|
@ -102,7 +102,7 @@ terms specified in this license.
|
||||||
#define __PAGE_H__
|
#define __PAGE_H__
|
||||||
|
|
||||||
#include <stasis/common.h>
|
#include <stasis/common.h>
|
||||||
#include "latches.h"
|
#include <stasis/latches.h>
|
||||||
#include <stasis/transactional.h>
|
#include <stasis/transactional.h>
|
||||||
|
|
||||||
BEGIN_C_DECLS
|
BEGIN_C_DECLS
|
|
@ -75,7 +75,7 @@ terms specified in this license.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
#include <stasis/common.h>
|
#include <stasis/common.h>
|
||||||
#include "../page.h"
|
#include <stasis/page.h>
|
||||||
|
|
||||||
#define units_from_start_raw(unit,page,count) (((unit*)(page->memAddr))+(count))
|
#define units_from_start_raw(unit,page,count) (((unit*)(page->memAddr))+(count))
|
||||||
|
|
7
stasis/pageFile.h
Normal file
7
stasis/pageFile.h
Normal file
|
@ -0,0 +1,7 @@
|
||||||
|
|
||||||
|
#ifndef __PAGE_FILE_H
|
||||||
|
#define __PAGE_FILE_H
|
||||||
|
|
||||||
|
void openPageFile();
|
||||||
|
|
||||||
|
#endif /* __PAGE_FILE_H */
|
|
@ -47,7 +47,7 @@ terms specified in this license.
|
||||||
#include <stasis/transactional.h>
|
#include <stasis/transactional.h>
|
||||||
|
|
||||||
|
|
||||||
#include "../../src/stasis/page.h"
|
#include <stasis/page.h>
|
||||||
|
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
#include <limits.h>
|
#include <limits.h>
|
||||||
|
|
|
@ -46,7 +46,6 @@ terms specified in this license.
|
||||||
|
|
||||||
#include <stasis/logger/logger2.h>
|
#include <stasis/logger/logger2.h>
|
||||||
#include <stasis/truncation.h>
|
#include <stasis/truncation.h>
|
||||||
#include "../../src/stasis/logger/logWriter.h"
|
|
||||||
#include "../check_includes.h"
|
#include "../check_includes.h"
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
|
|
||||||
|
|
|
@ -1,8 +1,8 @@
|
||||||
#include <config.h>
|
#include <config.h>
|
||||||
#include <check.h>
|
#include <check.h>
|
||||||
#include <stasis/transactional.h>
|
#include <stasis/transactional.h>
|
||||||
#include "../../src/stasis/latches.h"
|
#include <stasis/latches.h>
|
||||||
#include "../../src/stasis/page.h"
|
#include <stasis/page.h>
|
||||||
#include <stasis/bufferManager.h>
|
#include <stasis/bufferManager.h>
|
||||||
#include <sched.h>
|
#include <sched.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
|
|
|
@ -46,8 +46,8 @@ terms specified in this license.
|
||||||
|
|
||||||
#include "../check_includes.h"
|
#include "../check_includes.h"
|
||||||
#include <stasis/bufferManager.h>
|
#include <stasis/bufferManager.h>
|
||||||
#include "src/stasis/page.h"
|
#include <stasis/page.h>
|
||||||
#include "../../src/stasis/page/indirect.h"
|
#include <stasis/page/indirect.h>
|
||||||
|
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
|
|
||||||
|
|
|
@ -51,11 +51,11 @@ terms specified in this license.
|
||||||
#include <check.h>
|
#include <check.h>
|
||||||
|
|
||||||
#include <stasis/transactional.h>
|
#include <stasis/transactional.h>
|
||||||
#include "../../src/stasis/logger/logHandle.h"
|
#include <stasis/logger/logHandle.h>
|
||||||
#include <stasis/logger/logger2.h>
|
#include <stasis/logger/logger2.h>
|
||||||
#include "../../src/stasis/logger/logWriter.h"
|
#include <stasis/logger/logWriter.h>
|
||||||
|
|
||||||
#include "../../src/stasis/latches.h"
|
#include <stasis/latches.h>
|
||||||
#include <sched.h>
|
#include <sched.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
#include "../check_includes.h"
|
#include "../check_includes.h"
|
||||||
|
|
|
@ -51,7 +51,7 @@ terms specified in this license.
|
||||||
#include "../check_includes.h"
|
#include "../check_includes.h"
|
||||||
|
|
||||||
#include <stasis/multiplexer.h>
|
#include <stasis/multiplexer.h>
|
||||||
#include "../../src/stasis/logger/logMemory.h"
|
#include <stasis/logger/logMemory.h>
|
||||||
|
|
||||||
#include <sys/time.h>
|
#include <sys/time.h>
|
||||||
#include <time.h>
|
#include <time.h>
|
||||||
|
|
|
@ -47,7 +47,7 @@ terms specified in this license.
|
||||||
#include <stasis/bufferManager.h>
|
#include <stasis/bufferManager.h>
|
||||||
#include <stasis/truncation.h>
|
#include <stasis/truncation.h>
|
||||||
#include "../check_includes.h"
|
#include "../check_includes.h"
|
||||||
#include "../../src/stasis/page.h"
|
#include <stasis/page.h>
|
||||||
#define LOG_NAME "check_operations.log"
|
#define LOG_NAME "check_operations.log"
|
||||||
|
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
|
|
|
@ -49,14 +49,14 @@ terms specified in this license.
|
||||||
#include <config.h>
|
#include <config.h>
|
||||||
#include <check.h>
|
#include <check.h>
|
||||||
|
|
||||||
#include "../../src/stasis/page.h"
|
#include <stasis/page.h>
|
||||||
#include "../../src/stasis/page/indirect.h"
|
#include <stasis/page/indirect.h>
|
||||||
#include "../../src/stasis/page/slotted.h"
|
#include <stasis/page/slotted.h>
|
||||||
#include "../../src/stasis/blobManager.h"
|
#include <stasis/blobManager.h>
|
||||||
#include <stasis/bufferManager.h>
|
#include <stasis/bufferManager.h>
|
||||||
#include <stasis/transactional.h>
|
#include <stasis/transactional.h>
|
||||||
|
|
||||||
#include "../../src/stasis/latches.h"
|
#include <stasis/latches.h>
|
||||||
#include <sched.h>
|
#include <sched.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
#include "../check_includes.h"
|
#include "../check_includes.h"
|
||||||
|
|
|
@ -44,19 +44,18 @@ terms specified in this license.
|
||||||
#include <config.h>
|
#include <config.h>
|
||||||
#include <check.h>
|
#include <check.h>
|
||||||
|
|
||||||
#include "../../src/stasis/page.h"
|
#include <stasis/page.h>
|
||||||
#include <stasis/bufferManager.h>
|
#include <stasis/bufferManager.h>
|
||||||
#include <stasis/transactional.h>
|
#include <stasis/transactional.h>
|
||||||
#include <stasis/truncation.h>
|
#include <stasis/truncation.h>
|
||||||
#include <stasis/logger/logger2.h>
|
#include <stasis/logger/logger2.h>
|
||||||
|
|
||||||
#include "../../src/stasis/latches.h"
|
#include <stasis/latches.h>
|
||||||
#include <sched.h>
|
#include <sched.h>
|
||||||
#include <assert.h>
|
#include <assert.h>
|
||||||
#include "../check_includes.h"
|
#include "../check_includes.h"
|
||||||
|
|
||||||
#define LOG_NAME "check_pageOperations.log"
|
#define LOG_NAME "check_pageOperations.log"
|
||||||
#include "../../src/stasis/logger/logWriter.h"
|
|
||||||
extern int numActiveXactions;
|
extern int numActiveXactions;
|
||||||
|
|
||||||
START_TEST(pageOpCheckRecovery) {
|
START_TEST(pageOpCheckRecovery) {
|
||||||
|
|
|
@ -46,7 +46,6 @@ terms specified in this license.
|
||||||
#include <stasis/transactional.h>
|
#include <stasis/transactional.h>
|
||||||
#include <stasis/logger/logger2.h>
|
#include <stasis/logger/logger2.h>
|
||||||
#include <stasis/truncation.h>
|
#include <stasis/truncation.h>
|
||||||
#include "../../src/stasis/logger/logWriter.h"
|
|
||||||
#include "../check_includes.h"
|
#include "../check_includes.h"
|
||||||
|
|
||||||
#define LOG_NAME "check_recovery.log"
|
#define LOG_NAME "check_recovery.log"
|
||||||
|
|
|
@ -2,8 +2,8 @@
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
|
|
||||||
#include "../src/stasis/logger/logHandle.h"
|
#include <stasis/logger/logHandle.h>
|
||||||
#include "../src/stasis/logger/logWriter.h"
|
#include <stasis/logger/logWriter.h>
|
||||||
|
|
||||||
|
|
||||||
static char * logEntryToString(const LogEntry * le) {
|
static char * logEntryToString(const LogEntry * le) {
|
||||||
|
|
Loading…
Reference in a new issue