BasicRTSPOnlySubsession Class Reference

#include <BasicRTSPOnlySubsession.hh>

Inheritance diagram for BasicRTSPOnlySubsession:

Collaboration diagram for BasicRTSPOnlySubsession:

Static Public Member Functions
static BasicRTSPOnlySubsession *	createNew (UsageEnvironment &env, Boolean reuseFirstSource, rtsp_types_t avType, int rtpPort, struct rtsp_server_parameters)

Protected Member Functions
	BasicRTSPOnlySubsession (UsageEnvironment &env, Boolean reuseFirstSource, rtsp_types_t avType, int rtpPort, struct rtsp_server_parameters)
	~BasicRTSPOnlySubsession () override
void	deleteStream (unsigned clientSessionId, void *&streamToken) override
void	getRTPSinkandRTCP (void *, const RTPSink *&, const RTCPInstance *&) override
void	getStreamParameters (unsigned clientSessionId, struct sockaddr_storage const &clientAddress, Port const &clientRTPPort, Port const &clientRTCPPort, int tcpSocketNum, unsigned char rtpChannelId, unsigned char rtcpChannelId, TLSState *tlsState, struct sockaddr_storage &destinationAddress, uint8_t &destinationTTL, Boolean &isMulticast, Port &serverRTPPort, Port &serverRTCPPort, void *&streamToken) override
char const *	sdpLines (int addressFamily) override
void	startStream (unsigned clientSessionId, void *streamToken, TaskFunc *rtcpRRHandler, void *rtcpRRHandlerClientData, unsigned short &rtpSeqNum, unsigned &rtpTimestamp, ServerRequestAlternativeByteHandler *serverRequestAlternativeByteHandler, void *serverRequestAlternativeByteHandlerClientData) override

Protected Attributes
Destinations *	Adestination
char *	fSDPLines
Destinations *	Vdestination

Private Member Functions
void	setSDPLines (int addressFamily)

Private Attributes
rtsp_types_t	avType
char	fCNAME [100]
MAYBE_UNUSED_ATTRIBUTE void *	fLastStreamToken
MAYBE_UNUSED_ATTRIBUTE Boolean	fReuseFirstSource
int	rtpPort
struct rtsp_server_parameters	rtsp_params

Detailed Description

Definition at line 89 of file BasicRTSPOnlySubsession.hh.

Constructor & Destructor Documentation

BasicRTSPOnlySubsession()

BasicRTSPOnlySubsession::BasicRTSPOnlySubsession ( UsageEnvironment & env, Boolean reuseFirstSource, rtsp_types_t avType, int rtpPort, struct rtsp_server_parameters params )

protected

Definition at line 71 of file BasicRTSPOnlySubsession.cpp.

                                                      :
                ServerMediaSubsession(env), fReuseFirstSource(reuseFirstSource),
                fLastStreamToken(nullptr), rtsp_params(params)
{
        assert(avType == rtsp_type_audio || avType == rtsp_type_video);
        Vdestination = NULL;
        Adestination = NULL;
        gethostname(fCNAME, sizeof fCNAME);
        this->avType = avType;
        this->rtpPort = rtpPort;
        fCNAME[sizeof fCNAME - 1] = '\0';
 
        // print (preliminary) SDP
        setSDPLines(AF_UNSPEC);
        delete[] fSDPLines;
        fSDPLines = nullptr;
}

References Adestination, avType, fCNAME, fSDPLines, rtpPort, rtsp_type_audio, rtsp_type_video, setSDPLines(), and Vdestination.

Referenced by createNew().

Here is the call graph for this function:

~BasicRTSPOnlySubsession()

BasicRTSPOnlySubsession::~BasicRTSPOnlySubsession ( )

overrideprotected

Definition at line 91 of file BasicRTSPOnlySubsession.cpp.

                                                  {
        delete[] fSDPLines;
        delete Adestination;
        delete Vdestination;
}

References Adestination, fSDPLines, and Vdestination.

Member Function Documentation

createNew()

BasicRTSPOnlySubsession * BasicRTSPOnlySubsession::createNew ( UsageEnvironment & env, Boolean reuseFirstSource, rtsp_types_t avType, int rtpPort, struct rtsp_server_parameters params )

