mqueue.h 文件参考

浏览源代码.

结构体
union	send_receive_t
struct	mqnotify
struct	mqarray
struct	mqpersonal
struct	mq_attr

类型定义
typedef union send_receive_t	mode_s
typedef UINTPTR	mqd_t

函数
mqd_t	mq_open (const char *mqName, int openFlag,...)
int	mq_close (mqd_t personal)
int	mq_unlink (const char *mqName)
int	mq_send (mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio)
ssize_t	mq_receive (mqd_t personal, char *msg, size_t msgLen, unsigned int *msgPrio)
int	mq_getsetattr (mqd_t personal, const struct mq_attr *mqSetAttr, struct mq_attr *MqOldAttr)
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)
void	MqueueRefer (int sysFd)
int	OsMqNotify (mqd_t personal, const struct sigevent *sigev)

类型定义说明

mode_s

typedef union send_receive_t mode_s

函数说明

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;
}

函数调用图:

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

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;
}

函数调用图:

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