mqueue.c 文件参考

浏览源代码.

函数
STATIC INLINE INT32	MqNameCheck (const CHAR *mqName)
STATIC INLINE UINT32	GetMqueueCBByID (UINT32 queueID, LosQueueCB **queueCB)
STATIC INLINE struct mqarray *	GetMqueueCBByName (const CHAR *name)
STATIC INT32	DoMqueueDelete (struct mqarray *mqueueCB)
STATIC int	SaveMqueueName (const CHAR *mqName, struct mqarray *mqueueCB)
STATIC struct mqpersonal *	DoMqueueCreate (const struct mq_attr *attr, const CHAR *mqName, INT32 openFlag, UINT32 mode)
STATIC struct mqpersonal *	DoMqueueOpen (struct mqarray *mqueueCB, INT32 openFlag)
STATIC INT32	DoMqueueClose (struct mqpersonal *privateMqPersonal)
STATIC struct mqpersonal *	MqGetPrivDataBuff (mqd_t personal)
STATIC INT32	MqAllocSysFd (int maxfdp, struct mqpersonal *privateMqPersonal)
STATIC VOID	MqFreeSysFd (mqd_t personal)
void	MqueueRefer (int sysFd)
STATIC INT32	MqTryClose (struct mqpersonal *privateMqPersonal)
STATIC INT32	MqueueModeAnalysisSet (struct mqpersonal *privateMqPersonal)
STATIC INT32	GetPermissionOfVisitor (struct mqarray *mqueueCB)
STATIC INT32	GetMqueueAttr (struct mq_attr *defaultAttr, struct mq_attr *attr)
mqd_t	mq_open (const char *mqName, int openFlag,...)
int	mq_close (mqd_t personal)
int	OsMqGetAttr (mqd_t personal, struct mq_attr *mqAttr)
int	OsMqSetAttr (mqd_t personal, const struct mq_attr *mqSetAttr, struct mq_attr *mqOldAttr)
int	mq_getsetattr (mqd_t mqd, const struct mq_attr *new, struct mq_attr *old)
int	mq_unlink (const char *mqName)
STATIC INT32	ConvertTimeout (long flags, const struct timespec *absTimeout, UINT64 *ticks)
STATIC INLINE BOOL	MqParamCheck (mqd_t personal, const char *msg, size_t msgLen)
static void	MqSendNotify (struct mqarray *mqueueCB)
int	mq_timedsend (mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio, const struct timespec *absTimeout)
ssize_t	mq_timedreceive (mqd_t personal, char *msg, size_t msgLen, unsigned int *msgPrio, const struct timespec *absTimeout)
int	mq_send (mqd_t personal, const char *msg_ptr, size_t msg_len, unsigned int msg_prio)
ssize_t	mq_receive (mqd_t personal, char *msg_ptr, size_t msg_len, unsigned int *msg_prio)
STATIC INLINE BOOL	MqNotifyParamCheck (mqd_t personal, const struct sigevent *sigev)
int	OsMqNotify (mqd_t personal, const struct sigevent *sigev)

变量
STATIC fd_set	g_queueFdSet
STATIC struct mqarray	g_queueTable [LOSCFG_BASE_IPC_QUEUE_LIMIT]
STATIC pthread_mutex_t	g_mqueueMutex = PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP
STATIC struct mqpersonal *	g_mqPrivBuf [MAX_MQ_FD]

函数说明

ConvertTimeout()

STATIC INT32 ConvertTimeout	(	long	flags,
		const struct timespec *	absTimeout,
		UINT64 *	ticks
	)

在文件 mqueue.c 第 686 行定义.

{
    if ((UINT32)flags & (UINT32)FNONBLOCK) {
        *ticks = LOS_NO_WAIT;
        return 0;
    }
 
    if (absTimeout == NULL) {
        *ticks = LOS_WAIT_FOREVER;
        return 0;
    }
 
    if (!ValidTimeSpec(absTimeout)) {
        errno = EINVAL;
        return -1;
    }
 
    *ticks = OsTimeSpec2Tick(absTimeout);
    return 0;
}

函数调用图:

这是这个函数的调用关系图:

DoMqueueClose()

STATIC INT32 DoMqueueClose

(

struct mqpersonal *

privateMqPersonal

)

在文件 mqueue.c 第 251 行定义.

