]> gitweb.factorcode.org Git - factor.git/blob - vm/factor.cpp
moved the thread stuff around a bit
[factor.git] / vm / factor.cpp
1 #include "master.hpp"
2
3 namespace factor
4 {
5
6 factorvm *vm;
7
8 unordered_map<long,factorvm*> thread_vms;
9
10 factorvm *lookup_vm(unsigned long threadid)
11 {
12         return thread_vms[threadid];
13 }
14
15 void register_vm(unsigned long threadid, factorvm *vm)
16 {
17         thread_vms[threadid] = vm;
18 }
19
20
21 void factorvm::default_parameters(vm_parameters *p)
22 {
23         p->image_path = NULL;
24
25         /* We make a wild guess here that if we're running on ARM, we don't
26         have a lot of memory. */
27 #ifdef FACTOR_ARM
28         p->ds_size = 8 * sizeof(cell);
29         p->rs_size = 8 * sizeof(cell);
30
31         p->gen_count = 2;
32         p->code_size = 4;
33         p->young_size = 1;
34         p->aging_size = 1;
35         p->tenured_size = 6;
36 #else
37         p->ds_size = 32 * sizeof(cell);
38         p->rs_size = 32 * sizeof(cell);
39
40         p->gen_count = 3;
41         p->code_size = 8 * sizeof(cell);
42         p->young_size = sizeof(cell) / 4;
43         p->aging_size = sizeof(cell) / 2;
44         p->tenured_size = 4 * sizeof(cell);
45 #endif
46
47         p->max_pic_size = 3;
48
49         p->secure_gc = false;
50         p->fep = false;
51
52 #ifdef WINDOWS
53         p->console = false;
54 #else
55         p->console = true;
56 #endif
57
58         p->stack_traces = true;
59 }
60
61 bool factorvm::factor_arg(const vm_char* str, const vm_char* arg, cell* value)
62 {
63         int val;
64         if(SSCANF(str,arg,&val) > 0)
65         {
66                 *value = val;
67                 return true;
68         }
69         else
70                 return false;
71 }
72
73 void factorvm::init_parameters_from_args(vm_parameters *p, int argc, vm_char **argv)
74 {
75         default_parameters(p);
76         p->executable_path = argv[0];
77
78         int i = 0;
79
80         for(i = 1; i < argc; i++)
81         {
82                 if(factor_arg(argv[i],STRING_LITERAL("-datastack=%d"),&p->ds_size));
83                 else if(factor_arg(argv[i],STRING_LITERAL("-retainstack=%d"),&p->rs_size));
84                 else if(factor_arg(argv[i],STRING_LITERAL("-generations=%d"),&p->gen_count));
85                 else if(factor_arg(argv[i],STRING_LITERAL("-young=%d"),&p->young_size));
86                 else if(factor_arg(argv[i],STRING_LITERAL("-aging=%d"),&p->aging_size));
87                 else if(factor_arg(argv[i],STRING_LITERAL("-tenured=%d"),&p->tenured_size));
88                 else if(factor_arg(argv[i],STRING_LITERAL("-codeheap=%d"),&p->code_size));
89                 else if(factor_arg(argv[i],STRING_LITERAL("-pic=%d"),&p->max_pic_size));
90                 else if(STRCMP(argv[i],STRING_LITERAL("-securegc")) == 0) p->secure_gc = true;
91                 else if(STRCMP(argv[i],STRING_LITERAL("-fep")) == 0) p->fep = true;
92                 else if(STRNCMP(argv[i],STRING_LITERAL("-i="),3) == 0) p->image_path = argv[i] + 3;
93                 else if(STRCMP(argv[i],STRING_LITERAL("-console")) == 0) p->console = true;
94                 else if(STRCMP(argv[i],STRING_LITERAL("-no-stack-traces")) == 0) p->stack_traces = false;
95         }
96 }
97
98 /* Do some initialization that we do once only */
99 void factorvm::do_stage1_init()
100 {
101         print_string("*** Stage 2 early init... ");
102         fflush(stdout);
103
104         compile_all_words();
105         userenv[STAGE2_ENV] = T;
106
107         print_string("done\n");
108         fflush(stdout);
109 }
110
111 void factorvm::init_factor(vm_parameters *p)
112 {
113         /* Kilobytes */
114         p->ds_size = align_page(p->ds_size << 10);
115         p->rs_size = align_page(p->rs_size << 10);
116
117         /* Megabytes */
118         p->young_size <<= 20;
119         p->aging_size <<= 20;
120         p->tenured_size <<= 20;
121         p->code_size <<= 20;
122
123         /* Disable GC during init as a sanity check */
124         gc_off = true;
125
126         /* OS-specific initialization */
127         early_init();
128
129         const vm_char *executable_path = vm_executable_path();
130
131         if(executable_path)
132                 p->executable_path = executable_path;
133
134         if(p->image_path == NULL)
135                 p->image_path = default_image_path();
136
137         srand(current_micros());
138         init_ffi();
139         init_stacks(p->ds_size,p->rs_size);
140         load_image(p);
141         init_c_io();
142         init_inline_caching(p->max_pic_size);
143         init_signals();
144
145         if(p->console)
146                 open_console();
147
148         init_profiler();
149
150         userenv[CPU_ENV] = allot_alien(F,(cell)FACTOR_CPU_STRING);
151         userenv[OS_ENV] = allot_alien(F,(cell)FACTOR_OS_STRING);
152         userenv[CELL_SIZE_ENV] = tag_fixnum(sizeof(cell));
153         userenv[EXECUTABLE_ENV] = allot_alien(F,(cell)p->executable_path);
154         userenv[ARGS_ENV] = F;
155         userenv[EMBEDDED_ENV] = F;
156
157         /* We can GC now */
158         gc_off = false;
159
160         if(userenv[STAGE2_ENV] == F)
161         {
162                 userenv[STACK_TRACES_ENV] = tag_boolean(p->stack_traces);
163                 do_stage1_init();
164         }
165 }
166
167 /* May allocate memory */
168 void factorvm::pass_args_to_factor(int argc, vm_char **argv)
169 {
170         growable_array args(this);
171         int i;
172
173         for(i = 1; i < argc; i++){
174                 args.add(allot_alien(F,(cell)argv[i]));
175         }
176
177         args.trim();
178         userenv[ARGS_ENV] = args.elements.value();
179 }
180
181 void factorvm::start_factor(vm_parameters *p)
182 {
183         if(p->fep) factorbug();
184
185         nest_stacks();
186         c_to_factor_toplevel(userenv[BOOT_ENV]);
187         unnest_stacks();
188 }
189
190
191 char *factorvm::factor_eval_string(char *string)
192 {
193         char *(*callback)(char *) = (char *(*)(char *))alien_offset(userenv[EVAL_CALLBACK_ENV]);
194         return callback(string);
195 }
196
197 void factorvm::factor_eval_free(char *result)
198 {
199         free(result);
200 }
201
202 void factorvm::factor_yield()
203 {
204         void (*callback)() = (void (*)())alien_offset(userenv[YIELD_CALLBACK_ENV]);
205         callback();
206 }
207
208 void factorvm::factor_sleep(long us)
209 {
210         void (*callback)(long) = (void (*)(long))alien_offset(userenv[SLEEP_CALLBACK_ENV]);
211         callback(us);
212 }
213
214 void factorvm::start_standalone_factor(int argc, vm_char **argv)
215 {
216         register_vm(thread_id(),this);
217         vm_parameters p;
218         default_parameters(&p);
219         init_parameters_from_args(&p,argc,argv);
220         init_factor(&p);
221         pass_args_to_factor(argc,argv);
222         start_factor(&p);
223 }
224
225 struct startargs {
226         int argc;
227         vm_char **argv;
228 };
229
230 void* start_standalone_factor_thread(void *arg) 
231 {
232         factorvm *newvm = new factorvm;
233         startargs *args = (startargs*) arg;
234         newvm->start_standalone_factor(args->argc, args->argv);
235         return 0;
236 }
237
238
239 VM_C_API void start_standalone_factor(int argc, vm_char **argv)
240 {
241         factorvm *newvm = new factorvm;
242         vm = newvm;
243         return newvm->start_standalone_factor(argc,argv);
244 }
245
246 VM_C_API THREADHANDLE start_standalone_factor_in_new_thread(int argc, vm_char **argv)
247 {
248         startargs *args = new startargs;   // leaks startargs structure
249         args->argc = argc; args->argv = argv;
250         return start_thread(start_standalone_factor_thread,args);
251 }
252
253 }