Commit Graph

500 Commits (d892eed7f688c1f1bc1c1c6cb78d2d97f5ea0bcf)

Author SHA1 Message Date
Ebbe Baß cb138dbbd9 added 5 sec sleeper before startin publisher
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 16:32:17 +01:00
Ebbe Baß 33d4441b30 made some performance improvements
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 16:31:03 +01:00
Ebbe Baß b9efd8d208 temp removed debug message
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 16:28:46 +01:00
Ebbe Baß 0378913371 removed debug
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 16:20:47 +01:00
Ebbe Baß bf2cd6ae8f made quciekr update cycle
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 16:20:06 +01:00
Ebbe Baß a797c28833 added a none check for original received data
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 16:18:47 +01:00
Ebbe Baß 79176e5af6 fixed exception malformed stirng or array
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 16:16:53 +01:00
Ebbe Baß 9795ebac91 added better logic for old data with if else
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 16:16:06 +01:00
Ebbe Baß eb458f3e7e added except back again
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 16:12:35 +01:00
Ebbe Baß f075db5206 test
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 16:11:26 +01:00
Ebbe Baß 43ec007e47 fixed none logix
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 16:03:33 +01:00
Ebbe Baß 233259afb9 test with old data
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 16:02:45 +01:00
Ebbe Baß 984598f6a2 added old data logic if tube index is none
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 16:01:08 +01:00
Ebbe Baß 774f8fa44c fixed old data storage
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 15:58:59 +01:00
Ebbe Baß 0fbdec6bfa test
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 15:58:13 +01:00
Ebbe Baß 0d1cbb811b nvm. not tuple. more like list
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 15:56:57 +01:00
Ebbe Baß bb9f5c8f2a made tube_index tuple when received
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 15:46:47 +01:00
Ebbe Baß 88ae6c1cb2 debug
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 15:46:04 +01:00
Ebbe Baß 988d3edf41 testing system with non-blocking
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 15:45:22 +01:00
Ebbe Baß a06d203245 test
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 15:40:50 +01:00
Ebbe Baß 4e7754b3f7 test
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 15:40:15 +01:00
Ebbe Baß fcc7b61605 test
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 14:59:35 +01:00
Ebbe Baß a4453d4abf added pipe back
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 13:43:56 +01:00
Ebbe Baß c86b3bd8b0 test
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 13:36:37 +01:00
Ebbe Baß 146786eec2 testing other methode
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 13:35:33 +01:00
Ebbe Baß b2342e54c2 test
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 13:34:04 +01:00
Ebbe Baß 5a91728b0f testing pipe
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 13:33:11 +01:00
Ebbe Baß e476c0c46d fixed disct shit
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 13:18:38 +01:00
Ebbe Baß 914c328a45 changed to Value again with c_char_p
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 13:17:15 +01:00
Ebbe Baß 4cae853f15 added to list
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:58:10 +01:00
Ebbe Baß 90231aeb16 tube_index to string when in dict
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:57:41 +01:00
Ebbe Baß 1e5a7dd980 fixed vars
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:56:45 +01:00
Ebbe Baß f1f9000705 testing out manager with sharing a dict for tube index
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:55:28 +01:00
Ebbe Baß 0ec07b5727 aded type code
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:48:20 +01:00
Ebbe Baß 7d6f4ebba6 test
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:47:48 +01:00
Ebbe Baß 81d20a2a27 test
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:47:10 +01:00
Ebbe Baß 5886416df3 fixed Value
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:44:49 +01:00
Ebbe Baß 68a27dc94f removed flag for mp
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:29:47 +01:00
Ebbe Baß d976af7f5a added multiprocessing+
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:28:35 +01:00
Ebbe Baß a1c23b63a2 place holder
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:25:58 +01:00
Ebbe Baß decdd88692 this methode is sooo fucking dumb but ok
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:24:58 +01:00
Ebbe Baß 8943085d7a added sleeper
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:24:07 +01:00
Ebbe Baß 41bb1bfa6f added shared value with mp
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:23:06 +01:00
Ebbe Baß 709ffb472e test
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:09:48 +01:00
Ebbe Baß 0468eab30c added encoding
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:07:15 +01:00
Ebbe Baß c4f980a2f5 removed enconding arg
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:06:03 +01:00
Ebbe Baß e12d147297 removed print
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:04:29 +01:00
Ebbe Baß 5a30afd611 convert tube_index to string for shared mem
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:03:50 +01:00
Ebbe Baß a5a5c001f3 foxed bytes
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:02:48 +01:00
Ebbe Baß 830b5932cf removed list. next test
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:02:23 +01:00
Ebbe Baß 688876903a debug
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 01:01:34 +01:00
Ebbe Baß 2c264ac6d6 switched from queue to shared mem
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 00:59:18 +01:00
Ebbe Baß dd5d64eed3 removed all debuggings
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 00:50:49 +01:00
Ebbe Baß 1dd6b570c0 new debugging
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 00:49:45 +01:00
Ebbe Baß 9d8d5e610d debugging
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 00:47:19 +01:00
Ebbe Baß acc6a93eb9 added some debugging
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 00:46:11 +01:00
Ebbe Baß 826641b0ce added some debugging
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 00:45:16 +01:00
Ebbe Baß 6cc0a003be added while loop and a 5 sec sleeper
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 00:44:26 +01:00
Ebbe Baß b2b958018e fixed typo
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 00:42:17 +01:00
Ebbe Baß b2c8dc5d83 added queue system for mem share between publisher and ti updater
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 00:41:47 +01:00
Ebbe Baß 3a5ad1e6af revert changed
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 00:08:39 +01:00
Ebbe Baß 3e1f60fa22 fixed mqtt
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-18 00:07:04 +01:00
Ebbe Baß 3c8c048c45 mqtt_publisher as normal function
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 23:43:51 +01:00
Ebbe Baß 50b358f6fc fixed update
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 23:37:21 +01:00
Ebbe Baß 6c69200a44 removed debug
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 23:31:12 +01:00
Ebbe Baß 02ced5fef2 added list conversion
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 23:15:40 +01:00
Ebbe Baß 74fa0640ff added while loop to tube index updater
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 23:15:02 +01:00
Ebbe Baß bedbf76b5f updated each second
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 23:08:31 +01:00
Ebbe Baß 83004d35fa added decode for publish
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 23:07:26 +01:00
Ebbe Baß 77ad069eec adfded multiprocessisng back again and also made a mqtt share for the tube index
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 23:03:40 +01:00
Ebbe Baß 775a6caf77 removed debug prints
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:35:37 +01:00
Ebbe Baß 935bdeb38b FUCK IT. Gonna fix that db spam later
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:34:59 +01:00
Ebbe Baß ac14cce7b5 fixed run forefer
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:33:39 +01:00
Ebbe Baß 04a5dbc19d index_updater run forever
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:32:07 +01:00
Ebbe Baß 7a60df2668 debug
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:31:05 +01:00
Ebbe Baß a484a63149 declare as globa
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:30:09 +01:00
Ebbe Baß 348ee5e4ad made tube index async functipn
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:28:02 +01:00
Ebbe Baß 3081f2ae66 thread manager update
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:21:20 +01:00
Ebbe Baß f0f13debae thread manager
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:19:53 +01:00
Ebbe Baß 070ae2fa41 testing
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:15:18 +01:00
Ebbe Baß d6e06901d3 tube index globalisation
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:12:12 +01:00
Ebbe Baß dfdac3897b tube index test
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:11:41 +01:00
Ebbe Baß 062c718dd9 remove del
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:11:22 +01:00
Ebbe Baß 923f0e4685 testing some weird siht
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:10:56 +01:00
Ebbe Baß 8ece5779ae debug tedt
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:08:25 +01:00
Ebbe Baß 3f5e0de208 print index row
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:07:13 +01:00
Ebbe Baß a4e004a1b3 moved dmx var
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:05:40 +01:00
Ebbe Baß ba23bae0d5 removed debug
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:03:19 +01:00
Ebbe Baß 3068288bcd debug
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:02:34 +01:00
Ebbe Baß ff183d7901 removed debug
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:01:33 +01:00
Ebbe Baß 6ddb8ff1a6 debug
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 17:00:49 +01:00
Ebbe Baß 761c3baaf1 added mac address back again
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 16:59:54 +01:00
Ebbe Baß 6f75b5eb01 print tube_index
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 16:58:17 +01:00
Ebbe Baß 762f7fc015 moved del
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 16:57:52 +01:00
Ebbe Baß 9b464fb5de delete tube index
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 16:56:47 +01:00
Ebbe Baß 283f4c8f01 removed globalisation
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 16:43:32 +01:00
Ebbe Baß bcfba3738c print TUBE_INDEX
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 16:42:14 +01:00
Ebbe Baß 28d8a50dbe removed universe from db request
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 16:40:39 +01:00
Ebbe Baß 31eb06a2ab added TUBE_INDEX to mqtt publisher and removed it at script start
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 16:38:46 +01:00
Ebbe Baß 7affda9c98 moved the updater out of a seperate function the worked as a multiprocess because the global var wasnt shared between the processes
Signed-off-by: Ebbe Baß <ebbe.bass>
2024-02-17 16:36:43 +01:00