← Back to branch summary

~ubuntu-branches/ubuntu/intrepid/ruby1.9/intrepid-updates

« back to all changes in this revision

Viewing changes to vm_core.h

  • Committer: Bazaar Package Importer
  • Author(s): Matthias Klose
  • Date: 2007-09-04 16:01:17 UTC
  • mfrom: (1.1.8 upstream)
  • Revision ID: james.westby@ubuntu.com-20070904160117-i15zckg2nhxe9fyw
Tags: 1.9.0+20070830-2ubuntu1
* Sync from Debian; remaining changes:
  - Add -g to CFLAGS.
* Fixes build failure on ia64.
* Fixes build failure with gcc-4.2 on lpia.
* Robustify check for target_os, fixing build failure on lpia.
* Set Ubuntu maintainer address.

Show diffs side-by-side

added added

removed removed

Lines of Context:
vm_core.h
 
1
/**********************************************************************
 
2
 
 
3
  vm_core.h - 
 
4
 
 
5
  $Author: ko1 $
 
6
  $Date: 2007-08-28 01:48:14 +0900 (火, 28  8月 2007) $
 
7
  created at: 04/01/01 19:41:38 JST
 
8
 
 
9
  Copyright (C) 2004-2007 Koichi Sasada
 
10
 
 
11
**********************************************************************/
 
12
 
 
13
#ifndef RUBY_CORE_H
 
14
#define RUBY_CORE_H
 
15
 
 
16
#define RUBY_VM_THREAD_MODEL 2
 
17
 
 
18
#include <setjmp.h>
 
19
 
 
20
#include "ruby/ruby.h"
 
21
#include "ruby/signal.h"
 
22
#include "ruby/st.h"
 
23
#include "ruby/node.h"
 
24
 
 
25
#include "debug.h"
 
26
#include "vm_opts.h"
 
27
#include "id.h"
 
28
 
 
29
#if   defined(_WIN32)
 
30
#include "thread_win32.h"
 
31
#elif defined(HAVE_PTHREAD_H)
 
32
#include "thread_pthread.h"
 
33
#else
 
34
#error "unsupported thread type"
 
35
#endif
 
36
 
 
37
#include <signal.h>
 
38
 
 
39
#ifndef NSIG
 
40
# ifdef DJGPP
 
41
#  define NSIG SIGMAX
 
42
# else
 
43
#  define NSIG (_SIGMAX + 1)      /* For QNX */
 
44
# endif
 
45
#endif
 
46
 
 
47
#define RUBY_NSIG NSIG
 
48
 
 
49
/*****************/
 
50
/* configuration */
 
51
/*****************/
 
52
 
 
53
/* gcc ver. check */
 
54
#if defined(__GNUC__) && __GNUC__ >= 2
 
55
 
 
56
#if OPT_TOKEN_THREADED_CODE
 
57
#if OPT_DIRECT_THREADED_CODE
 
58
#undef OPT_DIRECT_THREADED_CODE
 
59
#endif
 
60
#endif
 
61
 
 
62
#else /* defined(__GNUC__) && __GNUC__ >= 2 */
 
63
 
 
64
/* disable threaded code options */
 
65
#if OPT_DIRECT_THREADED_CODE
 
66
#undef OPT_DIRECT_THREADED_CODE
 
67
#endif
 
68
#if OPT_TOKEN_THREADED_CODE
 
69
#undef OPT_TOKEN_THREADED_CODE
 
70
#endif
 
71
#endif
 
72
 
 
73
/* call threaded code */
 
74
#if    OPT_CALL_THREADED_CODE
 
75
#if    OPT_DIRECT_THREADED_CODE
 
76
#undef OPT_DIRECT_THREADED_CODE
 
77
#endif /* OPT_DIRECT_THREADED_CODE */
 
78
#if    OPT_STACK_CACHING
 
79
#undef OPT_STACK_CACHING
 
80
#endif /* OPT_STACK_CACHING */
 
81
#endif /* OPT_CALL_THREADED_CODE */
 
