Revision c24f3970 measures-monl.c

View differences:

measures-monl.c
202 202
*/
203 203
void reg_offers_in_flight(int running_offer_threads)
204 204
{
205
	if (!offers_in_flight) {
205
	if (offers_in_flight < 0) {
206 206
		enum stat_types st[] =  {AVG, WIN_AVG, LAST};
207 207
		add_measure(&offers_in_flight, GENERIC, 0, PEER_PUBLISH_INTERVAL, "OffersInFlight", st, sizeof(st)/sizeof(enum stat_types), NULL, MSG_TYPE_ANY);	//[peers]
208 208
		monNewSample(offers_in_flight, 0);	//force publish even if there are no events
......
217 217
*/
218 218
void reg_queue_delay(double last_queue_delay)
219 219
{
220
	if (!queue_delay) {
220
	if (queue_delay < 0) {
221 221
		enum stat_types st[] =  {AVG, WIN_AVG, LAST};
222 222
		add_measure(&queue_delay, GENERIC, 0, PEER_PUBLISH_INTERVAL, "QueueDelay", st, sizeof(st)/sizeof(enum stat_types), NULL, MSG_TYPE_ANY);	//[peers]
223 223
		monNewSample(queue_delay, 0);	//force publish even if there are no events

Also available in: Unified diff