static

Definition at line 64 of file BasicRTSPOnlySubsession.cpp.

                                                      {
        return new BasicRTSPOnlySubsession(env, reuseFirstSource, avType,
                                           rtpPort, params);
}

References BasicRTSPOnlySubsession(), avType, and rtpPort.

Here is the call graph for this function:

deleteStream()

void BasicRTSPOnlySubsession::deleteStream ( unsigned clientSessionId, void *& streamToken )

overrideprotected

Definition at line 287 of file BasicRTSPOnlySubsession.cpp.

                          {
        if (Vdestination != NULL) {
                if (avType == rtsp_type_video) {
                        char pathV[1024];
                        delete Vdestination;
                        Vdestination = NULL;
                        memset(pathV, 0, sizeof(pathV));
                        enum module_class path_sender[] = { MODULE_CLASS_SENDER,
                                        MODULE_CLASS_NONE };
                        append_message_path(pathV, sizeof(pathV), path_sender);
 
                        //CHANGE DST PORT
                        struct msg_sender *msgV1 = (struct msg_sender *) new_message(
                                        sizeof(struct msg_sender));
                        msgV1->tx_port = rtsp_params.rtp_port_video;
                        msgV1->type = SENDER_MSG_CHANGE_PORT;
                        struct response *resp;
                        resp = send_message(rtsp_params.parent, pathV, (struct message *) msgV1);
                        free_response(resp);
 
                        //CHANGE DST ADDRESS
                        struct msg_sender *msgV2 = (struct msg_sender *) new_message(
                                        sizeof(struct msg_sender));
                        strncpy(msgV2->receiver, "127.0.0.1", sizeof(msgV2->receiver) - 1);
                        msgV2->type = SENDER_MSG_CHANGE_RECEIVER;
                        resp = send_message(rtsp_params.parent, pathV, (struct message *) msgV2);
                        free_response(resp);
                }
        }
 
        if (Adestination != NULL) {
                if (avType == rtsp_type_audio) {
                        char pathA[1024];
                        delete Adestination;
                        Adestination = NULL;
                        memset(pathA, 0, sizeof(pathA));
                        enum module_class path_sender[] = { MODULE_CLASS_AUDIO,
                                        MODULE_CLASS_SENDER, MODULE_CLASS_NONE };
                        append_message_path(pathA, sizeof(pathA), path_sender);
 
                        //CHANGE DST PORT
                        struct msg_sender *msgA1 = (struct msg_sender *) new_message(
                                        sizeof(struct msg_sender));
 
                        //TODO: GET AUDIO PORT SET (NOT A COMMON CASE WHEN RTSP IS ENABLED: DEFAULT -> vport + 2)
                        msgA1->tx_port = rtsp_params.rtp_port_audio;
                        msgA1->type = SENDER_MSG_CHANGE_PORT;
                        struct response *resp;
                        resp = send_message(rtsp_params.parent, pathA, (struct message *) msgA1);
                        free_response(resp);
 
                        //CHANGE DST ADDRESS
                        struct msg_sender *msgA2 = (struct msg_sender *) new_message(
                                        sizeof(struct msg_sender));
                        strncpy(msgA2->receiver, "127.0.0.1", sizeof(msgA2->receiver) - 1);
                        msgA2->type = SENDER_MSG_CHANGE_RECEIVER;
                        resp = send_message(rtsp_params.parent, pathA, (struct message *) msgA2);
                        free_response(resp);
                }
        }
}

References Adestination, append_message_path(), avType, free_response(), MODULE_CLASS_AUDIO, MODULE_CLASS_NONE, MODULE_CLASS_SENDER, new_message(), rtsp_server_parameters::parent, msg_sender::receiver, rtsp_server_parameters::rtp_port_audio, rtsp_server_parameters::rtp_port_video, rtsp_params, rtsp_type_audio, rtsp_type_video, send_message(), SENDER_MSG_CHANGE_PORT, SENDER_MSG_CHANGE_RECEIVER, msg_sender::tx_port, msg_sender::type, and Vdestination.

Here is the call graph for this function:

getRTPSinkandRTCP()

void BasicRTSPOnlySubsession::getRTPSinkandRTCP ( void * , const RTPSink *& , const RTCPInstance *&  )

