lin-epics-modules/adorca
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add adpluginkafka

Browse Source
This commit is contained in:
Iocuser
2023-02-06 13:20:07 +01:00
committed by Tomasz Brys
parent 7dc9fd7cb3
commit e7d48816d2
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
cmds/st.cmd
View File

@@ -1,5 +1,6 @@
# This should be a test startup script
require adhama
require adpluginkafka
epicsEnvSet("PREFIX", "Hama:")
@@ -36,6 +37,15 @@ dbLoadRecords("$(adcore_DIR)/db/NDPva.template", "P=$(PREFIX),R=Pva1:, PORT=PVA
NDStdArraysConfigure("Image1", "$(QSIZE)", 0, "$(PORT)", 0, 0)
dbLoadRecords("NDStdArrays.template", "P=$(PREFIX),R=image1:,PORT=Image1,ADDR=0,TIMEOUT=1,NDARRAY_PORT=$(PORT),TYPE=Int32,FTVL=LONG,NELEMENTS=$(NELEMENTS)")
# Create a kafka plugin, set it to get data from hama driver.
epicsEnvSet("KFK_SERVER_IP", "10.100.1.19")
epicsEnvSet("KFK_SERVER_PORT", "9092")
epicsEnvSet("KFK_TOPIC", "ymir_camera")
KafkaPluginConfigure("KFK1", 3, 1, "$(PORT)", 0, -1, "$(KFK_SERVER_IP):$(KFK_SERVER_PORT)", "$(KFK_TOPIC)", "hama_source")
dbLoadRecords("$(adpluginkafka_DIR)db/adpluginkafka.db", "P=$(PREFIX), R=Kfk1:, PORT=KFK1, ADDR=0, TIMEOUT=1, NDARRAY_PORT=$(PORT)")
startPVAServer
#
@@ -49,6 +59,7 @@ iocInit()
dbpf Hama:cam1:PoolUsedMem.SCAN 0
dbpf Hama:image1:EnableCallbacks 1
dbpf Hama:Kfk1:EnableCallbacks 1
epicsThreadSleep(1.0)