# This should be a test startup script
require adhama
require adpluginkafka
require seq


epicsEnvSet("PREFIX", "Hama:")
epicsEnvSet("PORT",   "HAMA")
epicsEnvSet("CAMERA", "0")
epicsEnvSet("QSIZE",  "21")
epicsEnvSet("XSIZE",  "2048")
epicsEnvSet("YSIZE",  "2048")
epicsEnvSet("NCHANS", "2048")
# Number of Elements
epicsEnvSet("NELEMENTS", "4194304")
epicsEnvSet("EPICS_CA_MAX_ARRAY_BYTES", "64000000")

#EVR settings
epicsEnvSet("EVR", "YMIR-TS:Ctrl-EVR-01")
epicsEnvSet("EVR_EVENT", "E")

# iocshLoad("$(adhama_DIR)ADHama.iocsh")

devHamamatsuConfig("$(PORT)", $(CAMERA), 0, 0, 0, 0, 10)

dbLoadRecords("$(adhama_DIR)db/hama.db","P=$(PREFIX),R=cam1:,EVR=$(EVR),E=$(EVR_EVENT),PORT=$(PORT),ADDR=0,TIMEOUT=1")

#asynSetTraceMask("$(PORT)",-1,0x9) 
#asynSetTraceIOMask("$(PORT)",-1,0x2)


# =========================================================================================================
# Create a PVA arrays plugin
# NDPvaConfigure (const char *portName, int queueSize, int blockingCallbacks,
#                      const char *NDArrayPort, int NDArrayAddr, const char *pvName,
#                      size_t maxMemory, int priority, int stackSize)
NDPvaConfigure("PVA1", $(QSIZE), 0, "$(PORT)", 0, "$(PREFIX)Pva1:Image", 0, 0, 0)
dbLoadRecords("$(adcore_DIR)/db/NDPva.template",  "P=$(PREFIX),R=Pva1:, PORT=PVA1,ADDR=0,TIMEOUT=1,NDARRAY_PORT=$(PORT)")
#

# Create a standard arrays plugin, set it to get data from hama driver.
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

#
#
# Start iocInit function===================================================================================
#
iocInit()
#
# End iocInit function ====================================================================================
#

dbpf Hama:cam1:PoolUsedMem.SCAN 0
dbpf Hama:image1:EnableCallbacks 1
dbpf Hama:Kfk1:EnableCallbacks 1

dbpf Hama:cam1:AcquireTime .05
#dbpf Hama:cam1:TriggerSource-S 1 # external
#dbpf Hama:cam1:NumImages 10
#dbpf Hama:cam1:ImageMode 1

#dbpf Hama:cam1:TriggerPolarity-S    # 2-positive, 1-negative

epicsThreadSleep(1.0)

dbl > pv.list

#
# END of st.cmd
#