* eval_jump.c (rb_exec_end_proc): reduce number of pushing/popping
  and reuse same tag.

git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@43730 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
nobu 2013-11-19 17:01:10 +00:00
Родитель 1eac0b55c9
Коммит 9d740ddebe
2 изменённых файлов: 34 добавлений и 38 удалений

Просмотреть файл

@ -104,6 +104,12 @@ extern int select_large_fdset(int, fd_set *, fd_set *, fd_set *, struct timeval
#define TH_POP_TAG2() \ #define TH_POP_TAG2() \
_th->tag = _tag.prev _th->tag = _tag.prev
#define TH_PUSH_TAG2() (_th->tag = &_tag, 0)
#define TH_TMPPOP_TAG() TH_POP_TAG2()
#define TH_REPUSH_TAG() TH_PUSH_TAG2()
#define PUSH_TAG() TH_PUSH_TAG(GET_THREAD()) #define PUSH_TAG() TH_PUSH_TAG(GET_THREAD())
#define POP_TAG() TH_POP_TAG() #define POP_TAG() TH_POP_TAG()
@ -128,7 +134,7 @@ rb_threadptr_tag_jump(rb_thread_t *th, int st)
[ISO/IEC 9899:1999] 7.13.1.1 [ISO/IEC 9899:1999] 7.13.1.1
*/ */
#define TH_EXEC_TAG() \ #define TH_EXEC_TAG() \
(ruby_setjmp(_tag.buf) ? rb_threadptr_tag_state(_th) : (_th->tag = &_tag, 0)) (ruby_setjmp(_tag.buf) ? rb_threadptr_tag_state(_th) : TH_PUSH_TAG2())
#define EXEC_TAG() \ #define EXEC_TAG() \
TH_EXEC_TAG() TH_EXEC_TAG()

Просмотреть файл

@ -93,53 +93,43 @@ rb_mark_end_proc(void)
} }
} }
static void
exec_end_procs_chain(struct end_proc_data *volatile *procs)
{
struct end_proc_data volatile endproc;
struct end_proc_data *link;
while ((link = *procs) != 0) {
*procs = link->next;
endproc = *link;
xfree(link);
rb_set_safe_level_force(endproc.safe);
(*endproc.func) (endproc.data);
}
}
void void
rb_exec_end_proc(void) rb_exec_end_proc(void)
{ {
struct end_proc_data volatile endproc;
struct end_proc_data volatile *link;
int status; int status;
volatile int safe = rb_safe_level(); volatile int safe = rb_safe_level();
rb_thread_t *th = GET_THREAD(); rb_thread_t *th = GET_THREAD();
volatile VALUE errinfo = th->errinfo; volatile VALUE errinfo = th->errinfo;
while (ephemeral_end_procs) { PUSH_TAG();
link = ephemeral_end_procs; if ((status = EXEC_TAG()) == 0) {
ephemeral_end_procs = link->next; again:
endproc = *link; exec_end_procs_chain(&ephemeral_end_procs);
xfree((void *)link); exec_end_procs_chain(&end_procs);
link = &endproc;
PUSH_TAG();
if ((status = EXEC_TAG()) == 0) {
rb_set_safe_level_force(link->safe);
(*link->func) (link->data);
}
POP_TAG();
if (status) {
error_handle(status);
if (!NIL_P(th->errinfo)) errinfo = th->errinfo;
}
} }
else {
while (end_procs) { TH_TMPPOP_TAG();
link = end_procs; error_handle(status);
end_procs = link->next; if (!NIL_P(th->errinfo)) errinfo = th->errinfo;
endproc = *link; TH_REPUSH_TAG();
xfree((void *)link); goto again;
link = &endproc;
PUSH_TAG();
if ((status = EXEC_TAG()) == 0) {
rb_set_safe_level_force(link->safe);
(*link->func) (link->data);
}
POP_TAG();
if (status) {
error_handle(status);
if (!NIL_P(th->errinfo)) errinfo = th->errinfo;
}
} }
POP_TAG();
rb_set_safe_level_force(safe); rb_set_safe_level_force(safe);
th->errinfo = errinfo; th->errinfo = errinfo;