00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
#ifndef LC_RETRANS_H
00026
#define LC_RETRANS_H
00027
00028
#include <config.h>
00029
#include "RetransBase.h"
00030
#include "RetransCommon.h"
00031
#include "MNRope.h"
00032
#include "lcrtp/MNLCRTPdefs.h"
00033
#include "lcrtp/MNLCRTPLossList.h"
00034
#include "lcrtp/MNLCRTPdefs.h"
00035
#include "sh/MNRTPEncoderSH.h"
00036
#include "sh/SHGraphManager.h"
00037
00038
00039
00040
00041
00042
00043
00044
00045
00046
namespace SH
00047 {
00048
00049 class LCRetrans :
public RetransCommon
00050 {
00051
ProtectedU_int32 _repeat_timeouts;
00052
lcstreamer_send_t* _StreamData;
00053
u_int64 _offset;
00054
Timeval _resend_timeout;
00055
MNMutex _send_mutex;
00056
Base* _encSH;
00057
public:
00058
00061
LCRetrans(
Base* encSH );
00062
00065
virtual ~LCRetrans( );
00066
00067
MNRope*
createExtensionHeaderData(
int& type );
00068
bool hasExtHeader( );
00069
bool prepareCallback( );
00070
SH::ReportPtr sendEnd( );
00071
MNRope*
get_next_data(
SH::SinkEndpoint* pull_here,
00072 size_t max_bytes_to_pull,
00073 SH::ReturnCode& except,
00074 size_t& pulled_bytes,
00075
bool& rtp_marker,
00076
u_int32& rtp_timestamp,
00077
Timeval& next_playtime_packet,
00078
int bandwidth,
00079
int& cbpidx);
00080
bool evalRTRTCP(
void* data,
int len,
int subtype,
int& cbpidx);
00081 };
00082
00083 };
00084
#endif