inlineoverrideprotected

Definition at line 133 of file BasicRTSPOnlySubsession.hh.

    {
    }

getStreamParameters()

void BasicRTSPOnlySubsession::getStreamParameters ( unsigned clientSessionId, struct sockaddr_storage const & clientAddress, Port const & clientRTPPort, Port const & clientRTCPPort, int tcpSocketNum, unsigned char rtpChannelId, unsigned char rtcpChannelId, TLSState * tlsState, struct sockaddr_storage & destinationAddress, uint8_t & destinationTTL, Boolean & isMulticast, Port & serverRTPPort, Port & serverRTCPPort, void *& streamToken )

overrideprotected

Definition at line 176 of file BasicRTSPOnlySubsession.cpp.

                          {
        if (avType == rtsp_type_video) {
                Port rtp(rtsp_params.rtp_port_video);
                serverRTPPort = rtp;
                Port rtcp(rtsp_params.rtp_port_video + 1);
                serverRTCPPort = rtcp;
 
                delete Vdestination;
                Vdestination = new Destinations(clientAddress, clientRTPPort,
                                clientRTCPPort);
        }
        if (avType == rtsp_type_audio) {
                Port rtp(rtsp_params.rtp_port_audio);
                serverRTPPort = rtp;
                Port rtcp(rtsp_params.rtp_port_audio + 1);
                serverRTCPPort = rtcp;
 
                delete Adestination;
                Adestination = new Destinations(clientAddress, clientRTPPort,
                                clientRTCPPort);
        }
}

References Adestination, avType, rtsp_server_parameters::rtp_port_audio, rtsp_server_parameters::rtp_port_video, rtsp_params, rtsp_type_audio, rtsp_type_video, and Vdestination.

sdpLines()

char const * BasicRTSPOnlySubsession::sdpLines ( int addressFamily )

overrideprotected

Definition at line 108 of file BasicRTSPOnlySubsession.cpp.

                                                               {
        if (fSDPLines == NULL) {
                setSDPLines(addressFamily);
        }
        return fSDPLines;
}

References fSDPLines, and setSDPLines().

Referenced by setSDPLines().

Here is the call graph for this function:

setSDPLines()

void BasicRTSPOnlySubsession::setSDPLines ( int addressFamily )

private

Definition at line 115 of file BasicRTSPOnlySubsession.cpp.

                                                           {
        //TODO: should be more dynamic
        const char *ip_ver_list_addr = nullptr;
        const char *control  = trackId();
        switch (addressFamily) {
        case AF_INET:
                ip_ver_list_addr = "4 0.0.0.0";
                break;
        case AF_INET6:
                ip_ver_list_addr = "6 ::";
                break;
        case AF_UNSPEC:
                ip_ver_list_addr = "<VER> <TO_BE_FILLED>";
                control = "<CONTROL>"; // is null here
                break;
        default:
                abort();
        }
 
        const struct media_spec *mspec = &media_params[avType];
        char rtpmapLine[STR_LEN];
        int rtpPayloadType = avType == rtsp_type_audio
                  ? get_audio_rtp_pt_rtpmap(
                      rtsp_params.adesc.codec, rtsp_params.adesc.sample_rate,
                      rtsp_params.adesc.ch_count, rtpmapLine)
                  : get_video_rtp_pt_rtpmap(rtsp_params.video_codec, rtpmapLine);
        if (rtpPayloadType < 0) {
                MSG(ERROR, "Unsupported %s codec %s!\n", mspec[avType].mname,
                    avType == rtsp_type_audio
                        ? get_name_to_audio_codec(rtsp_params.adesc.codec)
                        : get_codec_name(rtsp_params.video_codec));
        }
        //char const* auxSDPLine = "";
 
        char const *const sdpFmt = "m=%s %u RTP/AVP %d\r\n"
                                   "c=IN IP%s\r\n"
                                   "b=AS:%u\r\n"
                                   "a=rtcp:%d\r\n"
                                   "%s"
                                   "a=control:%s\r\n";
        unsigned sdpFmtSize = strlen(sdpFmt) + strlen(mspec->mname) +
                              5   /* max short len */
                              + 3 /* max char len */
                              + strlen(ip_ver_list_addr) + 20 /* max int len */
                              + strlen(rtpmapLine) + strlen(control);
        char *sdpLines = new char[sdpFmtSize];
 
        snprintf(sdpLines, sdpFmtSize, sdpFmt, mspec->mname, // m= <media>
                 rtpPort,         // fPortNumForSDP, // m= <port>
                 rtpPayloadType,    // m= <fmt list>
                 ip_ver_list_addr,  // c= address
                 mspec->estBitrate, // b=AS:<bandwidth>
                 rtpPort + 1,
                 rtpmapLine, // a=rtpmap:... (if present)
                 control); // a=control:<track-id>
 
        fSDPLines = sdpLines;
        MSG(VERBOSE, "SDP%s:\n%s\n",
            addressFamily == AF_UNSPEC ? " (preliminary)" : "", fSDPLines);
}

