Maximum number of consumers (16) exceeded

[gelanchez]

Hey folks, I'm hitting a weird limit in HORUS with Python. I’ve got one producer and one consumer on separate files, but I keep getting: RuntimeError: Maximum number of consumers (16) exceeded for topic 'keyboard.pressed'. I’ve confirmed no other instances are running. This happens randomly.

[neos-builder]

Hmnn, did you use the keyboardnode? to get the topic 'keyboard.pressed'. It would be nice to see the code you were running

[gelanchez]

Hi. Yes, keyboardnode. The code is quite simple, just two files. I think I've seen this error happening when running horus.run(), and not when running with the scheduler. Is it better one than the other one? If I hit the same error, I'll C&P the code here.

[neos-builder]

Yeah, there is a bug, there is no decrement of count when receiving continuous data, I will add drop() for shm,I remembered adding this, but might be deleted somewhere along merging the commits. For now, it doesnt have the automatic clean up, so you might need to rm -rf dev/shm/topic _name every once in a while. I will check on the mismatch of scheduler and python binding.

[gelanchez]

For these tests I'm running rm -rf /dev/shm/horus before every hours run. I think I've seen it even with that.

[neos-builder]

Hmnn, it might be in that runtime, when you clean the topic and run again, it create that dev/shm/horus/topic_name and the Hub, which is MPMC has a dedicated fixed amount of slots, without the drop(), when exceeding, it doesn't auto point back to the first slot to overwritten. This might likely be the cause. I will test with keyboard node before next commit.