+/*
+ * kconsumerd_find_session_fd
+ *
+ * Find a session fd in the global list.
+ *
+ * Return 1 if found else 0
+ */
+static int kconsumerd_find_session_fd(int fd)
+{
+ struct kconsumerd_fd *iter;
+
+ pthread_mutex_lock(&kconsumerd_lock_fds);
+ cds_list_for_each_entry(iter, &kconsumerd_fd_list.head, list) {
+ if (iter->sessiond_fd == fd) {
+ DBG("Duplicate session fd %d", fd);
+ pthread_mutex_unlock(&kconsumerd_lock_fds);
+ return 1;
+ }
+ }
+ pthread_mutex_unlock(&kconsumerd_lock_fds);
+
+ return 0;
+}
+