return IDestructQueItem;
}
-void DecreaseShutdownDeliveries(OneQueItem *MyQItem)
-{
- pthread_mutex_lock(&ActiveQItemsLock);
- MyQItem->NotYetShutdownDeliveries--;
- pthread_mutex_unlock(&ActiveQItemsLock);
-}
-
-int GetShutdownDeliveries(OneQueItem *MyQItem)
-{
- int DestructNow;
-
- pthread_mutex_lock(&ActiveQItemsLock);
- DestructNow = MyQItem->ActiveDeliveries == 0;
- pthread_mutex_unlock(&ActiveQItemsLock);
- return DestructNow;
-}
void RemoveQItem(OneQueItem *MyQItem)
{
long len;
}
DeleteHashPos(&It);
- MyQItem->NotYetShutdownDeliveries =
MyQItem->ActiveDeliveries = CountActiveQueueEntries(MyQItem);
/* failsafe against overload: