mirror of
https://github.com/xcat2/confluent.git
synced 2026-09-02 07:26:04 +00:00
054ca63600
State of offloader was never checked after acquiring the lock. Fix by checking with the lock held. Also, neaten up by putting all the offload startup inside the function to start it up.