mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
tcltklib.c : bug fix
multi-tk.rb : bug fix and pack options are pssed to the safeTk container sample/safe-tk.rb : add example for pack options of safeTk container git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@4200 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
parent
0a75581a37
commit
df33012935
3 changed files with 89 additions and 36 deletions
|
@ -73,8 +73,8 @@ Tcl_Interp *current_interp;
|
|||
#define DEFAULT_NO_EVENT_TICK 10/*counts*/
|
||||
#define DEFAULT_NO_EVENT_WAIT 20/*milliseconds ( 1 -- 999 ) */
|
||||
#define WATCHDOG_INTERVAL 10/*milliseconds ( 1 -- 999 ) */
|
||||
#define DEFAULT_TIMER_TICK 0/*milliseconds*/
|
||||
#define NO_THREAD_INTERRUPT_TIME 200/*milliseconds*/
|
||||
#define DEFAULT_TIMER_TICK 0/*milliseconds ( 0 -- 999 ) */
|
||||
#define NO_THREAD_INTERRUPT_TIME 200/*milliseconds ( 1 -- 999 ) */
|
||||
|
||||
static int event_loop_max = DEFAULT_EVENT_LOOP_MAX;
|
||||
static int no_event_tick = DEFAULT_NO_EVENT_TICK;
|
||||
|
@ -83,6 +83,7 @@ static int timer_tick = DEFAULT_TIMER_TICK;
|
|||
static int req_timer_tick = DEFAULT_TIMER_TICK;
|
||||
static int run_timer_flag = 0;
|
||||
|
||||
static int event_loop_wait_event = 0;
|
||||
static int event_loop_abort_no_cmd = 0;
|
||||
static int loop_counter = 0;
|
||||
|
||||
|
@ -101,8 +102,8 @@ static void
|
|||
_timer_for_tcl(clientData)
|
||||
ClientData clientData;
|
||||
{
|
||||
struct invoke_queue *q, *tmp;
|
||||
VALUE thread;
|
||||
/* struct invoke_queue *q, *tmp; */
|
||||
/* VALUE thread; */
|
||||
|
||||
DUMP1("called timer_for_tcl");
|
||||
Tk_DeleteTimerHandler(timer_token);
|
||||
|
@ -216,8 +217,8 @@ rb_evloop_abort_no_cmd_set(self, val)
|
|||
VALUE self, val;
|
||||
{
|
||||
rb_secure(4);
|
||||
event_loop_abort_no_cmd = (val == Qtrue)? 1: 0;
|
||||
return rb_evloop_abort_no_cmd();
|
||||
event_loop_abort_no_cmd = (RTEST(val))? 1: 0;
|
||||
return rb_evloop_abort_no_cmd(self);
|
||||
}
|
||||
|
||||
VALUE
|
||||
|
@ -244,6 +245,8 @@ lib_mainloop_core(check_root_widget)
|
|||
for(;;) {
|
||||
if (rb_thread_alone()) {
|
||||
DUMP1("no other thread");
|
||||
event_loop_wait_event = 0;
|
||||
|
||||
if (timer_tick == 0) {
|
||||
timer_tick = NO_THREAD_INTERRUPT_TIME;
|
||||
timer_token = Tk_CreateTimerHandler(timer_tick,
|
||||
|
@ -268,6 +271,8 @@ lib_mainloop_core(check_root_widget)
|
|||
|
||||
} else {
|
||||
DUMP1("there are other threads");
|
||||
event_loop_wait_event = 1;
|
||||
|
||||
timer_tick = req_timer_tick;
|
||||
tick_counter = 0;
|
||||
while(tick_counter < event_loop_max) {
|
||||
|
@ -366,15 +371,15 @@ VALUE
|
|||
lib_watchdog_core(check_rootwidget)
|
||||
VALUE check_rootwidget;
|
||||
{
|
||||
VALUE current = eventloop_thread;
|
||||
VALUE evloop;
|
||||
int check = (check_rootwidget == Qtrue);
|
||||
int prev_val = -1;
|
||||
struct timeval t;
|
||||
VALUE ret;
|
||||
int chance = 0;
|
||||
struct timeval t0, t1;
|
||||
|
||||
t.tv_sec = (time_t)0;
|
||||
t.tv_usec = (time_t)((WATCHDOG_INTERVAL)*1000.0);
|
||||
t0.tv_sec = (time_t)0;
|
||||
t0.tv_usec = (time_t)((NO_THREAD_INTERRUPT_TIME)*1000.0);
|
||||
t1.tv_sec = (time_t)0;
|
||||
t1.tv_usec = (time_t)((WATCHDOG_INTERVAL)*1000.0);
|
||||
|
||||
/* check other watchdog thread */
|
||||
if (watchdog_thread != 0) {
|
||||
|
@ -389,18 +394,29 @@ lib_watchdog_core(check_rootwidget)
|
|||
/* watchdog start */
|
||||
do {
|
||||
if (eventloop_thread == 0 || loop_counter == prev_val) {
|
||||
/* start new eventloop thread */
|
||||
DUMP2("eventloop thread %lx is sleeping or dead",
|
||||
eventloop_thread);
|
||||
evloop = rb_thread_create(lib_mainloop_launcher,
|
||||
(void*)&check_rootwidget);
|
||||
DUMP2("create new eventloop thread %lx", evloop);
|
||||
rb_thread_run(evloop);
|
||||
if (rb_funcall(eventloop_thread, rb_intern("stop?"), 0) == Qtrue
|
||||
&& ++chance >= 3) {
|
||||
/* start new eventloop thread */
|
||||
DUMP2("eventloop thread %lx is sleeping or dead",
|
||||
eventloop_thread);
|
||||
evloop = rb_thread_create(lib_mainloop_launcher,
|
||||
(void*)&check_rootwidget);
|
||||
DUMP2("create new eventloop thread %lx", evloop);
|
||||
loop_counter = -1;
|
||||
chance = 0;
|
||||
rb_thread_run(evloop);
|
||||
}
|
||||
} else {
|
||||
rb_thread_wait_for(t);
|
||||
loop_counter = prev_val;
|
||||
chance = 0;
|
||||
if (event_loop_wait_event) {
|
||||
rb_thread_wait_for(t0);
|
||||
} else {
|
||||
rb_thread_wait_for(t1);
|
||||
}
|
||||
/* rb_thread_schedule(); */
|
||||
}
|
||||
} while(!check || Tk_GetNumMainWindows() != 0);
|
||||
} while(!(check_rootwidget == Qtrue) || Tk_GetNumMainWindows() != 0);
|
||||
|
||||
return Qnil;
|
||||
}
|
||||
|
@ -439,7 +455,7 @@ lib_do_one_event(argc, argv, self)
|
|||
VALUE *argv;
|
||||
VALUE self;
|
||||
{
|
||||
VALUE obj, vflags;
|
||||
VALUE vflags;
|
||||
int flags;
|
||||
int ret;
|
||||
|
||||
|
@ -619,7 +635,7 @@ ip_init(argc, argv, self)
|
|||
VALUE self;
|
||||
{
|
||||
struct tcltkip *ptr; /* tcltkip data struct */
|
||||
VALUE argv0, opts, opt_n;
|
||||
VALUE argv0, opts;
|
||||
int cnt;
|
||||
|
||||
/* create object */
|
||||
|
@ -960,7 +976,26 @@ ip_invoke_real(argc, argv, obj)
|
|||
#endif
|
||||
{
|
||||
TRAP_BEG;
|
||||
#if TCL_MAJOR_VERSION >= 8
|
||||
# ifdef CONST84 /* Tcl8.4.x -- ?.?.? (current latest version is 8.4.4) */
|
||||
ptr->return_value = (*info.proc)(info.clientData, ptr->ip,
|
||||
argc, (CONST84 char **)av);
|
||||
# else
|
||||
# if TCL_MAJOR_VERSION == 8 && TCL_MINOR_VERSION <= 4 /* Tcl8.0.x -- 8.4b1 */
|
||||
ptr->return_value = (*info.proc)(info.clientData, ptr->ip, argc, av);
|
||||
|
||||
# else /* unknown (maybe TCL_VERSION >= 8.5) */
|
||||
# ifdef CONST
|
||||
ptr->return_value = (*info.proc)(info.clientData, ptr->ip,
|
||||
argc, (CONST char **)av);
|
||||
# else
|
||||
ptr->return_value = (*info.proc)(info.clientData, ptr->ip, argc, av);
|
||||
# endif
|
||||
# endif
|
||||
# endif
|
||||
#else /* TCL_MAJOR_VERSION < 8 */
|
||||
ptr->return_value = (*info.proc)(info.clientData, ptr->ip, argc, av);
|
||||
#endif
|
||||
TRAP_END;
|
||||
}
|
||||
|
||||
|
@ -992,7 +1027,7 @@ invoke_queue_handler(evPtr, flags)
|
|||
Tcl_Event *evPtr;
|
||||
int flags;
|
||||
{
|
||||
struct invoke_queue *tmp, *q = (struct invoke_queue *)evPtr;
|
||||
struct invoke_queue *q = (struct invoke_queue *)evPtr;
|
||||
|
||||
DUMP1("do_invoke_queue_handler");
|
||||
DUMP2("invoke queue_thread : %lx", rb_thread_current());
|
||||
|
|
|
@ -259,7 +259,7 @@ class MultiTkIp
|
|||
def __check_safetk_optkeys(optkeys)
|
||||
# based on 'safetk.tcl'
|
||||
new_keys = {}
|
||||
optkeys.each{|k,v| new_key[k.to_s] = v}
|
||||
optkeys.each{|k,v| new_keys[k.to_s] = v}
|
||||
|
||||
# check 'display'
|
||||
if !new_keys.key?('display')
|
||||
|
@ -312,12 +312,24 @@ class MultiTkIp
|
|||
private :__check_safetk_optkeys
|
||||
|
||||
def __create_safetk_frame(slave_ip, slave_name, app_name, keys)
|
||||
# create toplevel widget
|
||||
# display option is used by ::safe::loadTk
|
||||
loadTk_keys = {}
|
||||
loadTk_keys['display'] = keys['display']
|
||||
dup_keys = keys.dup
|
||||
dup_keys['screen'] = dup_keys.delete('display')
|
||||
dup_keys['classname'] = 'SafeTk'
|
||||
|
||||
# keys for toplevel : allow followings
|
||||
toplevel_keys = {}
|
||||
['height', 'width', 'background', 'menu'].each{|k|
|
||||
toplevel_keys[k] = dup_keys.delete(k) if dup_keys.key?(k)
|
||||
}
|
||||
toplevel_keys['classname'] = 'SafeTk'
|
||||
toplevel_keys['screen'] = dup_keys.delete('display')
|
||||
|
||||
# other keys used by pack option of container frame
|
||||
|
||||
# create toplevel widget
|
||||
begin
|
||||
top = TkToplevel.new(dup_keys)
|
||||
top = TkToplevel.new(toplevel_keys)
|
||||
rescue NameError
|
||||
fail unless @interp.safe?
|
||||
fail SecurityError, "unable create toplevel on the safe interpreter"
|
||||
|
@ -360,10 +372,13 @@ class MultiTkIp
|
|||
}
|
||||
|
||||
# container frame for slave interpreter
|
||||
c = TkFrame.new(top, :container=>true).pack(:fill=>:both, :expand=>true)
|
||||
dup_keys['fill'] = :both unless dup_keys.key?('fill')
|
||||
dup_keys['expand'] = true unless dup_keys.key?('expand')
|
||||
c = TkFrame.new(top, :container=>true).pack(dup_keys)
|
||||
|
||||
# return container's window id
|
||||
TkWinfo.id(c)
|
||||
# return keys
|
||||
loadTk_keys['use'] = TkWinfo.id(c)
|
||||
loadTk_keys
|
||||
end
|
||||
private :__create_safetk_frame
|
||||
|
||||
|
@ -375,8 +390,7 @@ class MultiTkIp
|
|||
@interp._eval("::safe::interpInit #{ip_name} "+_keys2opts(safe_opts))
|
||||
tk_opts = __check_safetk_optkeys(tk_opts)
|
||||
unless tk_opts.key?('use')
|
||||
tk_opts['use'] = __create_safetk_frame(slave_ip, ip_name,
|
||||
app_name, tk_opts)
|
||||
tk_opts = __create_safetk_frame(slave_ip, ip_name, app_name, tk_opts)
|
||||
end
|
||||
slave_ip._invoke('set', 'argv0', app_name) if app_name.kind_of?(String)
|
||||
@interp._eval("::safe::loadTk #{ip_name} #{_keys2opts(tk_opts)}")
|
||||
|
|
|
@ -5,7 +5,10 @@ require "multi-tk"
|
|||
|
||||
# create slave interpreters
|
||||
trusted_slave = MultiTkIp.new_slave
|
||||
safe_slave = MultiTkIp.new_safeTk
|
||||
safe_slave1 = MultiTkIp.new_safeTk
|
||||
safe_slave2 = MultiTkIp.new_safeTk('fill'=>:none, 'expand'=>false)
|
||||
#safe_slave2 = MultiTkIp.new_safeTk('fill'=>:none)
|
||||
#safe_slave2 = MultiTkIp.new_safeTk('expand'=>false)
|
||||
|
||||
|
||||
cmd = Proc.new{|txt|
|
||||
|
@ -42,7 +45,8 @@ cmd = Proc.new{|txt|
|
|||
|
||||
# call on the default master interpreter
|
||||
trusted_slave.eval_proc(cmd, 'trusted')
|
||||
safe_slave.eval_proc(cmd, 'safe')
|
||||
safe_slave1.eval_proc(cmd, 'safe1')
|
||||
safe_slave2.eval_proc(cmd, 'safe2')
|
||||
cmd.call('master')
|
||||
|
||||
Tk.mainloop
|
||||
|
|
Loading…
Reference in a new issue