update

src/ioctx.cc

@@ -35,15 +35,6 @@ bool InOutCtx::isReady() noexcept {
 //                                   InCtx                                   //
 ///////////////////////////////////////////////////////////////////////////////
 
-InCtx::InCtx(std::string path, CustomProto proto):
-    InOutCtx(path, proto) {
-
-    // FIXME: Build AVIOContex for custom proto
-    AVIOContext *customIO = nullptr;
-
-    fmt = Utils::makeInAVFormat(path, customIO);
-}
-
 void InCtx::readFrame(AVPacket *packet) {
     if (av_read_frame(fmt.get(), packet) < 0)
         throw END_OF_FILE();

src/ioctx.h

@@ -41,7 +41,7 @@ enum IOCTX_ERROR {
 
 using StreamPrediction = std::function<bool(AVStream*)>;
 
-template<typename T>
+
 class InOutCtx {
 public:
     InOutCtx(std::string path, bool isCustom):
@@ -52,6 +52,7 @@ public:
 protected:
     Utils::AVFormatContextShared fmt;
     std::string path;
+    bool isCustomIO;
 };
 
 

src/proto/proto.h

@@ -29,15 +29,15 @@ public:
         name(name), flag(flag), io(nullptr), priv(priv) {}
 
     int read_packet(void *priv, uint8_t *buf, int bufSize) {
-        static_cast<T*>(this)->read_packet_internal(priv, buf, bufSize);
+        return static_cast<T*>(this)->read_packet_internal(priv, buf, bufSize);
     }
 
     int write_packet(void *priv, uint8_t *buf, int bufSize) {
-        static_cast<T*>(this)->write_packet_internal(priv, buf, bufSize);
+        return static_cast<T*>(this)->write_packet_internal(priv, buf, bufSize);
     }
 
     int64_t seek_packet(void *opaque, int64_t offset, int whence) {
-        static_cast<T*>(this)->seek_packet_internal(opaque, offset, whence);
+        return static_cast<T*>(this)->seek_packet_internal(opaque, offset, whence);
     }
 
     AVIOContext* to_avioctx() noexcept {