82
 
 
83
/* likely */
 
84
#if __GNUC__ >= 3
 
85
#define LIKELY(x)   (__builtin_expect((x), 1))
 
86
#define UNLIKELY(x) (__builtin_expect((x), 0))
 
87
#else /* __GNUC__ >= 3 */
 
88
#define LIKELY(x)   (x)
 
89
#define UNLIKELY(x) (x)
 
90
#endif /* __GNUC__ >= 3 */
 
91
 
 
92
#define ISEQ_TYPE_TOP    INT2FIX(1)
 
93
#define ISEQ_TYPE_METHOD INT2FIX(2)
 
94
#define ISEQ_TYPE_BLOCK  INT2FIX(3)
 
95
#define ISEQ_TYPE_CLASS  INT2FIX(4)
 
96
#define ISEQ_TYPE_RESCUE INT2FIX(5)
 
97
#define ISEQ_TYPE_ENSURE INT2FIX(6)
 
98
#define ISEQ_TYPE_EVAL   INT2FIX(7)
 
99
#define ISEQ_TYPE_DEFINED_GUARD INT2FIX(8)
 
100
 
 
101
#define CATCH_TYPE_RESCUE INT2FIX(1)
 
102
#define CATCH_TYPE_ENSURE INT2FIX(2)
 
103
#define CATCH_TYPE_RETRY  INT2FIX(3)
 
104
#define CATCH_TYPE_BREAK  INT2FIX(4)
 
105
#define CATCH_TYPE_REDO   INT2FIX(5)
 
106
#define CATCH_TYPE_NEXT   INT2FIX(6)
 
107
 
 
108
struct iseq_insn_info_entry {
 
109
    unsigned short position;
 
110
    unsigned short line_no;
 
111
};
 
112
 
 
113
struct iseq_catch_table_entry {
 
114
    VALUE type;
 
115
    VALUE iseq;
 
116
    unsigned long start;
 
117
    unsigned long end;
 
118
    unsigned long cont;
 
119
    unsigned long sp;
 
120
};
 
121
 
 
122
#define INITIAL_ISEQ_COMPILE_DATA_STORAGE_BUFF_SIZE (512)
 
123
 
 
124
struct iseq_compile_data_storage {
 
125
    struct iseq_compile_data_storage *next;
 
126
    unsigned long pos;
 
127
    unsigned long size;
 
128
    char *buff;
 
129
};
 
130
 
 
131
struct iseq_compile_data_ensure_node_stack;
 
132
 
 
133
typedef struct rb_compile_option_struct {
 
134
    int inline_const_cache;
 
135
    int peephole_optimization;
 
136
    int tailcall_optimization;
 
137
    int specialized_instruction;
 
138
    int operands_unification;
 
139
    int instructions_unification;
 
140
    int stack_caching;
 
141
    int trace_instruction;
 
142
} rb_compile_option_t;
 
143
 
 
144
struct iseq_compile_data {
 
145
    /* GC is needed */
 
146
    VALUE err_info;
 
147
    VALUE mark_ary;
 
148
    VALUE catch_table_ary;      /* Array */
 
149
 
 
150
    /* GC is not needed */
 
151
    struct iseq_label_data *start_label;
 
152
    struct iseq_label_data *end_label;
 
153
    struct iseq_label_data *redo_label;
 
154
    VALUE current_block;
 
155
    VALUE loopval_popped;       /* used by NODE_BREAK */
 
156
    VALUE ensure_node;
 
157
    VALUE for_iseq;
 
158
    struct iseq_compile_data_ensure_node_stack *ensure_node_stack;
 
159
    int cached_const;
 
160
    struct iseq_compile_data_storage *storage_head;
 
161
    struct iseq_compile_data_storage *storage_current;
 
162
    int last_line;
 
163
    int flip_cnt;
 
164
    const rb_compile_option_t *option;
 
165
};
 
166
 
 
167
#if 1
 
168
#define GetCoreDataFromValue(obj, type, ptr) do { \
 
169
    ptr = (type*)DATA_PTR(obj); \
 
