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_no_longer_necessary ⇒ 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_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(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(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.
308 |
# File 'lib/weel.rb', line 308 def initialize(arguments,position=nil,continue=nil); end |
Class Method Details
.inform_connectionwrapper_error(arguments, err) ⇒ Object
305 |
# File 'lib/weel.rb', line 305 def self::inform_connectionwrapper_error(arguments,err); end |
.inform_position_change(arguments, ipc = {}) ⇒ Object
306 |
# File 'lib/weel.rb', line 306 def self::inform_position_change(arguments,ipc={}); end |
.inform_state_change(arguments, newstate) ⇒ Object
303 |
# File 'lib/weel.rb', line 303 def self::inform_state_change(arguments,newstate); end |
.inform_syntax_error(arguments, err, code) ⇒ Object
304 |
# File 'lib/weel.rb', line 304 def self::inform_syntax_error(arguments,err,code); end |
.loop_guard(arguments, lid, count) ⇒ Object
{{{
302 |
# File 'lib/weel.rb', line 302 def self::loop_guard(arguments,lid,count); false; end |
Instance Method Details
#activity_handle(passthrough, parameters) ⇒ Object
312 |
# File 'lib/weel.rb', line 312 def activity_handle(passthrough, parameters); end |
#activity_manipulate_handle(parameters) ⇒ Object
313 |
# File 'lib/weel.rb', line 313 def activity_manipulate_handle(parameters); end |
#activity_no_longer_necessary ⇒ Object
322 |
# File 'lib/weel.rb', line 322 def activity_no_longer_necessary; end |
#activity_passthrough_value ⇒ Object
319 |
# File 'lib/weel.rb', line 319 def activity_passthrough_value; end |
#activity_result_options ⇒ Object
316 |
# File 'lib/weel.rb', line 316 def ; end |
#activity_result_value ⇒ Object
315 |
# File 'lib/weel.rb', line 315 def activity_result_value; end |
#activity_stop ⇒ Object
318 |
# File 'lib/weel.rb', line 318 def activity_stop; end |
#activity_uuid ⇒ Object
320 |
# File 'lib/weel.rb', line 320 def activity_uuid; '42424242-cpee-cpee-cpee-424242424242'; end |
#additional ⇒ Object
310 |
# File 'lib/weel.rb', line 310 def additional; {}; end |
#callback(result = nil, options = {}) ⇒ Object
332 |
# File 'lib/weel.rb', line 332 def callback(result=nil,={}); end |
#inform_activity_done ⇒ Object
324 |
# File 'lib/weel.rb', line 324 def inform_activity_done; end |
#inform_activity_failed(err) ⇒ Object
326 |
# File 'lib/weel.rb', line 326 def inform_activity_failed(err); end |
#inform_activity_manipulate ⇒ Object
325 |
# File 'lib/weel.rb', line 325 def inform_activity_manipulate; end |
#inform_manipulate_change(status, changed_data, changed_endpoints, data, endpoints) ⇒ Object
327 |
# File 'lib/weel.rb', line 327 def inform_manipulate_change(status,changed_data,changed_endpoints,data,endpoints); end |
#join_branches(branches) ⇒ Object
347 |
# File 'lib/weel.rb', line 347 def join_branches(branches); end |
#manipulate(readonly, lock, dataelements, endpoints, status, local, additional, code, where, result = nil, options = nil) ⇒ Object
337 338 339 340 341 342 343 344 345 |
# File 'lib/weel.rb', line 337 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
333 |
# File 'lib/weel.rb', line 333 def mem_guard; end |
#prepare(lock, dataelements, endpoints, status, local, additional, code, exec_endpoints, exec_parameters) ⇒ Object
335 |
# File 'lib/weel.rb', line 335 def prepare(lock,dataelements,endpoints,status,local,additional,code,exec_endpoints,exec_parameters); end |
#split_branches(branches) ⇒ Object
348 |
# File 'lib/weel.rb', line 348 def split_branches(branches); end |
#test_condition(dataelements, endpoints, local, additional, code, args = {}) ⇒ Object
336 |
# File 'lib/weel.rb', line 336 def test_condition(dataelements,endpoints,local,additional,code,args={}); ReadStructure.new(dataelements,endpoints,local,additional).instance_eval(code); end |
#vote_sync_after ⇒ Object
330 |
# File 'lib/weel.rb', line 330 def vote_sync_after; true; end |
#vote_sync_before(parameters = nil) ⇒ Object
329 |
# File 'lib/weel.rb', line 329 def vote_sync_before(parameters=nil); true; end |