examples/omf_vlc.py

   1 #!/usr/bin/env python
   2 # -*- coding: utf-8 -*-
   3
   4 #
   5 # Experiment Topology:
   6 #
   7 #  n1 --- n2
   8 #  0.1   0.2
   9 #
  10
  11 from nepi.core.design import ExperimentDescription, FactoriesProvider
  12 from nepi.core.execute import ExperimentController
  13 import getpass
  14 import tempfile
  15 import time
  16
  17 root_dir = tempfile.mkdtemp()
  18
  19 exp_desc = ExperimentDescription()
  20
  21 testbed_id = "omf"
  22 omf_provider = FactoriesProvider(testbed_id)
  23 omf_desc = exp_desc.add_testbed_description(omf_provider)
  24 omf_desc.set_attribute_value("homeDirectory", root_dir)
  25 omf_desc.set_attribute_value("enableDebug", True)
  26 omf_desc.set_attribute_value("xmppSlice", "default_slice")
  27 omf_desc.set_attribute_value("xmppHost", "xmpp-omf.onelab.eu")
  28 omf_desc.set_attribute_value("xmppPort", 5222)
  29 omf_desc.set_attribute_value("xmppPassword", "******")
  30
  31 node1 = omf_desc.create("Node")
  32 node1.set_attribute_value("hostname", "omf.my.wlab18")
  33 node2 = omf_desc.create("Node")
  34 node2.set_attribute_value("hostname", "omf.my.wlab49")
  35
  36 iface12 = omf_desc.create("WifiInterface")
  37 iface12.set_attribute_value("mode", "adhoc")
  38 iface12.set_attribute_value("channel", "g")
  39 iface12.set_attribute_value("type", "g")
  40 iface12.set_attribute_value("essid", "cvlcmode")
  41 node1.connector("devs").connect(iface12.connector("node"))
  42
  43 iface21 = omf_desc.create("WifiInterface")
  44 iface21.set_attribute_value("mode", "adhoc")
  45 iface21.set_attribute_value("channel", "g")
  46 iface21.set_attribute_value("type", "g")
  47 iface21.set_attribute_value("essid", "cvlcmode")
  48 node2.connector("devs").connect(iface21.connector("node"))
  49
  50 ip12 = iface12.add_address()
  51 ip12.set_attribute_value("Address", "192.168.0.18")
  52
  53 ip21 = iface21.add_address()
  54 ip21.set_attribute_value("Address", "192.168.0.49")
  55
  56 channel = omf_desc.create("Channel")
  57 channel.set_attribute_value("mode", "adhoc")
  58 channel.set_attribute_value("channel", "g")
  59 channel.set_attribute_value("type", "g")
  60 channel.set_attribute_value("essid", "cvlcmode")
  61 channel.connector("devs").connect(iface12.connector("chan"))
  62 channel.connector("devs").connect(iface21.connector("chan"))
  63
  64 app2 = omf_desc.create("Application")
  65 app2.set_attribute_value("appId", "Vlc#2")
  66 app2.set_attribute_value("arguments", "rtp://239.255.0.1:1234")
  67 app2.set_attribute_value("path", "/opt/vlc-1.1.13/vlc")
  68 app2.connector("node").connect(node2.connector("apps"))
  69
  70 app1 = omf_desc.create("Application")
  71 app1.set_attribute_value("appId", "Vlc#1")
  72 app1.set_attribute_value("arguments", "/opt/10-by-p0d.avi --sout '#duplicate{dst=display,dst=rtp{mux=ts,dst=239.255.0.1,port=1234}}'")
  73 app1.set_attribute_value("path", "/opt/vlc-1.1.13/vlc")
  74 app1.connector("node").connect(node1.connector("apps"))
  75
  76 xml = exp_desc.to_xml()
  77
  78 controller = ExperimentController(xml, root_dir)
  79 controller.start()
  80 #while not (controller.is_finished(app1.guid) and \
  81 #        controller.is_finished(app2.guid)):
  82 #    time.sleep(0.5)
  83
  84 time.sleep(30)
  85
  86 controller.stop()
  87 controller.shutdown()
  88