Commit 808e937c authored by Niclas Esser's avatar Niclas Esser
Browse files

Added SPEAD2 protocol to EDDDataStore::format

parent 570303a0
......@@ -33,7 +33,7 @@ data_formats = {
"port": "",
"description": "Spead stream of integrated spectra.",
"central_freq": "",
"receiver_id": "", # Passign down all informations via the data format is only a hack as any product should not what to pass down from upstream to downstream. Only a full desciption of itself should be passed. If a data writer needs all information, it should recnstrut it from the entreis in the data store.
"receiver_id": "", # Passign down all informations via the data format is only a hack as any product should not what to pass down from upstream to downstream. Only a full desciption of itself should be passed. If a data writer needs all information, it should recnstrut it from the entreis in the data store.
"band_flip": ""
},
"MPIFR_EDD_Packetizer:1": {
......@@ -53,9 +53,55 @@ data_formats = {
"EDDVDIF:1": {
"ip": "",
"port": ""
}
},
"CRYO_PAF_PACKETIZER:1": {
"ip": "",
"port": "",
"bit_depth" : 0,
"sample_rate" : 0,
"sync_time" : 0,
"band_flip": False,
"central_freq": 0,
"receiver_id": "",
"polarization": 2,
"samples_per_heap": 4096,
"description": "Spead stream of time-domain packetizer data as in EDD ICD."
},
"SIMPLE_SPEAD2:1": {
"ip": "",
"port": "",
"bit_depth" : 0,
"sample_rate" : 0,
"sync_time" : 0,
"band_flip": False,
"central_freq": 0,
"receiver_id": "",
"polarization": 2,
"samples_per_heap": 4096,
"spead2_description" : [
{
"id": "0x1600",
"name" : "timestamp",
"description":"",
"shape" : [6],
"dtype" : ">u1",
"order" : "C",
"value" : 0,
"step" : 16384
},
{
"id": "0x1601",
"name" : "payload",
"description":"payload",
"shape" : [16384],
"dtype" : "int8",
"order" : "C"
}
],
"description": "Spead stream of time-domain packetizer data as in EDD ICD."
}
}
......@@ -223,7 +269,7 @@ if __name__ == "__main__":
parser.add_argument('--redis-port', dest='redis_port', type=int, default=6379,
help='The port number for the redis server')
parser.add_argument('--register_product', dest='product_config', type=str,
parser.add_argument('--register_product', dest='product_config', type=str,
help='Product config for the registration id=ProductId;ip=HOSTNAME;port=port')
args= parser.parse_args()
......@@ -238,4 +284,3 @@ if __name__ == "__main__":
print(" {}: {}".format(k, v))
cfg[k] = v
dataStore.updateProduct(cfg)
Supports Markdown
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