170
} while (0)
 
171
#else
 
172
#define GetCoreDataFromValue(obj, type, ptr) Data_Get_Struct(obj, type, ptr)
 
173
#endif
 
174
 
 
175
#define GetISeqPtr(obj, ptr) \
 
176
  GetCoreDataFromValue(obj, rb_iseq_t, ptr)
 
177
 
 
178
typedef struct rb_iseq_profile_struct {
 
179
    VALUE count;
 
180
    VALUE time_self;
 
181
    VALUE time_cumu; /* cumulative */
 
182
} rb_iseq_profile_t;
 
183
 
 
184
struct rb_iseq_struct;
 
185
 
 
186
struct rb_iseq_struct {
 
187
    /***************/
 
188
    /* static data */
 
189
    /***************/
 
190
 
 
191
    VALUE type;          /* instruction sequence type */
 
192
    VALUE name;          /* String: iseq name */
 
193
    VALUE filename;      /* file information where this sequence from */
 
194
    VALUE *iseq;         /* iseq (insn number and openrads) */
 
195
    VALUE *iseq_encoded; /* encoded iseq */
 
196
    unsigned long iseq_size;
 
197
    VALUE mark_ary;     /* Array: includes operands which should be GC marked */
 
198
 
 
199
    /* insn info, must be freed */
 
200
    struct iseq_insn_info_entry *insn_info_table;
 
201
    unsigned long insn_info_size;
 
202
 
 
203
    ID *local_table;            /* must free */
 
204
    int local_table_size;
 
205
 
 
206
    /* method, class frame: sizeof(vars) + 1, block frame: sizeof(vars) */
 
207
    int local_size; 
 
208
 
 
209
    /**
 
210
     * argument information
 
211
     *
 
212
     *  def m(a1, a2, ..., aM,                    # mandatory
 
213
     *        b1=(...), b2=(...), ..., bN=(...),  # optinal
 
214
     *        *c,                                 # rest
 
215
     *        d1, d2, ..., dO,                    # post
 
216
     *        &e)                                 # block
 
217
     * =>
 
218
     *
 
219
     *  argc           = M
 
220
     *  arg_rest       = M+N+1 // or -1 if no rest arg
 
221
     *  arg_opts       = N
 
222
     *  arg_opts_tbl   = [ (N entries) ]
 
223
     *  arg_post_len   = O // 0 if no post arguments
 
224
     *  arg_post_start = M+N+2
 
225
     *  arg_block      = M+N + 1 + O + 1 // -1 if no block arg
 
226
     *  arg_simple     = 0 if not simple arguments.
 
227
     *                 = 1 if no opt, rest, post, block.
 
228
     *                 = 2 if ambiguos block parameter ({|a|}).
 
229
     *  arg_size       = argument size.
 
230
     */
 
231
 
 
232
    int argc;
 
233
    int arg_simple;
 
234
    int arg_rest;
 
235
    int arg_block;
 
236
    int arg_opts;
 
237
    int arg_post_len;
 
238
    int arg_post_start;
 
239
    int arg_size;
 
240
    VALUE *arg_opt_table;
 
241
 
 
242
    int stack_max; /* for stack overflow check */
 
243
 
 
244
    /* catch table */
 
245
    struct iseq_catch_table_entry *catch_table;
 
246
    int catch_table_size;
 
247
 
 
248
    /* for child iseq */
 
249
    struct rb_iseq_struct *parent_iseq;
 
250
    struct rb_iseq_struct *local_iseq;
 
251
 
 
252
    /****************/
 
253
    /* dynamic data */
 
254
    /****************/
 
255
 
 
256
    VALUE self;
 
257
 
 
258
    /* block inlining */
 
259
    NODE *node;
 
260
    void *special_block_builder;
 
261
    void *cached_special_block_builder;
 
262
    VALUE cached_special_block;
 
263
 
 
264
    /* klass/module nest information stack (cref) */
 
265
    NODE *cref_stack;
 
266
    VALUE klass;
 
267
 
 
268
    /* misc */
 
269
    ID defined_method_id;       /* for define_method */
 
270
    rb_iseq_profile_t profile;
 
271
 
 
272
    /* used at compile time */
 
273
    struct iseq_compile_data *compile_data;
 
274
};
 
