From: Brian Demsky Date: Sat, 21 Jul 2012 02:12:20 +0000 (-0700) Subject: move more configurables and add documentation X-Git-Url: http://plrg.eecs.uci.edu/git/?p=c11tester.git;a=commitdiff_plain;h=1dbc6ce8102e79ead8c3ae09214126abab1b5c51 move more configurables and add documentation --- diff --git a/common.h b/common.h index 0db1cfe1..9794a92e 100644 --- a/common.h +++ b/common.h @@ -6,12 +6,7 @@ #define __COMMON_H__ #include - -/* -#ifndef CONFIG_DEBUG -#define CONFIG_DEBUG -#endif -*/ +#include "config.h" #ifdef CONFIG_DEBUG #define DEBUG(fmt, ...) do { printf("*** %25s(): line %-4d *** " fmt, __func__, __LINE__, ##__VA_ARGS__); } while (0) diff --git a/config.h b/config.h index 62bc92b5..1d0b6380 100644 --- a/config.h +++ b/config.h @@ -5,16 +5,39 @@ #ifndef CONFIG_H #define CONFIG_H +/** Turn on debugging. */ +/* #ifndef CONFIG_DEBUG + #define CONFIG_DEBUG + #endif +*/ + + /** Do we have a 48 bit virtual address (64 bit machine) or 32 bit addresses. * Set to 1 for 48-bit, 0 for 32-bit. */ #ifndef BIT48 - #ifdef _LP64 #define BIT48 1 #else #define BIT48 0 #endif - #endif /* BIT48 */ +/** Snapshotting configurables */ + +/** If USE_MPROTECT_SNAPSHOT=1, then snapshot by using mmap() and mprotect() + * If USE_MPROTECT_SNAPSHOT=0, then snapshot by using fork() */ +#define USE_MPROTECT_SNAPSHOT 1 + +/** Size of signal stack */ +#define SIGSTACKSIZE 32768 + +/** Page size configuration */ +#define PAGESIZE 4096 + +/** Thread parameters */ + +/* Size of stack to allocate for a thread. */ +#define STACK_SIZE (1024 * 1024) + + #endif diff --git a/snapshot.h b/snapshot.h index e41eb9c9..f8995923 100644 --- a/snapshot.h +++ b/snapshot.h @@ -6,15 +6,7 @@ #define _SNAPSHOT_H #include "snapshot-interface.h" - -#define PAGESIZE 4096 - -/* If USE_MPROTECT_SNAPSHOT=1, then snapshot by using mmap() and mprotect() - If USE_MPROTECT_SNAPSHOT=0, then snapshot by using fork() */ -#define USE_MPROTECT_SNAPSHOT 1 - -/* Size of signal stack */ -#define SIGSTACKSIZE 32768 +#include "config.h" void addMemoryRegionToSnapShot( void * ptr, unsigned int numPages ); snapshot_id takeSnapshot( ); diff --git a/threads.cc b/threads.cc index 399472c9..cde331db 100644 --- a/threads.cc +++ b/threads.cc @@ -2,7 +2,6 @@ * @brief Thread functions. */ - #include "libthreads.h" #include "common.h" #include "threads.h" @@ -10,18 +9,20 @@ /* global "model" object */ #include "model.h" -#define STACK_SIZE (1024 * 1024) - +/** Allocate a stack for a new thread. */ static void * stack_allocate(size_t size) { return malloc(size); } +/** Free a stack for a terminated thread. */ static void stack_free(void *stack) { free(stack); } +/** Return the currently executing thread. */ + Thread * thread_current(void) { ASSERT(model); @@ -46,6 +47,11 @@ void thread_startup() { curr_thread->start_routine(curr_thread->arg); } +/** Create a thread context for a new thread so we can use + * setcontext/getcontext/swapcontext to swap it out. + * @return 0 on success. + */ + int Thread::create_context() { int ret; @@ -75,6 +81,9 @@ int Thread::swap(ucontext_t *ctxt, Thread *t) return swapcontext(ctxt, &t->context); } + +/** Terminate a thread and free its stack. */ + void Thread::complete() { if (state != THREAD_COMPLETED) { @@ -85,6 +94,12 @@ void Thread::complete() } } +/** Create a new thread. + * Takes the following parameters: + * @param t The thread identifier of the newly created thread. + * @param func The function that the thread will call. + * @param a The parameter to pass to this function. */ + Thread::Thread(thrd_t *t, void (*func)(void *), void *a) : start_routine(func), arg(a), @@ -110,6 +125,8 @@ Thread::~Thread() model->remove_thread(this); } +/** Return the thread_id_t corresponding to this Thread object. */ + thread_id_t Thread::get_id() { return id;