code: def recv_rpc(self, context, payload):
          
          logger.debug("Adding RPC payload to ControlBuffer queue: %s", payload)
          self.buf.put(('rpc', (context, payload)))
          with self.cv:
              self.cv.notifyAll()
docs: Call from any thread