275
 
 
276
typedef struct rb_iseq_struct rb_iseq_t;
 
277
 
 
278
#define RUBY_EVENT_NONE     0x00
 
279
#define RUBY_EVENT_LINE     0x01
 
280
#define RUBY_EVENT_CLASS    0x02
 
281
#define RUBY_EVENT_END      0x04
 
282
#define RUBY_EVENT_CALL     0x08
 
283
#define RUBY_EVENT_RETURN   0x10
 
284
#define RUBY_EVENT_C_CALL   0x20
 
285
#define RUBY_EVENT_C_RETURN 0x40
 
286
#define RUBY_EVENT_RAISE    0x80
 
287
#define RUBY_EVENT_ALL      0xff
 
288
#define RUBY_EVENT_VM      0x100
 
289
#define RUBY_EVENT_SWITCH  0x200
 
290
 
 
291
typedef unsigned int rb_event_flag_t;
 
292
typedef void (*rb_event_hook_func_t)(rb_event_flag_t, VALUE data, VALUE, ID, VALUE klass);
 
293
 
 
294
typedef struct rb_event_hook_struct {
 
295
    rb_event_flag_t flag;
 
296
    rb_event_hook_func_t func;
 
297
    VALUE data;
 
298
    struct rb_event_hook_struct *next;
 
299
} rb_event_hook_t;
 
300
 
 
301
#define GetVMPtr(obj, ptr) \
 
302
  GetCoreDataFromValue(obj, rb_vm_t, ptr)
 
303
 
 
304
typedef struct rb_vm_struct {
 
305
    VALUE self;
 
306
 
 
307
    rb_thread_lock_t global_interpreter_lock;
 
308
 
 
309
    struct rb_thread_struct *main_thread;
 
310
    struct rb_thread_struct *running_thread;
 
311
 
 
312
    st_table *living_threads;
 
313
    VALUE thgroup_default;
 
314
    VALUE last_status; /* $? */
 
315
 
 
316
    int thread_abort_on_exception;
 
317
    unsigned long trace_flag;
 
318
 
 
319
    /* object management */
 
320
    VALUE mark_object_ary;
 
321
 
 
322
    /* load */
 
323
    VALUE top_self;
 
324
    VALUE loaded_features;
 
325
    struct st_table *loading_table;
 
326
    
 
327
    /* signal */
 
328
    rb_atomic_t signal_buff[RUBY_NSIG];
 
329
    rb_atomic_t bufferd_signal_size;
 
330
 
 
331
    /* hook */
 
332
    rb_event_hook_t *event_hooks;
 
333
} rb_vm_t;
 
334
 
 
335
typedef struct {
 
336
    VALUE *pc;                  /* cfp[0] */
 
337
    VALUE *sp;                  /* cfp[1] */
 
338
    VALUE *bp;                  /* cfp[2] */
 
339
    rb_iseq_t *iseq;            /* cfp[3] */
 
340
    VALUE flag;                 /* cfp[4] */
 
341
    VALUE self;                 /* cfp[5] / block[0] */
 
342
    VALUE *lfp;                 /* cfp[6] / block[1] */
 
343
    VALUE *dfp;                 /* cfp[7] / block[2] */
 
344
    rb_iseq_t *block_iseq;      /* cfp[8] / block[3] */
 
345
    VALUE proc;                 /* cfp[9] / block[4] */
 
346
    ID method_id;               /* cfp[10] saved in special case */
 
347
    VALUE method_klass;         /* cfp[11] saved in special case */
 
348
    VALUE prof_time_self;       /* cfp[12] */
 
349
    VALUE prof_time_chld;       /* cfp[13] */
 
350
} rb_control_frame_t;
 
