Mercurial > projects > ldc
view dmd/root/async.c @ 1650:40bd4a0d4870
Update to work with LLVM 2.7.
Removed use of dyn_cast, llvm no compiles
without exceptions and rtti by
default. We do need exceptions for the libconfig stuff, but rtti isn't
necessary (anymore).
Debug info needs to be rewritten, as in LLVM 2.7 the format has
completely changed. To have something to look at while rewriting, the
old code has been wrapped inside #ifndef DISABLE_DEBUG_INFO , this means
that you have to define this to compile at the moment.
Updated tango 0.99.9 patch to include updated EH runtime code, which is
needed for LLVM 2.7 as well.
author | Tomas Lindquist Olsen |
---|---|
date | Wed, 19 May 2010 12:42:32 +0200 |
parents | def7a1d494fd |
children |
line wrap: on
line source
#define _MT 1 #include <stdio.h> #include <stdlib.h> #include <assert.h> #if _WIN32 #include <windows.h> #include <stdio.h> #include <errno.h> #include <process.h> #include "root.h" #include "rmem.h" static unsigned __stdcall startthread(void *p); struct FileData { File *file; int result; HANDLE event; }; struct AsyncRead { static AsyncRead *create(size_t nfiles); void addFile(File *file); void start(); int read(size_t i); static void dispose(AsyncRead *); HANDLE hThread; size_t filesdim; size_t filesmax; FileData files[1]; }; AsyncRead *AsyncRead::create(size_t nfiles) { AsyncRead *aw = (AsyncRead *)mem.calloc(1, sizeof(AsyncRead) + (nfiles - 1) * sizeof(FileData)); aw->filesmax = nfiles; return aw; } void AsyncRead::addFile(File *file) { //printf("addFile(file = %p)\n", file); //printf("filesdim = %d, filesmax = %d\n", filesdim, filesmax); assert(filesdim < filesmax); files[filesdim].file = file; files[filesdim].event = CreateEvent(NULL, TRUE, FALSE, NULL); ResetEvent(files[filesdim].event); filesdim++; } void AsyncRead::start() { //printf("aw->filesdim = %p %d\n", this, filesdim); if (filesdim) { unsigned threadaddr; hThread = (HANDLE) _beginthreadex(NULL, 0, &startthread, this, 0, (unsigned *)&threadaddr); if (hThread) { SetThreadPriority(hThread, THREAD_PRIORITY_HIGHEST); } else { assert(0); } } } int AsyncRead::read(size_t i) { FileData *f = &files[i]; WaitForSingleObject(f->event, INFINITE); Sleep(0); // give up time slice return f->result; } void AsyncRead::dispose(AsyncRead *aw) { delete aw; } unsigned __stdcall startthread(void *p) { AsyncRead *aw = (AsyncRead *)p; //printf("aw->filesdim = %p %d\n", aw, aw->filesdim); for (size_t i = 0; i < aw->filesdim; i++) { FileData *f = &aw->files[i]; f->result = f->file->read(); SetEvent(f->event); } _endthreadex(EXIT_SUCCESS); return EXIT_SUCCESS; // if skidding } #else #include <stdio.h> #include <errno.h> #include "root.h" #include "rmem.h" struct FileData { File *file; int result; //HANDLE event; }; struct AsyncRead { static AsyncRead *create(size_t nfiles); void addFile(File *file); void start(); int read(size_t i); static void dispose(AsyncRead *); //HANDLE hThread; size_t filesdim; size_t filesmax; FileData files[1]; }; AsyncRead *AsyncRead::create(size_t nfiles) { AsyncRead *aw = (AsyncRead *)mem.calloc(1, sizeof(AsyncRead) + (nfiles - 1) * sizeof(FileData)); aw->filesmax = nfiles; return aw; } void AsyncRead::addFile(File *file) { //printf("addFile(file = %p)\n", file); //printf("filesdim = %d, filesmax = %d\n", filesdim, filesmax); assert(filesdim < filesmax); files[filesdim].file = file; //files[filesdim].event = CreateEvent(NULL, TRUE, FALSE, NULL); //ResetEvent(files[filesdim].event); filesdim++; } void AsyncRead::start() { } int AsyncRead::read(size_t i) { FileData *f = &files[i]; f->result = f->file->read(); return f->result; } void AsyncRead::dispose(AsyncRead *aw) { delete aw; } #endif