MNTFRCRecv.h

Go to the documentation of this file.

/* Copyright (C) 2000 KOM/Darmstadt University of Technology
 *
 * You are allowed to use all other parts of the code under the following terms:
 *
 * For non-commercial use, code may be used in unmodified form provided
 * that this copyright notice and this permission notice appear in
 * supporting documentation.
 *
 * This software is provided "as is" and without any express or implied
 * warranties, including, without limitation, the implied warranty of
 * fitness for a particular purpose.
 *
 * The code may be subjected to the GNU General Public License, Version 2,
 * and re-distributed under the terms of this license.
 * As a special exception, permission is granted to link this code
 * with the Qt library and distribute executables, as long as you
 * follow the requirements of the GNU GPL in regard to all of the
 * software in the executable aside from Qt.
 *
 * Commercial use other than under the terms of the GNU General Public
 * License is allowed only after express negotiation of conditions
 * with the authors.
 */

#ifndef MN_TFRCRECV_H
#define MN_TFRCRECV_H

#include <sys/types.h>
#include "var_type.h"
#include "MNTimeval.h"
#include "MNRTPPacket.h"
#include "lcrtp/MNLCRTPdefs.h"

#define HIST_SIZE 100000
#define MAX_WEIGHTS 32


class MNTFRCRecv
{
protected:
    int     _ppl_cur;
    int     _ppl_hist[HIST_SIZE];
    int     _ts_hist[HIST_SIZE];       /* in ms */
    int     _seq_hist[HIST_SIZE];
    int     _ppl[MAX_WEIGHTS + 1];
    int     _num_loss;
    int     _weights;
    int     _const_weights;
    int     _data_per_report;
    u_int32 _round;
    u_int32 _mode;
    int32   _mseq_offs, _high_offs;
    int32   _ppl_start, _ppl_end;
    int64   _last_report;
    float   _weight[MAX_WEIGHTS];
    float   _new_mult; /* deweighting factor */
    double  _rtt_ema;
    Timeval _start_time;
    Timeval _old_time;
    bool    _first;
    MNMutex _timer_mutex;
    /* float   mult[MAX_WEIGHTS + 1]; */

   
public:
    MNTFRCRecv( );
    virtual ~MNTFRCRecv( );

    bool packet_received( tfrc_payload* packet, u_int16 seqnum,  u_int32 ts, 
                          size_t length, LCfeedb_tfrc_t* reply );
private:
    void init(); 
    void init_time( ); 
    void set_weights();
    void log_loss(int64 arrival); 
    void fake_history(int ppl_est); 
    double bitrate_eq(double l, double rtt, double t0); 
    double lossfraction_eq(double bitrate, double rtt, double t0);
    double lossfraction( ); 
    int update_history(u_int32 mseq, int64 arrival, double rtt, double tzero, double b_act); 
    int64 get_time(); 
};

#endif /* MN_TFRCRECV_H */

---