351
 
 
352
typedef struct {
 
353
    VALUE self;                 /* share with method frame if it's only block */
 
354
    VALUE *lfp;                 /* share with method frame if it's only block */
 
355
    VALUE *dfp;                 /* share with method frame if it's only block */
 
356
    rb_iseq_t *iseq;
 
357
    VALUE proc;
 
358
} rb_block_t;
 
359
 
 
360
#define GetThreadPtr(obj, ptr) \
 
361
  GetCoreDataFromValue(obj, rb_thread_t, ptr)
 
362
 
 
363
enum rb_thread_status {
 
364
    THREAD_TO_KILL,
 
365
    THREAD_RUNNABLE,
 
366
    THREAD_STOPPED,
 
367
    THREAD_KILLED,
 
368
};
 
369
 
 
370
typedef jmp_buf rb_jmpbuf_t;
 
371
 
 
372
struct rb_vm_tag {
 
373
    rb_jmpbuf_t buf;
 
374
    VALUE tag;
 
375
    VALUE retval;
 
376
    struct rb_vm_tag *prev;
 
377
};
 
378
 
 
379
struct rb_vm_trap_tag {
 
380
    struct rb_vm_trap_tag *prev;
 
381
};
 
382
 
 
383
#define RUBY_VM_VALUE_CACHE_SIZE 0x1000
 
384
#define USE_VALUE_CACHE 0
 
385
 
 
386
struct rb_thread_struct
 
387
{
 
388
    VALUE self;
 
389
    rb_vm_t *vm;
 
390
 
 
391
    /* execution information */
 
392
    VALUE *stack;               /* must free, must mark */
 
393
    unsigned long stack_size;
 
394
    rb_control_frame_t *cfp;
 
395
    int safe_level;
 
396
    int raised_flag;
 
397
    
 
398
    /* passing state */
 
399
    int state;
 
400
 
 
401
    /* for rb_iterate */
 
402
    rb_block_t *passed_block;
 
403
 
 
404
    /* for load(true) */
 
405
    VALUE top_self;
 
406
    VALUE top_wrapper;
 
407
 
 
408
    /* eval env */
 
409
    rb_block_t *base_block;
 
410
 
 
411
    VALUE *local_lfp;
 
412
    VALUE local_svar;
 
413
 
 
414
    /* thread control */
 
415
    rb_thread_id_t thread_id;
 
416
    enum rb_thread_status status;
 
417
    int priority;
 
418
 
 
419
    native_thread_data_t native_thread_data;
 
420
 
 
421
    VALUE thgroup;
 
422
    VALUE value;
 
423
 
 
424
    VALUE errinfo;
 
425
    VALUE thrown_errinfo;
 
426
    int exec_signal;
 
427
 
 
428
    int interrupt_flag;
 
429
    rb_unblock_function_t *unblock_function;
 
430
    void *unblock_function_arg;
 
431
    rb_thread_lock_t interrupt_lock;
 
432
 
 
433
    struct rb_vm_tag *tag;
 
434
    struct rb_vm_trap_tag *trap_tag;
 
435
 
 
436
    int parse_in_eval;
 
437
 
 
438
    /* storage */
 
439
    st_table *local_storage;
 
440
#if USE_VALUE_CACHE
 
441
    VALUE value_cache[RUBY_VM_VALUE_CACHE_SIZE + 1];
 
442
    VALUE *value_cache_ptr;
 
443
#endif
 
444
 
 
445
    struct rb_thread_struct *join_list_next;
 
446
    struct rb_thread_struct *join_list_head;
 
447
 
 
448
    VALUE first_proc;
 
449
    VALUE first_args;
 
450
    VALUE (*first_func)(ANYARGS);
 
451
 
 
452
    /* for GC */
 
453
    VALUE *machine_stack_start;
 
454
    VALUE *machine_stack_end;
 
455
#ifdef __ia64
 
456
    VALUE *machine_register_stack_start;
 
457
    VALUE *machine_register_stack_end;
 
458
#endif
 
459
    jmp_buf machine_regs;
 
460
    int mark_stack_len;
 
461
 
 
462
    /* statistics data for profiler */
 
463
    VALUE stat_insn_usage;
 
464
 
 
465
    /* tracer */
 
466
    rb_event_hook_t *event_hooks;
 
467
    rb_event_flag_t event_flags;
 
468
    int tracing;
 
469
 
 
470
    /* fiber */
 
471
    VALUE fiber;
 
472
    VALUE root_fiber;
 
473
    rb_jmpbuf_t root_jmpbuf;
 
474
 
 
475
    /* misc */
 
476
    int method_missing_reason;
 
477
    int abort_on_exception;
 
478
};
 
