100 lines
2.1 KiB
C
100 lines
2.1 KiB
C
#include <unistd.h>
|
|
#include <errno.h>
|
|
#include <string.h>
|
|
#include <stdlib.h>
|
|
#include "threads.h"
|
|
|
|
void* parseunit(void* input) {
|
|
COMPILEUNIT* unit = (COMPILEUNIT*)input;
|
|
|
|
unit->parsed = parse(unit->parser);
|
|
|
|
pthread_exit(NULL);
|
|
}
|
|
|
|
void* compileunit(void* input) {
|
|
COMPILEUNIT* unit = (COMPILEUNIT*)input;
|
|
|
|
unit->compiled = compileclass(unit->compiler, unit->parsed);
|
|
|
|
pthread_exit(NULL);
|
|
}
|
|
|
|
char* getclassname(char* filename) {
|
|
int len = strlen(filename) - 1;
|
|
|
|
for(len = len; len >= 0; len--)
|
|
if(filename[len] == '.')
|
|
break;
|
|
|
|
int sz = sizeof(char) * (len + 1);
|
|
char* classname = (char*)malloc(sz);
|
|
snprintf(classname, sz, "%s", filename); // legitimately needs to be snprintf
|
|
return classname;
|
|
}
|
|
|
|
void* vmtranslateunit(void* input) {
|
|
COMPILEUNIT* unit = (COMPILEUNIT*)input;
|
|
|
|
if(unit->compiled == NULL) {
|
|
eprintf("Class '%s' is empty; file '%s'\n", unit->parsed->name, unit->file->name);
|
|
exit(1);
|
|
}
|
|
|
|
char* classname = getclassname(unit->file->name);
|
|
unit->vmtranslator = mkvmtranslator(classname, unit->compiled);
|
|
unit->asmlns = translatevm(unit->vmtranslator);
|
|
free(classname);
|
|
|
|
pthread_exit(NULL);
|
|
}
|
|
|
|
void waitthreads(pthread_t* threads, int amount) {
|
|
void* status;
|
|
int code;
|
|
for(int i = 0; i < amount; i++) {
|
|
code = pthread_join(threads[i], &status);
|
|
if(code) {
|
|
eprintf("Error while joining thread %i: %s\n", i, strerror(code));
|
|
exit(code);
|
|
}
|
|
}
|
|
}
|
|
|
|
void actonunits(COMPILEUNIT* units, void*(*fun)(void*)) {
|
|
pthread_t mythreads[_SC_THREAD_THREADS_MAX];
|
|
pthread_attr_t attr;
|
|
pthread_attr_init(&attr);
|
|
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE);
|
|
|
|
COMPILEUNIT* curr = units;
|
|
|
|
int i;
|
|
int code;
|
|
do {
|
|
i = 0;
|
|
while(curr != NULL && i < _SC_THREAD_THREADS_MAX) {
|
|
code = pthread_create(&mythreads[i], &attr, fun, curr);
|
|
|
|
if(code) {
|
|
eprintf("Error while creating thread %i: %s\n", i, strerror(code));
|
|
exit(code);
|
|
}
|
|
|
|
curr = curr->next;
|
|
i++;
|
|
}
|
|
waitthreads(mythreads, i);
|
|
} while(i == _SC_THREAD_THREADS_MAX);
|
|
|
|
pthread_attr_destroy(&attr);
|
|
}
|
|
|
|
void freeunit(COMPILEUNIT* u) {
|
|
freeparser(u->parser);
|
|
freelnblk(u->compiled);
|
|
freestrlist(u->asmlns);
|
|
freevmtranslator(u->vmtranslator);
|
|
free(u);
|
|
}
|