Class: WEEL::ConnectionWrapperBase
- Inherits:
-
Object
- Object
- WEEL::ConnectionWrapperBase
- Defined in:
- lib/weel.rb
Overview
}}}
Class Method Summary collapse
- .inform_connectionwrapper_error(arguments, err) ⇒ Object
- .inform_position_change(arguments, ipc = {}) ⇒ Object
- .inform_state_change(arguments, newstate) ⇒ Object
- .inform_syntax_error(arguments, err, code) ⇒ Object
-
.loop_guard(arguments, lid, count) ⇒ Object
{{{.
Instance Method Summary collapse
- #activity_handle(passthrough, parameters) ⇒ Object
- #activity_manipulate_handle(parameters) ⇒ Object
- #activity_passthrough_value ⇒ Object
- #activity_result_options ⇒ Object
- #activity_result_value ⇒ Object
- #activity_stop ⇒ Object
- #activity_uuid ⇒ Object
- #additional ⇒ Object
- #callback(result = nil, options = {}) ⇒ Object
- #inform_activity_cancelled ⇒ Object
- #inform_activity_done ⇒ Object
- #inform_activity_failed(err) ⇒ Object
- #inform_activity_manipulate ⇒ Object
- #inform_manipulate_change(status, changed_data, changed_endpoints, data, endpoints) ⇒ Object
-
#initialize(arguments, position = nil, continue = nil) ⇒ ConnectionWrapperBase
constructor
A new instance of ConnectionWrapperBase.
- #join_branches(id, branches = []) ⇒ Object
- #manipulate(readonly, lock, dataelements, endpoints, status, local, additional, code, where, result = nil, options = nil) ⇒ Object
- #mem_guard ⇒ Object
- #prepare(lock, dataelements, endpoints, status, local, additional, code, exec_endpoints, exec_parameters) ⇒ Object
- #split_branches(id, branches = []) ⇒ Object
- #test_condition(dataelements, endpoints, local, additional, code, args = {}) ⇒ Object
- #vote_sync_after ⇒ Object
- #vote_sync_before(parameters = nil) ⇒ Object
Constructor Details
#initialize(arguments, position = nil, continue = nil) ⇒ ConnectionWrapperBase
Returns a new instance of ConnectionWrapperBase.
344 |
# File 'lib/weel.rb', line 344 def initialize(arguments,position=nil,continue=nil); end |
Class Method Details
.inform_connectionwrapper_error(arguments, err) ⇒ Object
341 |
# File 'lib/weel.rb', line 341 def self::inform_connectionwrapper_error(arguments,err); end |
.inform_position_change(arguments, ipc = {}) ⇒ Object
342 |
# File 'lib/weel.rb', line 342 def self::inform_position_change(arguments,ipc={}); end |
.inform_state_change(arguments, newstate) ⇒ Object
339 |
# File 'lib/weel.rb', line 339 def self::inform_state_change(arguments,newstate); end |
.inform_syntax_error(arguments, err, code) ⇒ Object
340 |
# File 'lib/weel.rb', line 340 def self::inform_syntax_error(arguments,err,code); end |
.loop_guard(arguments, lid, count) ⇒ Object
{{{
338 |
# File 'lib/weel.rb', line 338 def self::loop_guard(arguments,lid,count); false; end |
Instance Method Details
#activity_handle(passthrough, parameters) ⇒ Object
348 |
# File 'lib/weel.rb', line 348 def activity_handle(passthrough, parameters); end |
#activity_manipulate_handle(parameters) ⇒ Object
349 |
# File 'lib/weel.rb', line 349 def activity_manipulate_handle(parameters); end |
#activity_passthrough_value ⇒ Object
355 |
# File 'lib/weel.rb', line 355 def activity_passthrough_value; end |
#activity_result_options ⇒ Object
352 |
# File 'lib/weel.rb', line 352 def ; end |
#activity_result_value ⇒ Object
351 |
# File 'lib/weel.rb', line 351 def activity_result_value; end |
#activity_stop ⇒ Object
354 |
# File 'lib/weel.rb', line 354 def activity_stop; end |
#activity_uuid ⇒ Object
356 |
# File 'lib/weel.rb', line 356 def activity_uuid; '42424242-cpee-cpee-cpee-424242424242'; end |
#additional ⇒ Object
346 |
# File 'lib/weel.rb', line 346 def additional; {}; end |
#callback(result = nil, options = {}) ⇒ Object
367 |
# File 'lib/weel.rb', line 367 def callback(result=nil,={}); end |
#inform_activity_cancelled ⇒ Object
359 |
# File 'lib/weel.rb', line 359 def inform_activity_cancelled; end |
#inform_activity_done ⇒ Object
358 |
# File 'lib/weel.rb', line 358 def inform_activity_done; end |
#inform_activity_failed(err) ⇒ Object
361 |
# File 'lib/weel.rb', line 361 def inform_activity_failed(err); end |
#inform_activity_manipulate ⇒ Object
360 |
# File 'lib/weel.rb', line 360 def inform_activity_manipulate; end |
#inform_manipulate_change(status, changed_data, changed_endpoints, data, endpoints) ⇒ Object
362 |
# File 'lib/weel.rb', line 362 def inform_manipulate_change(status,changed_data,changed_endpoints,data,endpoints); end |
#join_branches(id, branches = []) ⇒ Object
382 |
# File 'lib/weel.rb', line 382 def join_branches(id,branches=[]); end |
#manipulate(readonly, lock, dataelements, endpoints, status, local, additional, code, where, result = nil, options = nil) ⇒ Object
372 373 374 375 376 377 378 379 380 |
# File 'lib/weel.rb', line 372 def manipulate(readonly,lock,dataelements,endpoints,status,local,additional,code,where,result=nil,=nil) lock.synchronize do if readonly ReadStructure.new(dataelements,endpoints,local,additional).instance_eval(code,where,1) else ManipulateStructure.new(dataelements,endpoints,local,additional).instance_eval(code,where,1) end end end |
#mem_guard ⇒ Object
368 |
# File 'lib/weel.rb', line 368 def mem_guard; end |
#prepare(lock, dataelements, endpoints, status, local, additional, code, exec_endpoints, exec_parameters) ⇒ Object
370 |
# File 'lib/weel.rb', line 370 def prepare(lock,dataelements,endpoints,status,local,additional,code,exec_endpoints,exec_parameters); end |
#split_branches(id, branches = []) ⇒ Object
383 |
# File 'lib/weel.rb', line 383 def split_branches(id,branches=[]); end |
#test_condition(dataelements, endpoints, local, additional, code, args = {}) ⇒ Object
371 |
# File 'lib/weel.rb', line 371 def test_condition(dataelements,endpoints,local,additional,code,args={}); ReadStructure.new(dataelements,endpoints,local,additional).instance_eval(code); end |
#vote_sync_after ⇒ Object
365 |
# File 'lib/weel.rb', line 365 def vote_sync_after; true; end |
#vote_sync_before(parameters = nil) ⇒ Object
364 |
# File 'lib/weel.rb', line 364 def vote_sync_before(parameters=nil); true; end |