{
    struct mqarray *mqueueCB = NULL;
    struct mqpersonal *tmp = NULL;
 
    mqueueCB = privateMqPersonal->mq_posixdes;
    if (mqueueCB == NULL || mqueueCB->mq_personal == NULL) {
        errno = EBADF;
        return LOS_NOK;
    }
 
    /* find the personal and remove */
    if (mqueueCB->mq_personal == privateMqPersonal) {
        mqueueCB->mq_personal = privateMqPersonal->mq_next;
    } else {
        for (tmp = mqueueCB->mq_personal; tmp->mq_next != NULL; tmp = tmp->mq_next) {
            if (tmp->mq_next == privateMqPersonal) {
                break;
            }
        }
        if (tmp->mq_next == NULL) {
            errno = EBADF;
            return LOS_NOK;
        }
        tmp->mq_next = privateMqPersonal->mq_next;
    }
    /* flag no use */
    privateMqPersonal->mq_status = 0;
 
    /* free the personal */
    (VOID)LOS_MemFree(OS_SYS_MEM_ADDR, privateMqPersonal);
 
    if ((mqueueCB->unlinkflag == TRUE) && (mqueueCB->mq_personal == NULL)) {
        return DoMqueueDelete(mqueueCB);
    }
    return LOS_OK;
}

函数调用图:

这是这个函数的调用关系图:

DoMqueueCreate()

STATIC struct mqpersonal * DoMqueueCreate	(	const struct mq_attr *	attr,
		const CHAR *	mqName,
		INT32	openFlag,
		UINT32	mode
	)

在文件 mqueue.c 第 163 行定义.

{
    struct mqarray *mqueueCB = NULL;
    UINT32 mqueueID;
 
    UINT32 err = LOS_QueueCreate(NULL, attr->mq_maxmsg, &mqueueID, 0, attr->mq_msgsize);
    if (map_errno(err) != ENOERR) {
        goto ERROUT;
    }
 
    if (g_queueTable[GET_QUEUE_INDEX(mqueueID)].mqcb == NULL) {
        mqueueCB = &(g_queueTable[GET_QUEUE_INDEX(mqueueID)]);
        mqueueCB->mq_id = mqueueID;
    }
 
    if (mqueueCB == NULL) {
        errno = EINVAL;
        goto ERROUT;
    }
 
    if (SaveMqueueName(mqName, mqueueCB) != LOS_OK) {
        goto ERROUT;
    }
 
    if (GetMqueueCBByID(mqueueCB->mq_id, &(mqueueCB->mqcb)) != LOS_OK) {
        errno = ENOSPC;
        goto ERROUT;
    }
 
    mqueueCB->mq_personal = (struct mqpersonal *)LOS_MemAlloc(OS_SYS_MEM_ADDR, sizeof(struct mqpersonal));
    if (mqueueCB->mq_personal == NULL) {
        (VOID)LOS_QueueDelete(mqueueCB->mq_id);
        mqueueCB->mqcb->queueHandle = NULL;
        mqueueCB->mqcb = NULL;
        errno = ENOSPC;
        goto ERROUT;
    }
 
    mqueueCB->unlinkflag = FALSE;
    mqueueCB->unlink_ref = 0;
    mqueueCB->mq_personal->mq_status = MQ_USE_MAGIC;
    mqueueCB->mq_personal->mq_next = NULL;
    mqueueCB->mq_personal->mq_posixdes = mqueueCB;
    mqueueCB->mq_personal->mq_flags = (INT32)((UINT32)openFlag | ((UINT32)attr->mq_flags & (UINT32)FNONBLOCK));
    mqueueCB->mq_personal->mq_mode = mode;
    mqueueCB->mq_personal->mq_refcount = 0;
    mqueueCB->mq_notify.pid = 0;
 
    return mqueueCB->mq_personal;
ERROUT:
 
    if ((mqueueCB != NULL) && (mqueueCB->mq_name != NULL)) {
        LOS_MemFree(OS_SYS_MEM_ADDR, mqueueCB->mq_name);
        mqueueCB->mq_name = NULL;
    }
    return (struct mqpersonal *)-1;
}

函数调用图:

这是这个函数的调用关系图:

DoMqueueDelete()

STATIC INT32 DoMqueueDelete

(

struct mqarray *

mqueueCB

)

在文件 mqueue.c 第 110 行定义.

{
    UINT32 ret;
 
    if (mqueueCB->mq_name != NULL) {
        LOS_MemFree(OS_SYS_MEM_ADDR, mqueueCB->mq_name);
        mqueueCB->mq_name = NULL;
    }
 
    mqueueCB->mqcb = NULL;
    /* When mqueue-list head node needed free ,reset the mode_data */
    mqueueCB->mode_data.data = 0;
    mqueueCB->euid = -1;
    mqueueCB->egid = -1;
    mqueueCB->mq_notify.pid = 0;
 
    ret = LOS_QueueDelete(mqueueCB->mq_id);
    switch (ret) {
        case LOS_OK:
            return 0;
        case LOS_ERRNO_QUEUE_NOT_FOUND:
        case LOS_ERRNO_QUEUE_NOT_CREATE:
        case LOS_ERRNO_QUEUE_IN_TSKUSE:
        case LOS_ERRNO_QUEUE_IN_TSKWRITE:
            errno = EAGAIN;
            return -1;
        default:
            errno = EINVAL;
            return -1;
    }
}

函数调用图:

这是这个函数的调用关系图:

DoMqueueOpen()

STATIC struct mqpersonal * DoMqueueOpen	(	struct mqarray *	mqueueCB,
		INT32	openFlag
	)

在文件 mqueue.c 第 221 行定义.

{
    struct mqpersonal *privateMqPersonal = NULL;
 
    /* already have the same name of g_squeuetable */
    if (mqueueCB->unlinkflag == TRUE) {
        errno = EINVAL;
        goto ERROUT;
    }
    /* alloc mqprivate and add to mqarray */
    privateMqPersonal = (struct mqpersonal *)LOS_MemAlloc(OS_SYS_MEM_ADDR, sizeof(struct mqpersonal));
    if (privateMqPersonal == NULL) {
        errno = ENOSPC;
        goto ERROUT;
    }
 
    privateMqPersonal->mq_next = mqueueCB->mq_personal;
    mqueueCB->mq_personal = privateMqPersonal;
 
    privateMqPersonal->mq_posixdes = mqueueCB;
    privateMqPersonal->mq_flags = openFlag;
    privateMqPersonal->mq_status = MQ_USE_MAGIC;
    privateMqPersonal->mq_refcount = 0;
 
    return privateMqPersonal;
 
ERROUT:
    return (struct mqpersonal *)-1;
}

函数调用图:

这是这个函数的调用关系图:

GetMqueueAttr()

STATIC INT32 GetMqueueAttr	(	struct mq_attr *	defaultAttr,
		struct mq_attr *	attr
	)

在文件 mqueue.c 第 470 行定义.

{
    if (attr != NULL) {
        if (LOS_ArchCopyFromUser(defaultAttr, attr, sizeof(struct mq_attr))) {
            errno = EFAULT;
            return -1;
        }
        if ((defaultAttr->mq_maxmsg < 0) || (defaultAttr->mq_maxmsg > (long int)USHRT_MAX) ||
            (defaultAttr->mq_msgsize < 0) || (defaultAttr->mq_msgsize > (long int)(USHRT_MAX - sizeof(UINT32)))) {
            errno = EINVAL;
            return -1;
        }
    }
    return 0;
}

函数调用图:

这是这个函数的调用关系图:

GetMqueueCBByID()

STATIC INLINE UINT32 GetMqueueCBByID	(	UINT32	queueID,
		LosQueueCB **	queueCB
	)

在文件 mqueue.c 第 77 行定义.

{
    LosQueueCB *tmpQueueCB = NULL;
    if (queueCB == NULL) {
        errno = EINVAL;
        return LOS_ERRNO_QUEUE_READ_PTR_NULL;
    }
    tmpQueueCB = GET_QUEUE_HANDLE(queueID);
    if ((GET_QUEUE_INDEX(queueID) >= LOSCFG_BASE_IPC_QUEUE_LIMIT) || (tmpQueueCB->queueID != queueID)) {
        return LOS_ERRNO_QUEUE_INVALID;
    }
    *queueCB = tmpQueueCB;
 
    return LOS_OK;
}

这是这个函数的调用关系图:

GetMqueueCBByName()

STATIC INLINE struct mqarray * GetMqueueCBByName

