Lines Matching refs:privateMqPersonal
241 struct mqpersonal *privateMqPersonal = NULL;
249 privateMqPersonal = (struct mqpersonal *)LOS_MemAlloc(OS_SYS_MEM_ADDR, sizeof(struct mqpersonal));
250 if (privateMqPersonal == NULL) {
255 privateMqPersonal->mq_next = mqueueCB->mq_personal;
256 mqueueCB->mq_personal = privateMqPersonal;
258 privateMqPersonal->mq_posixdes = mqueueCB;
259 privateMqPersonal->mq_flags = openFlag;
260 privateMqPersonal->mq_status = MQ_USE_MAGIC;
261 privateMqPersonal->mq_refcount = 0;
263 return privateMqPersonal;
269 STATIC INT32 DoMqueueClose(struct mqpersonal *privateMqPersonal)
275 mqueueCB = privateMqPersonal->mq_posixdes;
281 if ((mqueueCB->unlinkflag == TRUE) && (privateMqPersonal->mq_next == NULL)) {
288 if (mqueueCB->mq_personal == privateMqPersonal) {
289 mqueueCB->mq_personal = privateMqPersonal->mq_next;
292 if (tmp->mq_next == privateMqPersonal) {
300 tmp->mq_next = privateMqPersonal->mq_next;
303 privateMqPersonal->mq_status = 0;
306 (VOID)LOS_MemFree(OS_SYS_MEM_ADDR, privateMqPersonal);
311 /* Translate a sysFd into privateMqPersonal */
330 * @param privateMqPersonal: Private data.
333 STATIC INT32 MqAllocSysFd(int maxfdp, struct mqpersonal *privateMqPersonal)
342 IPC_QUEUE_MQ_PRIV_BUF[i] = privateMqPersonal;
364 struct mqpersonal *privateMqPersonal = NULL;
368 privateMqPersonal = MqGetPrivDataBuff((mqd_t)sysFd);
369 if (privateMqPersonal == NULL) {
372 mqueueCB = privateMqPersonal->mq_posixdes;
377 privateMqPersonal->mq_refcount++;
383 STATIC INT32 MqTryClose(struct mqpersonal *privateMqPersonal)
386 mqueueCB = privateMqPersonal->mq_posixdes;
392 if (privateMqPersonal->mq_refcount == 0) {
395 privateMqPersonal->mq_refcount--;
400 STATIC INT32 MqueueModeAnalysisSet(struct mqpersonal *privateMqPersonal)
407 if ((INT32)(UINTPTR)privateMqPersonal < 0) {
411 mqueueCB = privateMqPersonal->mq_posixdes;
511 struct mqpersonal *privateMqPersonal = (struct mqpersonal *)-1;
531 privateMqPersonal = DoMqueueOpen(mqueueCB, openFlag);
541 privateMqPersonal = DoMqueueCreate(&defaultAttr, mqName, openFlag, mode);
544 if (MqueueModeAnalysisSet(privateMqPersonal)) {
545 if ((INT32)(UINTPTR)privateMqPersonal > 0) {
546 (VOID)DoMqueueClose(privateMqPersonal);
554 privateMqPersonal = DoMqueueOpen(mqueueCB, openFlag);
557 if ((INT32)(UINTPTR)privateMqPersonal > 0) {
559 sysFd = MqAllocSysFd(MAX_MQ_FD, privateMqPersonal);
562 (VOID)DoMqueueClose(privateMqPersonal);
575 struct mqpersonal *privateMqPersonal = NULL;
580 privateMqPersonal = MqGetPrivDataBuff(personal);
581 if (privateMqPersonal == NULL) {
585 if (privateMqPersonal->mq_status != MQ_USE_MAGIC) {
590 if (!MqTryClose(privateMqPersonal)) {
595 ret = DoMqueueClose(privateMqPersonal);
609 struct mqpersonal *privateMqPersonal = NULL;
612 privateMqPersonal = MqGetPrivDataBuff(personal);
613 if (privateMqPersonal == NULL) {
624 if (privateMqPersonal->mq_status != MQ_USE_MAGIC) {
630 mqueueCB = privateMqPersonal->mq_posixdes;
634 mqAttr->mq_flags = privateMqPersonal->mq_flags;
641 struct mqpersonal *privateMqPersonal = NULL;
644 privateMqPersonal = MqGetPrivDataBuff(personal);
645 if (privateMqPersonal == NULL) {
656 if (privateMqPersonal->mq_status != MQ_USE_MAGIC) {
666 privateMqPersonal->mq_flags = (INT32)((UINT32)privateMqPersonal->mq_flags & (UINT32)(~FNONBLOCK)); /* clear */
668 privateMqPersonal->mq_flags = (INT32)((UINT32)privateMqPersonal->mq_flags | (UINT32)FNONBLOCK);
791 struct mqpersonal *privateMqPersonal = NULL;
797 privateMqPersonal = MqGetPrivDataBuff(personal);
799 OS_MQ_GOTO_ERROUT_UNLOCK_IF(privateMqPersonal == NULL || privateMqPersonal->mq_status != MQ_USE_MAGIC, EBADF);
801 mqueueCB = privateMqPersonal->mq_posixdes;
804 OS_MQ_GOTO_ERROUT_UNLOCK_IF((((UINT32)privateMqPersonal->mq_flags & (UINT32)O_WRONLY) != (UINT32)O_WRONLY) &&
805 (((UINT32)privateMqPersonal->mq_flags & (UINT32)O_RDWR) != (UINT32)O_RDWR),
808 OS_MQ_GOTO_ERROUT_UNLOCK_IF(ConvertTimeout(privateMqPersonal->mq_flags, absTimeout, &absTicks) == -1, errno);
834 struct mqpersonal *privateMqPersonal = NULL;
845 privateMqPersonal = MqGetPrivDataBuff(personal);
846 if (privateMqPersonal == NULL || privateMqPersonal->mq_status != MQ_USE_MAGIC) {
851 mqueueCB = privateMqPersonal->mq_posixdes;
857 if (((UINT32)privateMqPersonal->mq_flags & (UINT32)O_WRONLY) == (UINT32)O_WRONLY) {
862 if (ConvertTimeout(privateMqPersonal->mq_flags, absTimeout, &absTicks) == -1) {
921 struct mqpersonal *privateMqPersonal = NULL;
928 privateMqPersonal = MqGetPrivDataBuff(personal);
929 if (privateMqPersonal == NULL) {
933 if (privateMqPersonal->mq_status != MQ_USE_MAGIC) {
938 mqueueCB = privateMqPersonal->mq_posixdes;