References rtsp_server_parameters::adesc, avType, audio_desc::ch_count, audio_desc::codec, media_spec::estBitrate, fSDPLines, get_audio_rtp_pt_rtpmap(), get_codec_name(), get_name_to_audio_codec(), get_video_rtp_pt_rtpmap(), media_params, media_spec::mname, MSG, rtpPort, rtsp_params, rtsp_type_audio, audio_desc::sample_rate, sdpLines(), STR_LEN, and rtsp_server_parameters::video_codec.

Referenced by BasicRTSPOnlySubsession(), and sdpLines().

Here is the call graph for this function:

startStream()

void BasicRTSPOnlySubsession::startStream ( unsigned clientSessionId, void * streamToken, TaskFunc * rtcpRRHandler, void * rtcpRRHandlerClientData, unsigned short & rtpSeqNum, unsigned & rtpTimestamp, ServerRequestAlternativeByteHandler * serverRequestAlternativeByteHandler, void * serverRequestAlternativeByteHandlerClientData )

overrideprotected

Definition at line 206 of file BasicRTSPOnlySubsession.cpp.

                         {
        struct response *resp = NULL;
 
        if (Vdestination != NULL) {
                if (avType == rtsp_type_video) {
                        char pathV[1024];
 
                        memset(pathV, 0, sizeof(pathV));
                        enum module_class path_sender[] = { MODULE_CLASS_SENDER,
                                        MODULE_CLASS_NONE };
                        append_message_path(pathV, sizeof(pathV), path_sender);
 
                        //CHANGE DST PORT
                        struct msg_sender *msgV1 = (struct msg_sender *) new_message(
                                        sizeof(struct msg_sender));
                        msgV1->tx_port = ntohs(Vdestination->rtpPort.num());
                        msgV1->type = SENDER_MSG_CHANGE_PORT;
                        resp = send_message(rtsp_params.parent, pathV, (struct message *) msgV1);
                        free_response(resp);
 
                        //CHANGE DST ADDRESS
                        struct msg_sender *msgV2 = (struct msg_sender *) new_message(
                                        sizeof(struct msg_sender));
                        char host[IN6_MAX_ASCII_LEN + 1];
                        const int ret =
                            getnameinfo((struct sockaddr *) &Vdestination->addr,
                                        sizeof Vdestination->addr, host,
                                        sizeof host, nullptr, 0, NI_NUMERICHOST);
                        assert(ret == 0);
                        strncpy(msgV2->receiver, host,
                                        sizeof(msgV2->receiver) - 1);
                        msgV2->type = SENDER_MSG_CHANGE_RECEIVER;
 
                        resp = send_message(rtsp_params.parent, pathV, (struct message *) msgV2);
                        free_response(resp);
                }
        }
 
        if (Adestination != NULL) {
                if (avType == rtsp_type_audio) {
                        char pathA[1024];
 
                        memset(pathA, 0, sizeof(pathA));
                        enum module_class path_sender[] = { MODULE_CLASS_AUDIO,
                                        MODULE_CLASS_SENDER, MODULE_CLASS_NONE };
                        append_message_path(pathA, sizeof(pathA), path_sender);
 
                        //CHANGE DST PORT
                        struct msg_sender *msgA1 = (struct msg_sender *) new_message(
                                        sizeof(struct msg_sender));
                        msgA1->tx_port = ntohs(Adestination->rtpPort.num());
                        msgA1->type = SENDER_MSG_CHANGE_PORT;
                        resp = send_message(rtsp_params.parent, pathA, (struct message *) msgA1);
                        free_response(resp);
                        resp = NULL;
 
                        //CHANGE DST ADDRESS
                        struct msg_sender *msgA2 = (struct msg_sender *) new_message(
                                        sizeof(struct msg_sender));
                        char host[IN6_MAX_ASCII_LEN + 1];
                        const int ret =
                            getnameinfo((struct sockaddr *) &Adestination->addr,
                                        sizeof Adestination->addr, host,
                                        sizeof host, nullptr, 0, NI_NUMERICHOST);
                        assert(ret == 0);
                        strncpy(msgA2->receiver, host,
                                        sizeof(msgA2->receiver) - 1);
                        msgA2->type = SENDER_MSG_CHANGE_RECEIVER;
 
                        resp = send_message(rtsp_params.parent, pathA, (struct message *) msgA2);
                        free_response(resp);
                        resp = NULL;
                }
        }
}