(

const CHAR *

name

)

在文件 mqueue.c 第 93 行定义.

{
    UINT32 index;
    UINT32 mylen = strlen(name);
 
    for (index = 0; index < LOSCFG_BASE_IPC_QUEUE_LIMIT; index++) {
        if ((g_queueTable[index].mq_name == NULL) || (strlen(g_queueTable[index].mq_name) != mylen)) {
            continue;
        }
 
        if (strncmp(name, (const CHAR *)(g_queueTable[index].mq_name), mylen) == 0) {
            return &(g_queueTable[index]);
        }
    }
    return NULL;
}

这是这个函数的调用关系图:

GetPermissionOfVisitor()

STATIC INT32 GetPermissionOfVisitor

(

struct mqarray *

mqueueCB

)

在文件 mqueue.c 第 425 行定义.

{
    uid_t euid;
    gid_t egid;
    UINT32 intSave;
    User *user = NULL;
 
    if (mqueueCB == NULL) {
        errno = ENOENT;
        return -EPERM;
    }
 
    /* Get the visitor process euid and egid */
    SCHEDULER_LOCK(intSave);
    user = OsCurrUserGet();
    euid = user->effUserID;
    egid = user->effGid;
    SCHEDULER_UNLOCK(intSave);
 
    /* root */
    if (euid == 0) {
        return ENOERR;
    }
    if (euid == mqueueCB->euid) { /* usr */
        if (!((mqueueCB->mode_data.usr & S_IRUSR) || (mqueueCB->mode_data.usr & S_IWUSR))) {
            errno = EACCES;
            goto ERR_OUT;
        }
    } else if (egid == mqueueCB->egid) { /* grp */
        if (!((mqueueCB->mode_data.grp & S_IRGRP) || (mqueueCB->mode_data.grp & S_IWGRP))) {
            errno = EACCES;
            goto ERR_OUT;
        }
    } else { /* oth */
        if (!((mqueueCB->mode_data.oth & S_IROTH) || (mqueueCB->mode_data.oth & S_IWOTH))) {
            errno = EACCES;
            goto ERR_OUT;
        }
    }
    return ENOERR;
 
ERR_OUT:
    return -EPERM;
}

函数调用图:

这是这个函数的调用关系图:

MqAllocSysFd()

STATIC INT32 MqAllocSysFd	(	int	maxfdp,
		struct mqpersonal *	privateMqPersonal
	)

Alloc sysFd, storage mq private data, set using bit.

参数

maxfdp	Maximum allowed application of mqueue sysFd.
fdset	Mqueue sysFd bit map.
privateMqPersonal	Private data.

返回

the index of the new fd; -1 on error

在文件 mqueue.c 第 311 行定义.

{
    INT32 i;
    fd_set *fdset = &g_queueFdSet;
    for (i = 0; i < maxfdp; i++) {
        /* sysFd: used bit setting, and get the index of swtmrID buffer */
        if (fdset && !(FD_ISSET(i + MQUEUE_FD_OFFSET, fdset))) {
            FD_SET(i + MQUEUE_FD_OFFSET, fdset);
            if (!g_mqPrivBuf[i]) {
                g_mqPrivBuf[i] = privateMqPersonal;
                return i + MQUEUE_FD_OFFSET;
            }
        }
    }
    return -1;
}

这是这个函数的调用关系图:

MqFreeSysFd()

STATIC VOID MqFreeSysFd

(

mqd_t

personal

)

在文件 mqueue.c 第 328 行定义.

{
    INT32 sysFd = (INT32)personal;
    fd_set *fdset = &g_queueFdSet;
    if (fdset && FD_ISSET(sysFd, fdset)) {
        FD_CLR(sysFd, fdset);
        g_mqPrivBuf[sysFd - MQUEUE_FD_OFFSET] = NULL;
    }
}

这是这个函数的调用关系图:

MqGetPrivDataBuff()

STATIC struct mqpersonal * MqGetPrivDataBuff

(

mqd_t

personal

)

在文件 mqueue.c 第 290 行定义.

{
    INT32 sysFd = (INT32)personal;
    INT32 id = sysFd - MQUEUE_FD_OFFSET;
 
    /* Filter illegal id */
    if ((id < 0) || (id >= MAX_MQ_FD)) {
        errno = EBADF;
        return NULL;
    }
    return g_mqPrivBuf[id];
}

