linux-imx

/*

 * POSIX message queues filesystem for Linux.

 *

 * Copyright (C) 2003,2004  Krzysztof Benedyczak    (golbi@mat.uni.torun.pl)

 *                          Michal Wronski          (michal.wronski@gmail.com)

 *

 * Spinlocks:               Mohamed Abbas           (abbas.mohamed@intel.com)

 * Lockless receive & send, fd based notify:

 *              Manfred Spraul      (manfred@colorfullife.com)

 *

 * Audit:                   George Wilson           (ltcgcw@us.ibm.com)

 *

 * This file is released under the GPL.

 */

​

#include <linux/capability.h>

#include <linux/init.h>

#include <linux/pagemap.h>

#include <linux/file.h>

#include <linux/mount.h>

#include <linux/fs_context.h>

#include <linux/namei.h>

#include <linux/sysctl.h>

#include <linux/poll.h>

#include <linux/mqueue.h>

#include <linux/msg.h>

#include <linux/skbuff.h>

#include <linux/vmalloc.h>

#include <linux/netlink.h>

#include <linux/syscalls.h>

#include <linux/audit.h>

#include <linux/signal.h>

#include <linux/mutex.h>

#include <linux/nsproxy.h>

#include <linux/pid.h>

#include <linux/ipc_namespace.h>

#include <linux/user_namespace.h>

#include <linux/slab.h>

#include <linux/sched/wake_q.h>

#include <linux/sched/signal.h>

#include <linux/sched/user.h>

​

#include <net/sock.h>

#include "util.h"

​

struct mqueue_fs_context {

    struct ipc_namespace    *ipc_ns;

};

​

#define MQUEUE_MAGIC    0x19800202

#define DIRENT_SIZE 20

#define FILENT_SIZE 80

​

#define SEND        0

#define RECV        1

​

#define STATE_NONE  0

#define STATE_READY 1

​

struct posix_msg_tree_node {

    struct rb_node      rb_node;

    struct list_head    msg_list;

    int         priority;

};

​

struct ext_wait_queue {     /* queue of sleeping tasks */

    struct task_struct *task;

    struct list_head list;

    struct msg_msg *msg;    /* ptr of loaded message */

    int state;      /* one of STATE_* values */

};

​

struct mqueue_inode_info {

    spinlock_t lock;

    struct inode vfs_inode;

    wait_queue_head_t wait_q;

​

    struct rb_root msg_tree;

    struct posix_msg_tree_node *node_cache;

    struct mq_attr attr;

​

    struct sigevent notify;

    struct pid *notify_owner;

    struct user_namespace *notify_user_ns;

    struct user_struct *user;   /* user who created, for accounting */

    struct sock *notify_sock;

    struct sk_buff *notify_cookie;

​

    /* for tasks waiting for free space and messages, respectively */

    struct ext_wait_queue e_wait_q[2];

​

    unsigned long qsize; /* size of queue in memory (sum of all msgs) */