479
 
 
480
/* iseq.c */
 
481
VALUE rb_iseq_new(NODE*, VALUE, VALUE, VALUE, VALUE);
 
482
VALUE rb_iseq_new_with_bopt(NODE*, VALUE, VALUE, VALUE, VALUE, VALUE);
 
483
VALUE rb_iseq_new_with_opt(NODE*, VALUE, VALUE, VALUE, VALUE, const rb_compile_option_t*);
 
484
VALUE rb_iseq_compile(VALUE src, VALUE file, VALUE line);
 
485
VALUE ruby_iseq_disasm(VALUE self);
 
486
VALUE ruby_iseq_disasm_insn(VALUE str, VALUE *iseqval, int pos, rb_iseq_t *iseq, VALUE child);
 
487
const char *ruby_node_name(int node);
 
488
 
 
489
 
 
490
/* each thread has this size stack : 128KB */
 
491
#define RUBY_VM_THREAD_STACK_SIZE (128 * 1024)
 
492
 
 
493
struct global_entry {
 
494
    struct global_variable *var;
 
495
    ID id;
 
496
};
 
497
 
 
498
#define GetProcPtr(obj, ptr) \
 
499
  GetCoreDataFromValue(obj, rb_proc_t, ptr)
 
500
 
 
501
typedef struct {
 
502
    rb_block_t block;
 
503
 
 
504
    VALUE envval;               /* for GC mark */
 
505
    VALUE blockprocval;
 
506
    int safe_level;
 
507
    int is_from_method;
 
508
    int is_lambda;
 
509
 
 
510
    NODE *special_cref_stack;
 
511
} rb_proc_t;
 
512
 
 
513
#define GetEnvPtr(obj, ptr) \
 
514
  GetCoreDataFromValue(obj, rb_env_t, ptr)
 
515
 
 
516
typedef struct {
 
517
    VALUE *env;
 
518
    int env_size;
 
519
    int local_size;
 
520
    VALUE prev_envval;          /* for GC mark */
 
521
    rb_block_t block;
 
522
} rb_env_t;
 
523
 
 
524
#define GetBindingPtr(obj, ptr) \
 
525
  GetCoreDataFromValue(obj, rb_binding_t, ptr)
 
526
 
 
527
typedef struct {
 
528
    VALUE env;
 
529
    NODE *cref_stack;
 
530
} rb_binding_t;
 
531
 
 
532
 
 
533
/* used by compile time and send insn */
 
534
#define VM_CALL_ARGS_SPLAT_BIT     (0x01 << 1)
 
535
#define VM_CALL_ARGS_BLOCKARG_BIT  (0x01 << 2)
 
536
#define VM_CALL_FCALL_BIT          (0x01 << 3)
 
537
#define VM_CALL_VCALL_BIT          (0x01 << 4)
 
538
#define VM_CALL_TAILCALL_BIT       (0x01 << 5)
 
539
#define VM_CALL_TAILRECURSION_BIT  (0x01 << 6)
 
540
#define VM_CALL_SUPER_BIT          (0x01 << 7)
 
541
#define VM_CALL_SEND_BIT           (0x01 << 8)
 
542
 
 
543
/* inline (method|const) cache */
 
544
#define NEW_INLINE_CACHE_ENTRY() NEW_WHILE(Qundef, 0, 0)
 
545
#define ic_klass  u1.value
 
546
#define ic_method u2.node
 
547
#define ic_value  u2.value
 
