2023-10-26 13:54:33 CST W43D4

avutil_threadmessage.go

@@ -0,0 +1,71 @@
+package ffmpeg
+
+/*
+#include <libavutil/threadmessage.h>
+
+typedef void (*av_thread_message_free_func)(void *msg);
+*/
+import "C"
+import "unsafe"
+
+type AVThreadMessageQueue C.struct_AVThreadMessageQueue
+
+// AVThreadMessageFlags
+type AVThreadMessageFlags = C.enum_AVThreadMessageFlags
+
+const (
+	AV_THREAD_MESSAGE_NONBLOCK = AVThreadMessageFlags(C.AV_THREAD_MESSAGE_NONBLOCK)
+)
+
+// AvThreadMessageQueueAlloc allocates a new message queue.
+func AvThreadMessageQueueAlloc[T HelperInteger](mq **AVThreadMessageQueue, nelem, elsize T) int32 {
+	return (int32)(C.av_thread_message_queue_alloc(
+		(**C.struct_AVThreadMessageQueue)(unsafe.Pointer(mq)), (C.uint)(nelem), (C.uint)(elsize)))
+}
+
+// AvThreadMessageQueueFree frees a message queue.
+func AvThreadMessageQueueFree(mq **AVThreadMessageQueue) {
+	C.av_thread_message_queue_free((**C.struct_AVThreadMessageQueue)(unsafe.Pointer(mq)))
+}
+
+// AvThreadMessageQueueSend sends a message on the queue.
+func AvThreadMessageQueueSend(mq *AVThreadMessageQueue, msg CVoidPointer, flags uint32) int32 {
+	return (int32)(C.av_thread_message_queue_send((*C.struct_AVThreadMessageQueue)(mq),
+		VoidPointer(msg), (C.uint)(flags)))
+}
+
+// AvThreadMessageQueueRecv receives a message from the queue.
+func AvThreadMessageQueueRecv(mq *AVThreadMessageQueue, msg CVoidPointer, flags uint32) int32 {
+	return (int32)(C.av_thread_message_queue_recv((*C.struct_AVThreadMessageQueue)(mq),
+		VoidPointer(msg), (C.uint)(flags)))
+}
+
+// AvThreadMessageQueueSetErrSend sets the sending error code.
+func AvThreadMessageQueueSetErrSend(mq *AVThreadMessageQueue, err int32) {
+	C.av_thread_message_queue_set_err_send((*C.struct_AVThreadMessageQueue)(mq), (C.int)(err))
+}
+
+// AvThreadMessageQueueSetErrRecv set the receiving error code.
+func AvThreadMessageQueueSetErrRecv(mq *AVThreadMessageQueue, err int32) {
+	C.av_thread_message_queue_set_err_recv((*C.struct_AVThreadMessageQueue)(mq), (C.int)(err))
+}
+
+// typedef void (*av_thread_message_free_func)(void *msg);
+type AvThreadMessageFreeFunc = C.av_thread_message_free_func
+
+// AvThreadMessageQueueSetFreeFunc sets the optional free message callback function which will be called if an
+// operation is removing messages from the queue.
+func AvThreadMessageQueueSetFreeFunc(mq *AVThreadMessageQueue, freeFunc AvThreadMessageFreeFunc) {
+	C.av_thread_message_queue_set_free_func((*C.struct_AVThreadMessageQueue)(mq),
+		(C.av_thread_message_free_func)(freeFunc))
+}
+
+// AvThreadMessageQueueNbElems returns the current number of messages in the queue.
+func AvThreadMessageQueueNbElems(mq *AVThreadMessageQueue) int32 {
+	return (int32)(C.av_thread_message_queue_nb_elems((*C.struct_AVThreadMessageQueue)(mq)))
+}
+
+// AvThreadMessageFlush flushes the message queue.
+func AvThreadMessageFlush(mq *AVThreadMessageQueue) {
+	C.av_thread_message_flush((*C.struct_AVThreadMessageQueue)(mq))
+}