PeerStreamer

 * Start one measure

void start_measure(MonHandler mh, MonParameterValue rate, const char *pubname, enum stat_types st[], int length, SocketId dst, MsgType mt)

	if (rate) monSetParameter (mh, P_PUBLISHING_RATE, rate);

	if (length) monPublishStatisticalType(mh, pubname, channel_get_name(), st , length, NULL);

	monActivateMeasure(mh, dst, mt);

}

/*

 * Initialize and start one measure

 */

void add_measure(MonHandler *mhp, MeasurementId id, MeasurementCapabilities mc, MonParameterValue rate, const char *pubname, enum stat_types st[], int length, SocketId dst, MsgType mt)

{

	*mhp = monCreateMeasure(id, mc);

	start_measure(*mhp, rate, pubname, st, length, dst, mt);

       id->mhs[j] = monCreateMeasure(HOPCOUNT, PACKET | IN_BAND);

       start_measure(id->mhs[j++], P2P_PUBLISH_INTERVAL, "HopCount", stwinavg, sizeof(stwinavg)/sizeof(enum stat_types), id->addr, MSG_TYPE_SIGNALLING);	//[IP hops]

       id->mhs[j] = monCreateMeasure(RTT, PACKET | IN_BAND);

       start_measure(id->mhs[j++], P2P_PUBLISH_INTERVAL, "RoundTripDelay", stwinavgwinvar, sizeof(stwinavgwinvar)/sizeof(enum stat_types), id->addr, MSG_TYPE_SIGNALLING);	//[seconds]

       id->mhs[j] = monCreateMeasure(SEQWIN, PACKET | IN_BAND);

       start_measure(id->mhs[j++], 0, NULL, NULL, 0, id->addr, MSG_TYPE_CHUNK);

       id->mhs[j] = monCreateMeasure(LOSS, PACKET | IN_BAND);

       start_measure(id->mhs[j++], P2P_PUBLISH_INTERVAL, "LossRate", stwinavg, sizeof(stwinavg)/sizeof(enum stat_types), id->addr, MSG_TYPE_CHUNK);	//LossRate_avg [probability 0..1] LossRate_rate [lost_pkts/sec]

       id->mhs[j] = monCreateMeasure(RX_BYTE, PACKET | IN_BAND);

       start_measure(id->mhs[j++], P2P_PUBLISH_INTERVAL, "RxBytesChunk", stsumwinsumrate, sizeof(stsumwinsumrate)/sizeof(enum stat_types), id->addr, MSG_TYPE_CHUNK);	//[bytes]

       id->mhs[j] = monCreateMeasure(TX_BYTE, PACKET | IN_BAND);

       start_measure(id->mhs[j++], P2P_PUBLISH_INTERVAL, "TxBytesChunk", stsumwinsumrate, sizeof(stsumwinsumrate)/sizeof(enum stat_types), id->addr, MSG_TYPE_CHUNK);	//[bytes]

       id->mhs[j] = monCreateMeasure(RX_BYTE, PACKET | IN_BAND);

       start_measure(id->mhs[j++], P2P_PUBLISH_INTERVAL, "RxBytesSig", stsumwinsumrate, sizeof(stsumwinsumrate)/sizeof(enum stat_types), id->addr, MSG_TYPE_SIGNALLING);	//[bytes]

       id->mhs[j] = monCreateMeasure(TX_BYTE, PACKET | IN_BAND);

       start_measure(id->mhs[j++], P2P_PUBLISH_INTERVAL, "TxBytesSig", stsumwinsumrate, sizeof(stsumwinsumrate)/sizeof(enum stat_types), id->addr, MSG_TYPE_SIGNALLING);	//[bytes]

       id->mhs[j] = monCreateMeasure(RX_PACKET, DATA | IN_BAND);

       start_measure(id->mhs[j++], P2P_PUBLISH_INTERVAL, "RxChunks", stwinavgrate, sizeof(stwinavgrate)/sizeof(enum stat_types), id->addr, MSG_TYPE_CHUNK);	//RxChunks_sum [chunks] RxChunks_rate [chunks/sec]

       id->mhs[j] = monCreateMeasure(TX_PACKET, DATA | IN_BAND);

       start_measure(id->mhs[j++], P2P_PUBLISH_INTERVAL, "TxChunks", stwinavgrate, sizeof(stwinavgrate)/sizeof(enum stat_types), id->addr, MSG_TYPE_CHUNK);	//TxChunks_sum [chunks] TxChunks_rate [chunks/sec]

       id->mhs[j] = monCreateMeasure(BULK_TRANSFER, PACKET | DATA | IN_BAND);

       start_measure(id->mhs[j++], P2P_PUBLISH_INTERVAL, "BulkTransfer", stwinavg, sizeof(stwinavg)/sizeof(enum stat_types), id->addr, MSG_TYPE_CHUNK); //Bulktransfer [bit/s]

	id->mhs[j] = monCreateMeasure(CLOCKDRIFT, PACKET | IN_BAND);

	monSetParameter (id->mhs[j], P_CLOCKDRIFT_ALGORITHM, 1);

	start_measure(id->mhs[j++], 0, NULL, NULL, 0, id->addr, MSG_TYPE_CHUNK);

	id->mhs[j] = monCreateMeasure(CORRECTED_DELAY, PACKET | IN_BAND);

	start_measure(id->mhs[j++], 0, NULL, NULL, 0, id->addr, MSG_TYPE_CHUNK);

	id->mhs[j] = monCreateMeasure(CAPACITY_CAPPROBE, PACKET | IN_BAND);

	monSetParameter (id->mhs[j], P_CAPPROBE_DELAY_TH, -1);

//	monSetParameter (id->mhs[j], P_CAPPROBE_PKT_TH, 5);

	start_measure(id->mhs[j++], P2P_PUBLISH_INTERVAL, "Capacity", stwinavg, sizeof(stwinavg)/sizeof(enum stat_types), id->addr, MSG_TYPE_CHUNK);	//[bytes/s]