这是这个函数的调用关系图:

MqNameCheck()

STATIC INLINE INT32 MqNameCheck

(

const CHAR *

mqName

)

在文件 mqueue.c 第 58 行定义.

{
    if (mqName == NULL) {
        errno = EINVAL;
        return -1;
    }
 
    if (strlen(mqName) == 0) {
        errno = EINVAL;
        return -1;
    }
 
    if (strlen(mqName) > (PATH_MAX - 1)) {
        errno = ENAMETOOLONG;
        return -1;
    }
    return 0;
}

这是这个函数的调用关系图:

MqNotifyParamCheck()

STATIC INLINE BOOL MqNotifyParamCheck	(	mqd_t	personal,
		const struct sigevent *	sigev
	)

在文件 mqueue.c 第 868 行定义.

{
    if (personal < 0) {
        errno = EBADF;
        goto ERROUT;
    }
 
    if (sigev != NULL) {
        if (sigev->sigev_notify != SIGEV_NONE && sigev->sigev_notify != SIGEV_SIGNAL) {
            errno = EINVAL;
            goto ERROUT;
        }
        if (sigev->sigev_notify == SIGEV_SIGNAL && !GOOD_SIGNO(sigev->sigev_signo)) {
            errno = EINVAL;
            goto ERROUT;
        }
    }
 
    return TRUE;
ERROUT:
    return FALSE;
}

函数调用图:

这是这个函数的调用关系图:

MqParamCheck()

STATIC INLINE BOOL MqParamCheck	(	mqd_t	personal,
		const char *	msg,
		size_t	msgLen
	)

在文件 mqueue.c 第 707 行定义.

{
    if (personal < 0) {
        return FALSE;
    }
 
    if ((msg == NULL) || (msgLen == 0)) {
        errno = EINVAL;
        return FALSE;
    }
    return TRUE;
}

这是这个函数的调用关系图:

MqSendNotify()

static void MqSendNotify ( struct mqarray *  mqueueCB )

static

在文件 mqueue.c 第 724 行定义.

{
    struct mqnotify *mqnotify = &mqueueCB->mq_notify;
 
    if ((mqnotify->pid) && (mqueueCB->mqcb->readWriteableCnt[OS_QUEUE_READ] == 0)) {
        siginfo_t info;
 
        switch (mqnotify->notify.sigev_notify) {
            case SIGEV_SIGNAL:
                /* sends signal */
                /* Create the siginfo structure */
                info.si_signo = mqnotify->notify.sigev_signo;
                info.si_code = SI_MESGQ;
                info.si_value = mqnotify->notify.sigev_value;
                OsDispatch(mqnotify->pid, &info, OS_USER_KILL_PERMISSION);
                break;
            case SIGEV_NONE:
            default:
                break;
        }
        /* after notification unregisters process */
        mqnotify->pid = 0;
    }
}

函数调用图:

这是这个函数的调用关系图:

MqTryClose()

STATIC INT32 MqTryClose

(

struct mqpersonal *

privateMqPersonal

)

在文件 mqueue.c 第 361 行定义.

{
    struct mqarray *mqueueCB = NULL;
    mqueueCB = privateMqPersonal->mq_posixdes;
    if (mqueueCB == NULL) {
        errno = ENFILE;
        return false;
    }
 
    if (privateMqPersonal->mq_refcount == 0) {
        return TRUE;
    }
    privateMqPersonal->mq_refcount--;
    return FALSE;
}

这是这个函数的调用关系图:

MqueueModeAnalysisSet()

STATIC INT32 MqueueModeAnalysisSet

(

struct mqpersonal *

privateMqPersonal

)

在文件 mqueue.c 第 378 行定义.

