30):
31
32 modules = []
33 queues = []
34
35 last_ip = 100
36
37 core_maps = []
38 for core in range(NUMBER_OF_CORES):
39 ips = []
40 for ip in range(NUMBER_OF_IPS_PER_CORE):
41 src_ip = f'{BASE_SOURCE_IP}{last_ip + core * NUMBER_OF_IPS_PER_CORE + ip}'
42 ips.append(src_ip)
43 core_maps.append(nsc.Core(lcore_id=core+1, src_ips=ips))
44
45 modules += [DAQModule(name="nic_sender", plugin="NICSender",
46 conf=nsc.Conf(
47 eal_arg_list=EAL_ARGS,
48 frontend_type='tde',
49 number_of_cores=NUMBER_OF_CORES,
50 number_of_ips_per_core=NUMBER_OF_IPS_PER_CORE,
51 burst_size=1,
52 rate=1,
53 core_list=core_maps,
54 time_tick_difference=TIME_TICK_DIFFERENCE,
55 )
56
57 )]
58
59 mgraph = ModuleGraph(modules, queues=queues)
60
61 dpdk_app = App(modulegraph=mgraph, host=HOST, name="dpdk_sender")
62 return dpdk_app