Added io interrupter

format_context.go

@@ -3,17 +3,6 @@ package astiav
 //#cgo pkg-config: libavcodec libavformat
 //#include <libavcodec/avcodec.h>
 //#include <libavformat/avformat.h>
-/*
-int astiavInterruptCallback(void *ret)
-{
-    return *((int*)ret);
-}
-AVIOInterruptCB astiavNewInterruptCallback(int *ret)
-{
-	AVIOInterruptCB c = { astiavInterruptCallback, ret };
-	return c;
-}
-*/
 import "C"
 import (
 	"math"
@@ -95,10 +84,10 @@ func (fc *FormatContext) Flags() FormatContextFlags {
 	return FormatContextFlags(fc.c.flags)
 }
 
-func (fc *FormatContext) SetInterruptCallback() *int {
-	ret := 0
-	fc.c.interrupt_callback = C.astiavNewInterruptCallback((*C.int)(unsafe.Pointer(&ret)))
-	return &ret
+func (fc *FormatContext) SetInterruptCallback() IOInterrupter {
+	i := newIOInterrupter()
+	fc.c.interrupt_callback = i.c
+	return i
 }
 
 func (fc *FormatContext) InputFormat() *InputFormat {

format_context_test.go

@@ -56,7 +56,12 @@ func TestFormatContext(t *testing.T) {
 	require.NotNil(t, s3)
 	require.Equal(t, 1, s3.Index())
 
-	// TODO Test SetInterruptCallback
+	fc4 := AllocFormatContext()
+	require.NotNil(t, fc4)
+	defer fc4.Free()
+	fc4.SetInterruptCallback().Interrupt()
+	require.ErrorIs(t, fc4.OpenInput("testdata/video.mp4", nil, nil), ErrExit)
+
 	// TODO Test ReadFrame
 	// TODO Test SeekFrame
 	// TODO Test Flush

io_interrupter.go

@@ -0,0 +1,37 @@
+package astiav
+
+//#cgo pkg-config: libavformat
+//#include <libavformat/avio.h>
+/*
+int astiavInterruptCallback(void *ret)
+{
+    return *((int*)ret);
+}
+AVIOInterruptCB astiavNewInterruptCallback(int *ret)
+{
+	AVIOInterruptCB c = { astiavInterruptCallback, ret };
+	return c;
+}
+*/
+import "C"
+
+type IOInterrupter interface {
+	Interrupt()
+}
+
+var _ IOInterrupter = (*ioInterrupter)(nil)
+
+type ioInterrupter struct {
+	c C.struct_AVIOInterruptCB
+	i C.int
+}
+
+func newIOInterrupter() *ioInterrupter {
+	cb := &ioInterrupter{}
+	cb.c = C.astiavNewInterruptCallback(&cb.i)
+	return cb
+}
+
+func (cb *ioInterrupter) Interrupt() {
+	cb.i = 1
+}