{
    UINT32 mode;
    UINT32 intSave;
    User *user = NULL;
    struct mqarray *mqueueCB = NULL;
 
    if ((INT32)(UINTPTR)privateMqPersonal < 0) {
        return -1;
    }
    /* Get mqueueCB of first time creating mqueue */
    mqueueCB = privateMqPersonal->mq_posixdes;
    if (mqueueCB == NULL) {
        errno = ENFILE;
        return -1;
    }
 
    mode = mqueueCB->mq_personal->mq_mode;
    /* Set mqueue gid uid */
    SCHEDULER_LOCK(intSave);
    user = OsCurrUserGet();
    mqueueCB->euid = user->effUserID;
    mqueueCB->egid = user->effGid;
    SCHEDULER_UNLOCK(intSave);
 
    /* Set mode data bit */
    if (mode & S_IRUSR) {
        mqueueCB->mode_data.usr |= S_IRUSR;
    }
    if (mode & S_IWUSR) {
        mqueueCB->mode_data.usr |= S_IWUSR;
    }
    if (mode & S_IRGRP) {
        mqueueCB->mode_data.grp |= S_IRGRP;
    }
    if (mode & S_IWGRP) {
        mqueueCB->mode_data.grp |= S_IWGRP;
    }
    if (mode & S_IROTH) {
        mqueueCB->mode_data.oth |= S_IROTH;
    }
    if (mode & S_IWOTH) {
        mqueueCB->mode_data.oth |= S_IWOTH;
    }
    return 0;
}

函数调用图:

这是这个函数的调用关系图:

MqueueRefer()

void MqueueRefer

(

int

sysFd

)

在文件 mqueue.c 第 339 行定义.

{
    struct mqarray *mqueueCB = NULL;
    struct mqpersonal *privateMqPersonal = NULL;
 
    (VOID)pthread_mutex_lock(&g_mqueueMutex);
    /* Get the personal sysFd and reset personal fd -1 */
    privateMqPersonal = MqGetPrivDataBuff((mqd_t)sysFd);
    if (privateMqPersonal == NULL) {
        goto OUT_UNLOCK;
    }
    mqueueCB = privateMqPersonal->mq_posixdes;
    if (mqueueCB == NULL) {
        goto OUT_UNLOCK;
    }
 
    privateMqPersonal->mq_refcount++;
OUT_UNLOCK:
    (VOID)pthread_mutex_unlock(&g_mqueueMutex);
    return;
}

函数调用图:

这是这个函数的调用关系图:

OsMqGetAttr()

int OsMqGetAttr	(	mqd_t	personal,
		struct mq_attr *	mqAttr
	)

在文件 mqueue.c 第 584 行定义.

{
    struct mqarray *mqueueCB = NULL;
    struct mqpersonal *privateMqPersonal = NULL;
 
    privateMqPersonal = MqGetPrivDataBuff(personal);
    if (privateMqPersonal == NULL) {
        return -1;
    }
 
    if (mqAttr == NULL) {
        errno = EINVAL;
        return -1;
    }
 
    (VOID)pthread_mutex_lock(&g_mqueueMutex);
    if (privateMqPersonal->mq_status != MQ_USE_MAGIC) {
        errno = EBADF;
        (VOID)pthread_mutex_unlock(&g_mqueueMutex);
        return -1;
    }
 
    mqueueCB = privateMqPersonal->mq_posixdes;
    mqAttr->mq_maxmsg = mqueueCB->mqcb->queueLen;
    mqAttr->mq_msgsize = mqueueCB->mqcb->queueSize - sizeof(UINT32);
    mqAttr->mq_curmsgs = mqueueCB->mqcb->readWriteableCnt[OS_QUEUE_READ];
    mqAttr->mq_flags = privateMqPersonal->mq_flags;
    (VOID)pthread_mutex_unlock(&g_mqueueMutex);
    return 0;
}

函数调用图:

这是这个函数的调用关系图:

OsMqNotify()

int OsMqNotify	(	mqd_t	personal,
		const struct sigevent *	sigev
	)

在文件 mqueue.c 第 891 行定义.

