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, data) ⇒ Object
- .inform_syntax_error(arguments, err, code) ⇒ Object
-
.loop_guard(arguments, lid, count) ⇒ Object
{{{.
Instance Method Summary collapse
- #activity_handle(passthrough, parameters, dataelements) ⇒ Object
- #activity_manipulate_handle(parameters) ⇒ Object
- #activity_passthrough_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(eid, 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(eid, branches = []) ⇒ Object
- #test_condition(eid, 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.
333 |
# File 'lib/weel.rb', line 333 def initialize(arguments,position=nil,continue=nil); end |
Class Method Details
.inform_connectionwrapper_error(arguments, err) ⇒ Object
330 |
# File 'lib/weel.rb', line 330 def self::inform_connectionwrapper_error(arguments,err); end |
.inform_position_change(arguments, ipc = {}) ⇒ Object
331 |
# File 'lib/weel.rb', line 331 def self::inform_position_change(arguments,ipc={}); end |
.inform_state_change(arguments, newstate, data) ⇒ Object
328 |
# File 'lib/weel.rb', line 328 def self::inform_state_change(arguments,newstate,data); end |
.inform_syntax_error(arguments, err, code) ⇒ Object
329 |
# File 'lib/weel.rb', line 329 def self::inform_syntax_error(arguments,err,code); end |
.loop_guard(arguments, lid, count) ⇒ Object
{{{
327 |
# File 'lib/weel.rb', line 327 def self::loop_guard(arguments,lid,count); false; end |
Instance Method Details
#activity_handle(passthrough, parameters, dataelements) ⇒ Object
337 |
# File 'lib/weel.rb', line 337 def activity_handle(passthrough, parameters, dataelements); end |
#activity_manipulate_handle(parameters) ⇒ Object
338 |
# File 'lib/weel.rb', line 338 def activity_manipulate_handle(parameters); end |
#activity_passthrough_value ⇒ Object
341 |
# File 'lib/weel.rb', line 341 def activity_passthrough_value; end |
#activity_stop ⇒ Object
340 |
# File 'lib/weel.rb', line 340 def activity_stop; end |
#activity_uuid ⇒ Object
342 |
# File 'lib/weel.rb', line 342 def activity_uuid; '42424242-cpee-cpee-cpee-424242424242'; end |
#additional ⇒ Object
335 |
# File 'lib/weel.rb', line 335 def additional; {}; end |
#callback(result = nil, options = {}) ⇒ Object
353 |
# File 'lib/weel.rb', line 353 def callback(result=nil,={}); end |
#inform_activity_cancelled ⇒ Object
345 |
# File 'lib/weel.rb', line 345 def inform_activity_cancelled; end |
#inform_activity_done ⇒ Object
344 |
# File 'lib/weel.rb', line 344 def inform_activity_done; end |
#inform_activity_failed(err) ⇒ Object
347 |
# File 'lib/weel.rb', line 347 def inform_activity_failed(err); end |
#inform_activity_manipulate ⇒ Object
346 |
# File 'lib/weel.rb', line 346 def inform_activity_manipulate; end |
#inform_manipulate_change(status, changed_data, changed_endpoints, data, endpoints) ⇒ Object
348 |
# File 'lib/weel.rb', line 348 def inform_manipulate_change(status,changed_data,changed_endpoints,data,endpoints); end |
#join_branches(eid, branches = []) ⇒ Object
368 |
# File 'lib/weel.rb', line 368 def join_branches(eid,branches=[]); end |
#manipulate(readonly, lock, dataelements, endpoints, status, local, additional, code, where, result = nil, options = nil) ⇒ Object
358 359 360 361 362 363 364 365 366 |
# File 'lib/weel.rb', line 358 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
354 |
# File 'lib/weel.rb', line 354 def mem_guard; end |
#prepare(lock, dataelements, endpoints, status, local, additional, code, exec_endpoints, exec_parameters) ⇒ Object
356 |
# File 'lib/weel.rb', line 356 def prepare(lock,dataelements,endpoints,status,local,additional,code,exec_endpoints,exec_parameters); end |
#split_branches(eid, branches = []) ⇒ Object
369 |
# File 'lib/weel.rb', line 369 def split_branches(eid,branches=[]); end |
#test_condition(eid, dataelements, endpoints, local, additional, code, args = {}) ⇒ Object
357 |
# File 'lib/weel.rb', line 357 def test_condition(eid,dataelements,endpoints,local,additional,code,args={}); ReadStructure.new(dataelements,endpoints,local,additional).instance_eval(code); end |
#vote_sync_after ⇒ Object
351 |
# File 'lib/weel.rb', line 351 def vote_sync_after; true; end |
#vote_sync_before(parameters = nil) ⇒ Object
350 |
# File 'lib/weel.rb', line 350 def vote_sync_before(parameters=nil); true; end |