Schedule decoder.new() on dirtyio scheduler. Exlude tests when running on GPU

Author: root

native/vkvideo_decoder/src/lib.rs

@@ -22,7 +22,7 @@ fn load(env: Env, _: Term) -> bool {
     rustler::resource!(DecoderResource, env)
 }
 
-#[rustler::nif]
+#[rustler::nif(schedule = "DirtyIo")]
 fn new() -> Result<(Atom, ResourceArc<DecoderResource>), Error> {
     let instance = vk_video::VulkanInstance::new()
         .map_err(|_| Error::Term(Box::new(vk_instance_creation_failure())))?;

test/decoder_native_test.exs

@@ -2,6 +2,7 @@ defmodule Decoder.NativeTest do
   use ExUnit.Case, async: true
   alias Membrane.VKVideo.Decoder.Native
 
+  @tag :requires_gpu
   test "Decoder decoded H.264 stream" do
     in_path = "./fixtures/input-100.h264" |> Path.expand(__DIR__)
 

test/decoder_test.exs

@@ -8,6 +8,7 @@ defmodule Decoder.Test do
   @frame_duration_ms div(1000, @framerate_numerator)
 
   describe "Decoder decodes" do
+    @tag :requires_gpu
     test "one hundred H.264 frames with B-frames in presentation order" do
       in_path = "./fixtures/input-100.h264" |> Path.expand(__DIR__)
 
@@ -41,6 +42,7 @@ defmodule Decoder.Test do
     end
 
     @tag :tmp_dir
+    @tag :requires_gpu
     test "ten H.264 frames", ctx do
       in_path = "./fixtures/input-10.h264" |> Path.expand(__DIR__)
       out_path = Path.join(ctx.tmp_dir, "out.nv12")

test/test_helper.exs

@@ -1,6 +1,6 @@
 opts =
   if System.get_env("CIRCLECI") == "true" do
-    [capture_log: true, include: :doesnt_require_gpu]
+    [capture_log: true, exclude: [requires_gpu: true]]
   else
     [capture_log: true]
   end