X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=VNFs%2FDPPD-PROX%2Finput.c;h=5eb5e4ce1383c49773aa12c7391d18370d385006;hb=974e4b3123b7d926d548d8924b41e8b732e2732f;hp=bb956bcda57f38013c2973e7b002ee0dfad6433c;hpb=a0eb3c45ca8a89220caaefa43665a7a1eb6c1933;p=samplevnf.git

diff --git a/VNFs/DPPD-PROX/input.c b/VNFs/DPPD-PROX/input.c
index bb956bcd..5eb5e4ce 100644
--- a/VNFs/DPPD-PROX/input.c
+++ b/VNFs/DPPD-PROX/input.c
@@ -74,6 +74,33 @@ static int tsc_diff_to_tv(uint64_t beg, uint64_t end, struct timeval *tv)
 	return 0;
 }
 
+void input_proc(void)
+{
+	struct timeval tv;
+	fd_set in_fd;
+	int ret = 1;
+
+	tv.tv_sec = 0;
+	tv.tv_usec = 0;
+	while (ret != 0) {
+		FD_ZERO(&in_fd);
+
+		for (int i = 0; i < n_inputs; ++i) {
+			FD_SET(inputs[i]->fd, &in_fd);
+		}
+
+		ret = select(max_input_fd + 1, &in_fd, NULL, NULL, &tv);
+
+		if (ret > 0) {
+			for (int i = 0; i < n_inputs; ++i) {
+				if (FD_ISSET(inputs[i]->fd, &in_fd)) {
+					inputs[i]->proc_input(inputs[i]);
+				}
+			}
+		}
+	}
+}
+
 void input_proc_until(uint64_t deadline)
 {
 	struct timeval tv;