Lines Matching defs:consumers
89 /* Feed back rest of messages to buffer (they are end messages) so other consumers wake up. */
173 vector<Consumer*> consumers;
179 consumers.push_back(new Consumer(buffer, numProducers));
181 // Start consumers.
182 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers.end(); i++)
193 // Write end messages for consumers.
199 // Wait for consumers.
200 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers.end(); i++)
212 cmpSum += consumers[j]->getPayloadSum((deUint16)i);
219 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers.end(); i++)