References Destinations::addr, Adestination, append_message_path(), avType, free_response(), IN6_MAX_ASCII_LEN, MODULE_CLASS_AUDIO, MODULE_CLASS_NONE, MODULE_CLASS_SENDER, new_message(), rtsp_server_parameters::parent, msg_sender::receiver, Destinations::rtpPort, rtsp_params, rtsp_type_audio, rtsp_type_video, send_message(), SENDER_MSG_CHANGE_PORT, SENDER_MSG_CHANGE_RECEIVER, msg_sender::tx_port, msg_sender::type, and Vdestination.

Here is the call graph for this function:

Member Data Documentation

Adestination

Destinations* BasicRTSPOnlySubsession::Adestination

protected

Definition at line 143 of file BasicRTSPOnlySubsession.hh.

Referenced by BasicRTSPOnlySubsession(), ~BasicRTSPOnlySubsession(), deleteStream(), getStreamParameters(), and startStream().

avType

rtsp_types_t BasicRTSPOnlySubsession::avType

private

Definition at line 152 of file BasicRTSPOnlySubsession.hh.

Referenced by BasicRTSPOnlySubsession(), createNew(), deleteStream(), getStreamParameters(), setSDPLines(), and startStream().

fCNAME

char BasicRTSPOnlySubsession::fCNAME[100]

private

Definition at line 151 of file BasicRTSPOnlySubsession.hh.

Referenced by BasicRTSPOnlySubsession().

fLastStreamToken

MAYBE_UNUSED_ATTRIBUTE void* BasicRTSPOnlySubsession::fLastStreamToken

private

Definition at line 150 of file BasicRTSPOnlySubsession.hh.

fReuseFirstSource

MAYBE_UNUSED_ATTRIBUTE Boolean BasicRTSPOnlySubsession::fReuseFirstSource

private

Definition at line 149 of file BasicRTSPOnlySubsession.hh.

fSDPLines

char* BasicRTSPOnlySubsession::fSDPLines

protected

Definition at line 141 of file BasicRTSPOnlySubsession.hh.

Referenced by BasicRTSPOnlySubsession(), ~BasicRTSPOnlySubsession(), sdpLines(), and setSDPLines().

rtpPort

int BasicRTSPOnlySubsession::rtpPort

private

Definition at line 153 of file BasicRTSPOnlySubsession.hh.

Referenced by BasicRTSPOnlySubsession(), createNew(), and setSDPLines().

rtsp_params

struct rtsp_server_parameters BasicRTSPOnlySubsession::rtsp_params

private

Definition at line 154 of file BasicRTSPOnlySubsession.hh.

Referenced by deleteStream(), getStreamParameters(), setSDPLines(), and startStream().

Vdestination

Destinations* BasicRTSPOnlySubsession::Vdestination

protected

Definition at line 142 of file BasicRTSPOnlySubsession.hh.

Referenced by BasicRTSPOnlySubsession(), ~BasicRTSPOnlySubsession(), deleteStream(), getStreamParameters(), and startStream().

---

The documentation for this class was generated from the following files:

• src/rtsp/BasicRTSPOnlySubsession.hh
• src/rtsp/BasicRTSPOnlySubsession.cpp