jackhong

def test
  puts 'Hello World'
  second version
end

jackhong

def blah
 puts helfefe
sadfsdfdsfsdf
end

jackhong

using System;
using System.Diagnostics;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO;

namespace TestGS
{
    class Program

jackhong

OMF 6 developer preview release email

OMF 6 developer preview is now available. Blah, blah.

To get start, please visit http://mytestbed.github.com/omf/

This developer preview release is to introduce the new system architectural design, protocol and API. At this stage, we are especially looking for the feedback on the new resource controller structure and the APIs for providing features and support for specific resources.

The code, protocol, and API will be continuously evolving and if you have any suggestion regarding the design or implementation, feel free to create a new issue on our official site, on our github project page, or simply drop an email on the mailing list.

jackhong

module OmfRc::ResourceProxy::Garage
  include OmfRc::ResourceProxyDSL

  register_proxy :garage

  def create(type, opts = nil)
    # I can check the type here
    if type.to_sym == :engine
      logger.info "I can do it"
    else

jackhong

@node = @comm.get_topic(`hostname`.chomp)

@node.on_message lambda {|m| m.operation == :inform && m.read_content('inform_type') == 'FAILED' } do |message|
  logger.error message
end

device_request = @comm.request_message([:devices])

device_request.on_inform_status do |message|
  @devices = message.read_property('devices').items

jackhong

# Original test01.rb

defProperty('res1', "unconfigured-node-1", "ID of a node")
defProperty('res2', "unconfigured-node-2", "ID of a node")

defGroup('Actor', property.res1)

onEvent(:ALL_UP) do |event|
  wait 3
  info "TEST - allGroups"

jackhong

# Given the asynchronous nature of all operations, 
# a simple property assignment is actually a chain of callbacks behind the scene.

# Take this not too simple example

g.applications[:name => 'app_foo'].target_ip = g[:name => 'node1'].interfaces[:name => 'wlan0'].ip

# If we think about xmpp communication, the work flow would be sth like this. (simplified pseudo code)

g[:name => 'node1'].request_interfaces[:name => 'wlan0'] do |i|

jackhong

# Original ruby script
#
require "xmlrpc/client"
require "pp"

XMLRPC::Config.module_eval do
  remove_const :ENABLE_NIL_PARSER
  const_set :ENABLE_NIL_PARSER, true
end

jackhong

require 'pp' 
require 'omf_rete/store' 
 
N = 100 
 
s = OMF::Rete::Store.create 3 
(1..N).each do |i| 
  s.addTuple(["node_#{i}", 'status', 'ok']) 
end