2 files changed, 8 insertions, 0 deletions
diff --git a/src/pad_common.cpp b/src/pad_common.cpp
index 13a96ef..f5da635 100644
--- a/src/pad_common.cpp
+++ b/src/pad_common.cpp
@@ -111,6 +111,13 @@ bool PADPacketizer::QueueFilled() {
     return !queue.empty();
 }
 
+bool PADPacketizer::QueueContainsDG(int apptype_start) {
+    for(std::deque<DATA_GROUP*>::const_iterator it = queue.cbegin(); it != queue.cend(); it++)
+        if((*it)->apptype_start == apptype_start)
+            return true;
+    return false;
+}
+
 pad_t* PADPacketizer::GetPAD() {
     bool pad_flushable = false;
 
diff --git a/src/pad_common.h b/src/pad_common.h
index 5ee2d80..95134bd 100644
--- a/src/pad_common.h
+++ b/src/pad_common.h
@@ -120,6 +120,7 @@ public:
     void AddDG(DATA_GROUP* dg, bool prepend);
     void AddDGs(const std::vector<DATA_GROUP*>& dgs, bool prepend);
     bool QueueFilled();
+    bool QueueContainsDG(int apptype_start);
 
     pad_t* GetPAD();
     void WriteAllPADs(int output_fd, int limit = -1, bool output_sole_fpad = false);