if status == AsyncKeys.STATUS_NONE:
time.sleep(0.001)
- if self.tui_global_lock.locked():
- self.x += 1
with self.tui_global_lock:
self.handle_state_machine()
('L2 len', len(obj['pkt']) + 4),
('mode', obj['mode']),
('rate', obj['rate']),
- ('next_stream', obj['next_id'])
+ ('next_stream', obj['next_id'] if not '-1' else 'None')
])
return {"streams" : OrderedDict(sorted(data.items())) }
# stateless simulation
class STLSim(object):
+ MASK_ALL = ((1 << 64) - 1)
+
def __init__ (self, bp_sim_path, handler = 0, port_id = 0, api_h = "dummy"):
self.bp_sim_path = os.path.abspath(bp_sim_path)
"force": force,
"port_id": self.port_id,
"mul": parsing_opts.decode_multiplier(mult),
- "duration": duration}
+ "duration": duration,
+ "core_mask": self.MASK_ALL}
}
SimStateless::prepare_dataplane() {
CGlobalInfo::m_options.m_expected_portd = m_port_count;
+ CGlobalInfo::m_options.m_run_mode = CParserOption::RUN_MODE_INTERACTIVE;
assert(CMsgIns::Ins()->Create(m_dp_core_count));
m_fl.Create();