548
#define ic_vmstat u3.cnt
 
549
typedef NODE *IC;
 
550
 
 
551
void rb_vm_change_state(void);
 
552
 
 
553
typedef VALUE CDHASH;
 
554
 
 
555
#ifndef FUNC_FASTCALL
 
556
#define FUNC_FASTCALL(x) x
 
557
#endif
 
558
 
 
559
typedef rb_control_frame_t *
 
560
  (FUNC_FASTCALL(*rb_insn_func_t))(rb_thread_t *, rb_control_frame_t *);
 
561
 
 
562
#define GC_GUARDED_PTR(p)     ((VALUE)((VALUE)(p) | 0x01))
 
563
#define GC_GUARDED_PTR_REF(p) ((void *)(((VALUE)p) & ~0x03))
 
564
#define GC_GUARDED_PTR_P(p)   (((VALUE)p) & 0x01)
 
565
 
 
566
#define RUBY_VM_METHOD_NODE NODE_METHOD
 
567
 
 
568
#define RUBY_VM_PREVIOUS_CONTROL_FRAME(cfp) (cfp+1)
 
569
#define RUBY_VM_NEXT_CONTROL_FRAME(cfp) (cfp-1)
 
570
#define RUBY_VM_END_CONTROL_FRAME(th) \
 
571
  ((rb_control_frame_t *)((th)->stack + (th)->stack_size))
 
572
#define RUBY_VM_VALID_CONTROL_FRAME_P(cfp, ecfp) \
 
573
  ((void *)(ecfp) > (void *)(cfp))
 
574
#define RUBY_VM_CONTROL_FRAME_STACK_OVERFLOW_P(th, cfp) \
 
575
  (!RUBY_VM_VALID_CONTROL_FRAME_P((cfp), RUBY_VM_END_CONTROL_FRAME(th)))
 
576
 
 
577
#define RUBY_VM_IFUNC_P(ptr)        (BUILTIN_TYPE(ptr) == T_NODE)
 
578
#define RUBY_VM_NORMAL_ISEQ_P(ptr) \
 
579
  (ptr && !RUBY_VM_IFUNC_P(ptr))
 
580
 
 
581
#define RUBY_VM_CLASS_SPECIAL_P(ptr) (((VALUE)(ptr)) & 0x02)
 
582
 
 
583
#define RUBY_VM_GET_BLOCK_PTR_IN_CFP(cfp) ((rb_block_t *)(&(cfp)->self))
 
584
#define RUBY_VM_GET_CFP_FROM_BLOCK_PTR(b) \
 
585
  ((rb_control_frame_t *)((VALUE *)(b) - 5))
 
586
 
 
587
/* defined? */
 
588
#define DEFINED_IVAR   INT2FIX(1)
 
589
#define DEFINED_IVAR2  INT2FIX(2)
 
590
#define DEFINED_GVAR   INT2FIX(3)
 
591
#define DEFINED_CVAR   INT2FIX(4)
 
592
#define DEFINED_CONST  INT2FIX(5)
 
593
#define DEFINED_METHOD INT2FIX(6)
 
594
#define DEFINED_YIELD  INT2FIX(7)
 
595
#define DEFINED_REF    INT2FIX(8)
 
596
#define DEFINED_ZSUPER INT2FIX(9)
 
597
#define DEFINED_FUNC   INT2FIX(10)
 
598
 
 
599
/* VM related object allocate functions */
 
600
/* TODO: should be static functions */
 
601
VALUE rb_thread_alloc(VALUE klass);
 
602
VALUE rb_proc_alloc(VALUE klass);
 
603
 
 
604
/* for debug */
 
605
extern void vm_stack_dump_raw(rb_thread_t *, rb_control_frame_t *);
 
606
#define SDR() vm_stack_dump_raw(GET_THREAD(), GET_THREAD()->cfp)
 
607
#define SDR2(cfp) vm_stack_dump_raw(GET_THREAD(), (cfp))
 
608
void rb_vm_bugreport(void);
 
