Skip to content

Conversation

@kirya-dev
Copy link
Contributor

ERR_CONCURRENT_API_CALL

Im added log_last_operation after PassThruWriteMsgs and this fix show me which real reason didnt work Pulsar correctly.

I temporarily fix this problem by adding before reading - time.sleep(0.02). Doesn't seem to be a good idea.

@kirya-dev
Copy link
Contributor Author

Will test Semaphore tomorrow with Pulsar..

@kirya-dev
Copy link
Contributor Author

kirya-dev commented Nov 19, 2024

Hmm.. I think this should be around in queries with all Connection classes.

Why reading is async from main thread? I think reading thread must be started when we want.

  1. Acquire Semaphore.
  2. Clerar rx buffer
  3. Send WriteMsgs
  4. Sending ReadMsgs during current timeout
  5. Release Semaphore.

Its steps creating queue of all queries. In one time handling one request-response.

@kirya-dev
Copy link
Contributor Author

test

Works perfectly ✨

@pylessard
Copy link
Owner

Is this a work in progress or ready to be merged?

@kirya-dev
Copy link
Contributor Author

I think ready for merge.

i can improve this for all connections. Maybe its a newer version 2.x will be?

But i can test only j2534

@pylessard
Copy link
Owner

No, don't touch other connections please. They are thread safe

@pylessard pylessard merged commit ac54977 into pylessard:master Nov 21, 2024
2 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants