msgsnd linux内核源码求救

qianhulou

各位大侠:
          小弟在研究消息队列源码中 看sys_msgsnd ->do_msgsnd 中遇到err = security_msg_queue_msgsnd(msq, msg, msgflg); 这个函数 ,请问这个函数的源码在哪里啊 我找了半天都没有找到 , 就找到一个 cap_security_msg_queue_msgsnd(...) { return 0; }; 我感觉这里是整个函数最重要的地方  怎么就没有下文了呢, 各位大侠指点指点啊 小弟先谢了
long do_msgsnd(int msqid, long mtype, void __user *mtext,
                size_t msgsz, int msgflg)
{
        struct msg_queue *msq;
        struct msg_msg *msg;
        int err;
        struct ipc_namespace *ns;

        ns = current->nsproxy->ipc_ns;

        if (msgsz > ns->msg_ctlmax || (long) msgsz < 0 || msqid < 0)
                return -EINVAL;
        if (mtype < 1)
                return -EINVAL;

        msg = load_msg(mtext, msgsz);
        if (IS_ERR(msg))
                return PTR_ERR(msg);

        msg->m_type = mtype;
        msg->m_ts = msgsz;

        msq = msg_lock_check(ns, msqid);
        if (IS_ERR(msq)) {
                err = PTR_ERR(msq);
                goto out_free;
        }

        for (; {
                struct msg_sender s;

                err = -EACCES;
                if (ipcperms(&msq->q_perm, S_IWUGO))
                        goto out_unlock_free;

                err = security_msg_queue_msgsnd(msq, msg, msgflg);                if (err)
                        goto out_unlock_free;

                if (msgsz + msq->q_cbytes <= msq->q_qbytes &&
                                1 + msq->q_qnum <= msq->q_qbytes) {
                        break;
                }

                /* queue full, wait: */
                if (msgflg & IPC_NOWAIT) {
                        err = -EAGAIN;
                        goto out_unlock_free;
                }
                ss_add(msq, &s);
                ipc_rcu_getref(msq);
                msg_unlock(msq);
                schedule();

                ipc_lock_by_ptr(&msq->q_perm);
                ipc_rcu_putref(msq);
                if (msq->q_perm.deleted) {
                        err = -EIDRM;
                        goto out_unlock_free;
                }
                ss_del(&s);

                if (signal_pending(current)) {
                        err = -ERESTARTNOHAND;
                        goto out_unlock_free;
                }
        }

        msq->q_lspid = task_tgid_vnr(current);
        msq->q_stime = get_seconds();

        if (!pipelined_send(msq, msg)) {
                /* noone is waiting for this message, enqueue it */
                list_add_tail(&msg->m_list, &msq->q_messages);
                msq->q_cbytes += msgsz;
                msq->q_qnum++;
                atomic_add(msgsz, &ns->msg_bytes);
                atomic_inc(&ns->msg_hdrs);
        }

        err = 0;
        msg = NULL;

out_unlock_free:
        msg_unlock(msq);
out_free:
        if (msg != NULL)
                free_msg(msg);
        return err;
}

还有 看这个源码主要是为了验证 msgsnd是否是线程安全函数  , 从代码上看 我认为是线程安全函数 , 而且 发送的过程 与写文件, SOCKET不同, 应该是判断空间够 一次写入的 (猜想...)

amarant

你是用什么工具看源码的？

qianhulou

SourceInsight

cores_cu

你看的是哪个版本的内核？

qianhulou

不是最新的 好象是比最新的低一个 现在最新的是.7 我的是.6

qianhulou

大侠 指点指点啊  我找不到后续代码了

kouu

LZ，看完这整个函数，你觉得还缺些什么东西没有实现呢？为什么会感觉security_msg_queue_msgsnd是整个函数中最重要的地方呢？

security_打头的函数大多是为linux security module留的钩子，可以通过这些钩子来扩展一些安全性检查。如果不需要安全性扩展，那么这些函数什么都不做。

qianhulou

呵呵 谢谢楼上的 你的留言很给力 我一直以为 security_msg_queue_msgsnd 这个函数负责把msg_msg 跟msg_queue联系起来, 现在看应该是pipelined_send 做的 , 是不是啊