return 0;
 }
 
+static ssize_t mmal_memcpy_wrapper(void *src, void *dst,
+                                  size_t offset, size_t size)
+{
+       memcpy(dst + offset, src + offset, size);
+
+       return size;
+}
+
 /* queue the buffer availability with MMAL_MSG_TYPE_BUFFER_FROM_HOST */
 static int
 buffer_from_host(struct vchiq_mmal_instance *instance,
 
        vchi_service_use(instance->handle);
 
-       ret = vchi_msg_queue(instance->handle, &m,
+       ret = vchi_msg_queue(instance->handle, mmal_memcpy_wrapper, &m,
                             sizeof(struct mmal_msg_header) +
-                            sizeof(m.u.buffer_from_host),
-                            VCHI_FLAGS_BLOCK_UNTIL_QUEUED, NULL);
+                            sizeof(m.u.buffer_from_host));
 
        if (ret != 0) {
                release_msg_context(msg_context);
        vchi_service_use(instance->handle);
 
        ret = vchi_msg_queue(instance->handle,
+                            mmal_memcpy_wrapper,
                             msg,
-                            sizeof(struct mmal_msg_header) + payload_len,
-                            VCHI_FLAGS_BLOCK_UNTIL_QUEUED, NULL);
+                            sizeof(struct mmal_msg_header) + payload_len);
 
        vchi_service_release(instance->handle);