Lines Matching refs:pAwait

614     SyncAwait *pAwait = (SyncAwait *) pTrigger;
620 pAwaitUnion = (SyncAwaitUnion *) pAwait->pHeader;
626 pAwait = &(pAwaitUnion + 1)->await;
637 for (; numwaits; numwaits--, pAwait++) {
645 if (pAwait->trigger.pSync->beingDestroyed) {
646 ppAwait[num_events++] = pAwait;
650 if (SYNC_COUNTER == pAwait->trigger.pSync->type) {
651 SyncCounter *pCounter = (SyncCounter *) pAwait->trigger.pSync;
658 pAwait->trigger.test_value);
665 diffgreater = diff > pAwait->event_threshold;
666 diffequal = diff == pAwait->event_threshold;
676 if (((pAwait->trigger.test_type == XSyncPositiveComparison ||
677 pAwait->trigger.test_type == XSyncPositiveTransition)
680 ((pAwait->trigger.test_type == XSyncNegativeComparison ||
681 pAwait->trigger.test_type == XSyncNegativeTransition)
685 ppAwait[num_events++] = pAwait;
1190 SyncAwait *pAwait;
1193 pAwait = &(pAwaitUnion + 1)->await; /* first await on list */
1198 numwaits--, pAwait++) {
1202 SyncObject *pSync = pAwait->trigger.pSync;
1205 SyncDeleteTriggerFromSyncObject(&pAwait->trigger);
1538 SyncAwait *pAwait;
1545 pAwait = &(pAwaitUnion + 1)->await; /* skip over header */
1546 for (i = 0; i < items; i++, pAwait++) {
1552 switch (pAwait->trigger.pSync->type) {
1554 value = ((SyncCounter *) pAwait->trigger.pSync)->value;
1560 if ((*pAwait->trigger.CheckTrigger) (&pAwait->trigger, value)) {
1561 (*pAwait->trigger.TriggerFired) (&pAwait->trigger);
1578 SyncAwait *pAwait;
1602 pAwait = &(pAwaitUnion + 1)->await; /* skip over header */
1603 for (i = 0; i < items; i++, pProtocolWaitConds++, pAwait++) {
1614 pAwait->trigger.pSync = NULL;
1615 pAwait->trigger.value_type = pProtocolWaitConds->value_type;
1616 pAwait->trigger.wait_value =
1619 pAwait->trigger.test_type = pProtocolWaitConds->test_type;
1621 status = SyncInitTrigger(client, &pAwait->trigger,
1632 pAwait->trigger.TriggerFired = SyncAwaitTriggerFired;
1633 pAwait->trigger.CounterDestroyed = SyncAwaitTriggerFired;
1634 pAwait->event_threshold =
1638 pAwait->pHeader = &pAwaitUnion->header;
2036 SyncAwait *pAwait;
2067 pAwait = &(pAwaitUnion + 1)->await; /* skip over header */
2068 for (i = 0; i < items; i++, pProtocolFences++, pAwait++) {
2078 pAwait->trigger.pSync = NULL;
2082 pAwait->trigger.value_type = XSyncAbsolute;
2083 pAwait->trigger.wait_value = 0;
2084 pAwait->trigger.test_type = 0;
2086 status = SyncInitTrigger(client, &pAwait->trigger,
2096 pAwait->trigger.TriggerFired = SyncAwaitTriggerFired;
2097 pAwait->trigger.CounterDestroyed = SyncAwaitTriggerFired;
2099 pAwait->event_threshold = 0;
2100 pAwait->pHeader = &pAwaitUnion->header;