@@ -96,7 +96,7 @@ def simulate(devs, duration, simu_name, is_remote, with_progress=True):
9696 parser .add_argument ("-remote" , help = _ ("Remote execution" ), action = "store_true" )
9797 parser .add_argument ("-name" , help = _ ("Simulation name" ), type = str , default = "simu" )
9898 # optional kernel for simulation kernel
99- parser .add_argument ("-kernel" , help = _ ("Simulation kernel [pyDEVS |PyPDEVS]" ), type = str , default = "pyDEVS " )
99+ parser .add_argument ("-kernel" , help = _ ("Simulation kernel [PyDEVS |PyPDEVS|KafkaDEVS ]" ), type = str , default = "PyDEVS " )
100100 # optional real time
101101 parser .add_argument ("-rt" , help = _ ("Real time simulation (only for PyPDEVS)" ), action = "store_true" )
102102
@@ -124,6 +124,15 @@ def simulate(devs, duration, simu_name, is_remote, with_progress=True):
124124
125125 ### Real time only for PyPDEVS...
126126 setattr (builtins , 'REAL_TIME' , args .rt )
127+ elif 'PyDEVS' in args .kernel :
128+ setattr (builtins ,'DEFAULT_DEVS_DIRNAME' ,'PyDEVS' )
129+ setattr (builtins , 'DEFAULT_SIM_STRATEGY' , 'bag-based' )
130+ elif 'KafkaDEVS' in args .kernel :
131+ setattr (builtins ,'DEFAULT_DEVS_DIRNAME' ,'KafkaDEVS' )
132+ setattr (builtins , 'DEFAULT_SIM_STRATEGY' , 'original' )
133+ else :
134+ sys .stdout .write (_ ("ERROR: Invalid kernel name (must be PyDEVS, PyPDEVS or KafkaDEVS)!\n " ))
135+ sys .exit (1 )
127136
128137 filename = args .filename
129138
0 commit comments