package/go-astiav
1
0
Fork 0
mirror of https://github.com/asticode/go-astiav.git synced 2025-10-05 00:02:45 +08:00
Code Issues Packages Projects Releases Wiki Activity

OpenIOContextWithDictionary (#116)

Browse Source 
* OpenIOContextWithDictionary

* OpenIOContext

* OpenIOContext

* IOInterrupterCB

* OpenIOContext(filename string, flags IOContextFlags, ii *IOInterrupter, d *Dictionary)
This commit is contained in:
oldma3095
2024-12-12 22:26:30 +08:00
committed by GitHub
parent 1f47f2ed3e
commit f8f8f0e7ee
6 changed files with 17 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
class_test.go
View File

@@ -48,7 +48,7 @@ func TestClassers(t *testing.T) {
fmc2 := AllocFormatContext() fmc2 := AllocFormatContext()
require.NoError(t, fmc2.OpenInput("testdata/video.mp4", nil, nil)) require.NoError(t, fmc2.OpenInput("testdata/video.mp4", nil, nil))
path := filepath.Join(t.TempDir(), "iocontext.txt") path := filepath.Join(t.TempDir(), "iocontext.txt")
ic1, err := OpenIOContext(path, NewIOContextFlags(IOContextFlagWrite)) ic1, err := OpenIOContext(path, NewIOContextFlags(IOContextFlagWrite), nil, nil)
require.NoError(t, err) require.NoError(t, err)
defer os.RemoveAll(path) defer os.RemoveAll(path)
ic2, err := AllocIOContext(1, true, nil, nil, nil) ic2, err := AllocIOContext(1, true, nil, nil, nil)

2
examples/remuxing/main.go
View File

@@ -103,7 +103,7 @@ func main() {
// If this is a file, we need to use an io context // If this is a file, we need to use an io context
if !outputFormatContext.OutputFormat().Flags().Has(astiav.IOFormatFlagNofile) { if !outputFormatContext.OutputFormat().Flags().Has(astiav.IOFormatFlagNofile) {
// Open io context // Open io context
ioContext, err := astiav.OpenIOContext(*output, astiav.NewIOContextFlags(astiav.IOContextFlagWrite)) ioContext, err := astiav.OpenIOContext(*output, astiav.NewIOContextFlags(astiav.IOContextFlagWrite), nil, nil)
if err != nil { if err != nil {
log.Fatal(fmt.Errorf("main: opening io context failed: %w", err)) log.Fatal(fmt.Errorf("main: opening io context failed: %w", err))
} }

2
examples/transcoding/main.go
View File

@@ -334,7 +334,7 @@ func openOutputFile() (err error) {
if !outputFormatContext.OutputFormat().Flags().Has(astiav.IOFormatFlagNofile) { if !outputFormatContext.OutputFormat().Flags().Has(astiav.IOFormatFlagNofile) {
// Open io context // Open io context
var ioContext *astiav.IOContext var ioContext *astiav.IOContext
if ioContext, err = astiav.OpenIOContext(*output, astiav.NewIOContextFlags(astiav.IOContextFlagWrite)); err != nil { if ioContext, err = astiav.OpenIOContext(*output, astiav.NewIOContextFlags(astiav.IOContextFlagWrite), nil, nil); err != nil {
err = fmt.Errorf("main: opening io context failed: %w", err) err = fmt.Errorf("main: opening io context failed: %w", err)
return return
} }

4
format_context_test.go
View File

@@ -61,7 +61,7 @@ func TestFormatContext(t *testing.T) {
fc3 := AllocFormatContext() fc3 := AllocFormatContext()
require.NotNil(t, fc3) require.NotNil(t, fc3)
defer fc3.Free() defer fc3.Free()
io, err := OpenIOContext("testdata/video.mp4", NewIOContextFlags(IOContextFlagRead)) io, err := OpenIOContext("testdata/video.mp4", NewIOContextFlags(IOContextFlagRead), nil, nil)
require.NoError(t, err) require.NoError(t, err)
defer io.Close() //nolint:errcheck defer io.Close() //nolint:errcheck
fc3.SetPb(io) fc3.SetPb(io)
@@ -140,7 +140,7 @@ func TestFormatContext(t *testing.T) {
require.NotNil(t, os) require.NotNil(t, os)
require.NoError(t, is.CodecParameters().Copy(os.CodecParameters())) require.NoError(t, is.CodecParameters().Copy(os.CodecParameters()))
} }
ic, err := OpenIOContext(outputPath, NewIOContextFlags(IOContextFlagWrite)) ic, err := OpenIOContext(outputPath, NewIOContextFlags(IOContextFlagWrite), nil, nil)
require.NoError(t, err) require.NoError(t, err)
fc7.SetPb(ic) fc7.SetPb(ic)
require.NoError(t, fc7.WriteHeader(nil)) require.NoError(t, fc7.WriteHeader(nil))

14
io_context.go
View File

@@ -108,12 +108,20 @@ func AllocIOContext(bufferSize int, writable bool, readFunc IOContextReadFunc, s
return return
} }
// https://ffmpeg.org/doxygen/7.0/avio_8c.html#ab1b99c5b70aa59f15ab7cd4cbb40381e // https://ffmpeg.org/doxygen/7.0/avio_8c.html#ae8589aae955d16ca228b6b9d66ced33d
func OpenIOContext(filename string, flags IOContextFlags) (*IOContext, error) { func OpenIOContext(filename string, flags IOContextFlags, ii *IOInterrupter, d *Dictionary) (*IOContext, error) {
cfi := C.CString(filename) cfi := C.CString(filename)
defer C.free(unsafe.Pointer(cfi)) defer C.free(unsafe.Pointer(cfi))
var dc **C.AVDictionary
if d != nil {
dc = &d.c
}
var cii *C.AVIOInterruptCB = nil
if ii != nil {
cii = &ii.c
}
var c *C.AVIOContext var c *C.AVIOContext
if err := newError(C.avio_open(&c, cfi, C.int(flags))); err != nil { if err := newError(C.avio_open2(&c, cfi, C.int(flags), cii, dc)); err != nil {
return nil, err return nil, err
} }
return newIOContextFromC(c), nil return newIOContextFromC(c), nil

2
io_context_test.go
View File

@@ -56,7 +56,7 @@ func TestIOContext(t *testing.T) {
func TestOpenIOContext(t *testing.T) { func TestOpenIOContext(t *testing.T) {
path := filepath.Join(t.TempDir(), "iocontext.txt") path := filepath.Join(t.TempDir(), "iocontext.txt")
c, err := OpenIOContext(path, NewIOContextFlags(IOContextFlagWrite)) c, err := OpenIOContext(path, NewIOContextFlags(IOContextFlagWrite), nil, nil)
require.NoError(t, err) require.NoError(t, err)
cl := c.Class() cl := c.Class()
require.NotNil(t, cl) require.NotNil(t, cl)