Lines Matching refs:mq_personal
172 mqueueCB->mq_personal->mq_status = MQ_USE_MAGIC;
173 mqueueCB->mq_personal->mq_next = NULL;
174 mqueueCB->mq_personal->mq_posixdes = mqueueCB;
175 mqueueCB->mq_personal->mq_flags = (INT32)((UINT32)openFlag | ((UINT32)attr->mq_flags & (UINT32)FNONBLOCK));
176 mqueueCB->mq_personal->mq_mode = mode;
177 mqueueCB->mq_personal->mq_refcount = 0;
215 mqueueCB->mq_personal = (struct mqpersonal *)LOS_MemAlloc(OS_SYS_MEM_ADDR, sizeof(struct mqpersonal));
216 if (mqueueCB->mq_personal == NULL) {
226 return mqueueCB->mq_personal;
255 privateMqPersonal->mq_next = mqueueCB->mq_personal;
256 mqueueCB->mq_personal = privateMqPersonal;
276 if (mqueueCB == NULL || mqueueCB->mq_personal == NULL) {
288 if (mqueueCB->mq_personal == privateMqPersonal) {
289 mqueueCB->mq_personal = privateMqPersonal->mq_next;
291 for (tmp = mqueueCB->mq_personal; tmp->mq_next != NULL; tmp = tmp->mq_next) {
417 mode = mqueueCB->mq_personal->mq_mode;
698 if (mqueueCB->mq_personal != NULL) {
984 (VOID)DoMqueueClose(mqueueCB->mq_personal);