lib: Fix filtering encrypted packets

The frcti_filter was reading raw data from the buffers, causing the
frcti_rcv to operate directly on encrypted packets. It decrypt and
filter for invalid packets. I moved the function from frct to the
fqueue implementation and renamed it fqueue_filter as it filters
fqueues. Should be extended to filter out keepalives on non-FRCT
flows, as these will now still cause spurious wakeups.

Signed-off-by: Dimitri Staessens <dimitri@ouroboros.rocks>
Signed-off-by: Sander Vrijders <sander@ouroboros.rocks>

1 files changed, 0 insertions, 52 deletions

diff --git a/src/lib/frct.c b/src/lib/frct.c
index 2d31e6f2..c9e45ef8 100644
--- a/src/lib/frct.c
+++ b/src/lib/frct.c
@@ -904,55 +904,3 @@ static void __frcti_rcv(struct frcti *       frcti,
         shm_rdrbuff_remove(ai.rdrb, idx);
         return;
 }
-
-/* Filter fqueue events for non-data packets */
-int frcti_filter(struct fqueue * fq)
-{
-        struct shm_du_buff * sdb;
-        int                  fd;
-        ssize_t              idx;
-        struct frcti *       frcti;
-        struct shm_rbuff *   rb;
-
-        while (fq->next < fq->fqsize) {
-                if (fq->fqueue[fq->next + 1] != FLOW_PKT)
-                        return 1;
-
-                pthread_rwlock_rdlock(&ai.lock);
-
-                fd = ai.ports[fq->fqueue[fq->next]].fd;
-                rb = ai.flows[fd].rx_rb;
-                frcti = ai.flows[fd].frcti;
-
-                if (frcti == NULL) {
-                        pthread_rwlock_unlock(&ai.lock);
-                        return 1;
-                }
-
-                if (__frcti_pdu_ready(frcti) >= 0) {
-                        pthread_rwlock_unlock(&ai.lock);
-                        return 1;
-                }
-
-                idx = shm_rbuff_read(rb);
-                if (idx < 0) {
-                        pthread_rwlock_unlock(&ai.lock);
-                        return 0;
-                }
-
-                sdb = shm_rdrbuff_get(ai.rdrb, idx);
-
-                __frcti_rcv(frcti, sdb);
-
-                if (__frcti_pdu_ready(frcti) >= 0) {
-                        pthread_rwlock_unlock(&ai.lock);
-                        return 1;
-                }
-
-                pthread_rwlock_unlock(&ai.lock);
-
-                fq->next += 2;
-        }
-
-        return fq->next < fq->fqsize;
-}