609
 
 
610
 
 
611
/* functions about thread/vm execution */
 
612
 
 
613
VALUE rb_iseq_eval(VALUE iseqval);
 
614
void rb_enable_interrupt(void);
 
615
void rb_disable_interrupt(void);
 
616
int rb_thread_method_id_and_klass(rb_thread_t *th, ID *idp, VALUE *klassp);
 
617
 
 
618
VALUE vm_eval_body(rb_thread_t *th);
 
619
VALUE vm_invoke_proc(rb_thread_t *th, rb_proc_t *proc, VALUE self, int argc, VALUE *argv);
 
620
VALUE vm_make_proc(rb_thread_t *th, rb_control_frame_t *cfp, rb_block_t *block);
 
621
VALUE vm_make_env_object(rb_thread_t *th, rb_control_frame_t *cfp);
 
622
VALUE vm_backtrace(rb_thread_t *, int);
 
623
 
 
624
VALUE vm_yield(rb_thread_t *th, int argc, VALUE *argv);
 
625
VALUE vm_call0(rb_thread_t *th, VALUE klass, VALUE recv, VALUE id, ID oid,
 
626
               int argc, const VALUE *argv, NODE *body, int nosuper);
 
627
 
 
628
int vm_get_sourceline(rb_control_frame_t *);
 
629
 
 
630
RUBY_EXTERN VALUE sysstack_error;
 
631
 
 
632
/* for thread */
 
633
 
 
634
#if RUBY_VM_THREAD_MODEL == 2
 
635
extern rb_thread_t *ruby_current_thread;
 
636
extern rb_vm_t *ruby_current_vm;
 
637
 
 
638
#define GET_VM() ruby_current_vm
 
639
#define GET_THREAD() ruby_current_thread
 
640
#define rb_thread_set_current_raw(th) (ruby_current_thread = th)
 
641
#define rb_thread_set_current(th) do { \
 
642
    rb_thread_set_current_raw(th); \
 
643
    th->vm->running_thread = th; \
 
644
} while (0)
 
645
 
 
646
#else
 
647
#error "unsupported thread model"
 
648
#endif
 
649
 
 
650
void rb_thread_execute_interrupts(rb_thread_t *);
 
651
 
 
652
#define RUBY_VM_CHECK_INTS_TH(th) do { \
 
653
  if(th->interrupt_flag){ \
 
654
    /* TODO: trap something event */ \
 
655
    rb_thread_execute_interrupts(th); \
 
656
  } \
 
657
} while (0)
 
658
 
 
659
#define RUBY_VM_CHECK_INTS() \
 
660
  RUBY_VM_CHECK_INTS_TH(GET_THREAD())
 
661
 
 
662
/* tracer */
 
663
static void inline
 
664
exec_event_hooks(rb_event_hook_t *hook, rb_event_flag_t flag, VALUE self, ID id, VALUE klass)
 
665
{
 
666
    while (hook) {
 
667
        if (flag & hook->flag) {
 
668
            (*hook->func)(flag, hook->data, self, id, klass);
 
669
        }
 
670
        hook = hook->next;
 
671
    }
 
672
}
 
673
 
 
674
#define EXEC_EVENT_HOOK(th, flag, self, id, klass) do { \
 
675
    rb_event_flag_t wait_event__ = th->event_flags; \
 
676
    if (UNLIKELY(wait_event__)) { \
 
677
        if (wait_event__ & (flag | RUBY_EVENT_VM)) { \
 
678
            VALUE self__ = (self), klass__ = (klass); \
 
679
            ID id__ = (id); \
 
680
            if (wait_event__ & flag) { \
 
681
                exec_event_hooks(th->event_hooks, flag, self__, id__, klass__); \
 
682
            } \
 
683
            if (wait_event__ & RUBY_EVENT_VM) { \
 
684
                exec_event_hooks(th->vm->event_hooks, flag, self__, id__, klass__); \
 
685
            } \
 
686
        } \
 
687
    } \
 
688
} while (0)
 
689
 
 
690
#endif /* RUBY_CORE_H */