Commit 5ca5bd03 authored by Alejandro Homs Puron's avatar Alejandro Homs Puron Committed by operator for beamline

Lima: implement GlobalCPUAffinityMgr:

* Receiver listener and writer threads
* Lima plugin and processing threads
* Other OS processes
* NetDevGroup queues rps_cpus
parent 0d053778
Subproject commit 97bacad038fd19f72ec115a3ab99317d7b9a1c66
Subproject commit 89aa4b6962294dc220cb3c14755c019c8298c853
def test_macro '{
while(1) {
local napi, cbp, cbe, bf, fr, nbi, et;
local lcd, lsd, ln, i;
napi = 1;
fr = ($# > 0) ? $1 : 22.0e3
nbi = ($# > 1) ? $2 : 30000
et = 1 / fr - _limapar_get("eiger500k", "latency_time")
for (i = 1; i <= list_n(LIMA_DEV); i++) {
ln = list_item(LIMA_DEV, i);
lcd = list_getpar(LIMA_DEV, ln, "control");
lsd = list_getpar(LIMA_DEV, ln, "config");
if (list_getpar(LIMA_DEV, ln, "unit") == CCD_U)
break;
}
if (i > list_n(LIMA_DEV)) {
printf("Error: could not find LIMA dev for CCD %d\n", \
CCD_U);
exit;
}
bench ccdtake et nbi;
if (napi) {
tango_io(lsd, "getStats", "-1:cb_period", \
eiger_cb_period_stats);
tango_io(lsd, "getStats", "-1:cb_exec", \
eiger_cb_exec_stats);
bf = tango_io(lsd, "getNbBadFrames", -1)
} else {
tango_get(lsd, "stats_cb_period", \
eiger_cb_period_stats);
tango_get(lsd, "stats_cb_exec", \
eiger_cb_exec_stats);
bf = tango_get(lsd, "nb_bad_frames")
};
printf("\n%6d %6d %8.2f %8.2f\n", \
tango_get(lcd, "last_image_acquired") + 1, bf, \
eiger_cb_period_stats[2], eiger_cb_exec_stats[2]);
double array port_stats[4][5];
if (napi) {
for (i = 0; i < 4; i++)
tango_io(lsd, "getStats", \
sprintf("%d:cb_period", i), \
port_stats[i]);
p port_stats[:][2];
for (i = 0; i < 4; i++)
tango_io(lsd, "getStats", \
sprintf("%d:cb_exec", i), \
port_stats[i]);
p port_stats[:][2];
};
sleep(1)
}
}'
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment