mqueue.c - OpenGrok cross reference for /kernel/liteos

Lines Matching refs:privateMqPersonal
235     struct mqpersonal *privateMqPersonal = NULL;
243     privateMqPersonal = (struct mqpersonal *)LOS_MemAlloc(OS_SYS_MEM_ADDR, sizeof(struct mqpersonal));
244     if (privateMqPersonal == NULL) {
249     privateMqPersonal->mq_next = mqueueCB->mq_personal;
250     mqueueCB->mq_personal = privateMqPersonal;
252     privateMqPersonal->mq_posixdes = mqueueCB;
253     privateMqPersonal->mq_flags = openFlag;
254     privateMqPersonal->mq_status = MQ_USE_MAGIC;
256     return privateMqPersonal;
265     struct mqpersonal *privateMqPersonal = (struct mqpersonal *)-1;
283             privateMqPersonal = DoMqueueOpen(mqueueCB, openFlag);
298             privateMqPersonal = DoMqueueCreate(&defaultAttr, mqName, openFlag);
305         privateMqPersonal = DoMqueueOpen(mqueueCB, openFlag);
310     return (mqd_t)privateMqPersonal;
317     struct mqpersonal *privateMqPersonal = NULL;
326     privateMqPersonal = (struct mqpersonal *)personal;
327     if (privateMqPersonal->mq_status != MQ_USE_MAGIC) {
332     mqueueCB = privateMqPersonal->mq_posixdes;
339     if (mqueueCB->mq_personal == privateMqPersonal) {
340         mqueueCB->mq_personal = privateMqPersonal->mq_next;
343             if (tmp->mq_next == privateMqPersonal) {
351         tmp->mq_next = privateMqPersonal->mq_next;
354     privateMqPersonal->mq_status = 0;
357     ret = LOS_MemFree(OS_SYS_MEM_ADDR, privateMqPersonal);
375     struct mqpersonal *privateMqPersonal = NULL;
383     privateMqPersonal = (struct mqpersonal *)personal;
384     if (privateMqPersonal->mq_status != MQ_USE_MAGIC) {
390     mqueueCB = privateMqPersonal->mq_posixdes;
394     mqAttr->mq_flags = privateMqPersonal->mq_flags;
401     struct mqpersonal *privateMqPersonal = NULL;
409     privateMqPersonal = (struct mqpersonal *)personal;
410     if (privateMqPersonal->mq_status != MQ_USE_MAGIC) {
417         (VOID)OsMqGetAttr((mqd_t)privateMqPersonal, mqOldAttr);
420     privateMqPersonal->mq_flags = (INT32)((UINT32)privateMqPersonal->mq_flags & (UINT32)(~FNONBLOCK)); /* clear */
422         privateMqPersonal->mq_flags = (INT32)((UINT32)privateMqPersonal->mq_flags | (UINT32)FNONBLOCK);
540     struct mqpersonal *privateMqPersonal = NULL;
547     privateMqPersonal = (struct mqpersonal *)personal;
548     OS_MQ_GOTO_ERROUT_UNLOCK_IF(privateMqPersonal->mq_status != MQ_USE_MAGIC, EBADF);
550     mqueueCB = privateMqPersonal->mq_posixdes;
553     OS_MQ_GOTO_ERROUT_UNLOCK_IF((((UINT32)privateMqPersonal->mq_flags & (UINT32)O_WRONLY) != (UINT32)O_WRONLY) &&
554                                 (((UINT32)privateMqPersonal->mq_flags & (UINT32)O_RDWR) != (UINT32)O_RDWR),
557     OS_MQ_GOTO_ERROUT_UNLOCK_IF(ConvertTimeout(privateMqPersonal->mq_flags, absTimeout, &absTicks) == -1, errno);
579     struct mqpersonal *privateMqPersonal = NULL;
590     privateMqPersonal = (struct mqpersonal *)personal;
591     if (privateMqPersonal->mq_status != MQ_USE_MAGIC) {
596     mqueueCB = privateMqPersonal->mq_posixdes;
602     if (((UINT32)privateMqPersonal->mq_flags & (UINT32)O_WRONLY) == (UINT32)O_WRONLY) {
607     if (ConvertTimeout(privateMqPersonal->mq_flags, absTimeout, &absTicks) == -1) {