{
    struct mqarray *mqueueCB = NULL;
    struct mqnotify *mqnotify = NULL;
    struct mqpersonal *privateMqPersonal = NULL;
 
    if (!MqNotifyParamCheck(personal, sigev)) {
        goto ERROUT;
    }
 
    (VOID)pthread_mutex_lock(&g_mqueueMutex);
    privateMqPersonal = MqGetPrivDataBuff(personal);
    if (privateMqPersonal == NULL) {
        goto OUT_UNLOCK;
    }
 
    if (privateMqPersonal->mq_status != MQ_USE_MAGIC) {
        errno = EBADF;
        goto OUT_UNLOCK;
    }
 
    mqueueCB = privateMqPersonal->mq_posixdes;
    mqnotify = &mqueueCB->mq_notify;
 
    if (sigev == NULL) {
        if (mqnotify->pid == LOS_GetCurrProcessID()) {
            mqnotify->pid = 0;
        }
    } else if (mqnotify->pid != 0) {
        errno = EBUSY;
        goto OUT_UNLOCK;
    } else {
        switch (sigev->sigev_notify) {
            case SIGEV_NONE:
                mqnotify->notify.sigev_notify = SIGEV_NONE;
                break;
            case SIGEV_SIGNAL:
                mqnotify->notify.sigev_signo = sigev->sigev_signo;
                mqnotify->notify.sigev_value = sigev->sigev_value;
                mqnotify->notify.sigev_notify = SIGEV_SIGNAL;
                break;
            default:
                break;
        }
 
        mqnotify->pid = LOS_GetCurrProcessID();
    }
 
    (VOID)pthread_mutex_unlock(&g_mqueueMutex);
    return 0;
OUT_UNLOCK:
    (VOID)pthread_mutex_unlock(&g_mqueueMutex);
ERROUT:
    return -1;
}

函数调用图:

这是这个函数的调用关系图:

OsMqSetAttr()

int OsMqSetAttr	(	mqd_t	personal,
		const struct mq_attr *	mqSetAttr,
		struct mq_attr *	mqOldAttr
	)

在文件 mqueue.c 第 615 行定义.

{
    struct mqpersonal *privateMqPersonal = NULL;
 
    privateMqPersonal = MqGetPrivDataBuff(personal);
    if (privateMqPersonal == NULL) {
        return -1;
    }
 
    if (mqSetAttr == NULL) {
        errno = EINVAL;
        return -1;
    }
 
    (VOID)pthread_mutex_lock(&g_mqueueMutex);
    if (privateMqPersonal->mq_status != MQ_USE_MAGIC) {
        errno = EBADF;
        (VOID)pthread_mutex_unlock(&g_mqueueMutex);
        return -1;
    }
 
    if (mqOldAttr != NULL) {
        (VOID)OsMqGetAttr(personal, mqOldAttr);
    }
 
    privateMqPersonal->mq_flags = (INT32)((UINT32)privateMqPersonal->mq_flags & (UINT32)(~FNONBLOCK)); /* clear */
    if (((UINT32)mqSetAttr->mq_flags & (UINT32)FNONBLOCK) == (UINT32)FNONBLOCK) {
        privateMqPersonal->mq_flags = (INT32)((UINT32)privateMqPersonal->mq_flags | (UINT32)FNONBLOCK);
    }
    (VOID)pthread_mutex_unlock(&g_mqueueMutex);
    return 0;
}

函数调用图:

这是这个函数的调用关系图:

SaveMqueueName()

STATIC int SaveMqueueName	(	const CHAR *	mqName,
		struct mqarray *	mqueueCB
	)

在文件 mqueue.c 第 142 行定义.

{
    size_t nameLen;
 
    nameLen = strlen(mqName); /* sys_mq_open has checked name and name length */
    mqueueCB->mq_name = (char *)LOS_MemAlloc(OS_SYS_MEM_ADDR, nameLen + 1);
    if (mqueueCB->mq_name == NULL) {
        errno = ENOMEM;
        return LOS_NOK;
    }
 
    if (strncpy_s(mqueueCB->mq_name, (nameLen + 1), mqName, nameLen) != EOK) {
        LOS_MemFree(OS_SYS_MEM_ADDR, mqueueCB->mq_name);
        mqueueCB->mq_name = NULL;
        errno = EINVAL;
        return LOS_NOK;
    }
    mqueueCB->mq_name[nameLen] = '\0';
    return LOS_OK;
}

函数调用图:

这是这个函数的调用关系图:

变量说明

g_mqPrivBuf

STATIC struct mqpersonal* g_mqPrivBuf[MAX_MQ_FD]

在文件 mqueue.c 第 55 行定义.

g_mqueueMutex

STATIC pthread_mutex_t g_mqueueMutex = PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP

在文件 mqueue.c 第 54 行定义.

g_queueFdSet

STATIC fd_set g_queueFdSet

在文件 mqueue.c 第 52 行定义.

g_queueTable

STATIC struct mqarray g_queueTable[LOSCFG_BASE_IPC_QUEUE_LIMIT]

在文件 mqueue.c 第 53 行定义.