Lines Matching refs:pWriteQueue
82 static int vbmsSolWPut(queue_t *pWriteQueue, mblk_t *pMBlk);
228 queue_t *pWriteQueue;
441 LogRelFlow((DEVICE_NAME "::Open, pWriteQueue=%p\n", WR(pReadQueue)));
458 if ( pState->pWriteQueue
459 && (pState->pWriteQueue != WR(pReadQueue)))
485 pState->pWriteQueue = WR(pReadQueue);
506 ASMAtomicWriteNullPtr(&pState->pWriteQueue);
549 queue_t *pReadQueue = RD(pState->pWriteQueue);
578 LogRelFlow((DEVICE_NAME "::Close, pWriteQueue=%p\n", WR(pReadQueue)));
600 ASMAtomicWriteNullPtr(&pState->pWriteQueue);
624 RTTEST_CHECK(hTest, g_OpenNodeState.pWriteQueue == WR(&aQueues[0]));
637 int vbmsSolWPut(queue_t *pWriteQueue, mblk_t *pMBlk)
639 PVBMSSTATE pState = (PVBMSSTATE)pWriteQueue->q_ptr;
648 flushq(pWriteQueue, FLUSHDATA);
652 flushq(RD(pWriteQueue), FLUSHDATA);
668 qreply(pWriteQueue, pMBlk);
670 miocnak(pWriteQueue, pMBlk, 0, err);
689 static inline bool testSetResolution(RTTEST hTest, queue_t *pWriteQueue,
692 PVBMSSTATE pState = (PVBMSSTATE)pWriteQueue->q_ptr;
714 bool (*pfnExtra)(RTTEST hTest, queue_t *pWriteQueue, struct msgb *pMBlk);
786 RTTEST_CHECK_MSG(hTest, g_OpenNodeState.pWriteQueue
842 RTTEST_CHECK_MSG(hTest, g_OpenNodeState.pWriteQueue
923 RTTEST_CHECK_MSG(hTest, g_OpenNodeState.pWriteQueue
986 RTTEST_CHECK_MSG(hTest, g_OpenNodeState.pWriteQueue