apps/astreamer/rtsp.h

Go to the documentation of this file.

#ifndef _RTSP_H_
#define _RTSP_H_

//#include "types.h"
#include "session.h"
#include "socket.h"

#include <map>
#include <list>
#include <string>
#include <iostream>

using namespace std;

class _Request {
public:
        _Request(const string &req);
        inline const string &get_method(void) {
                return method;
        }
        inline const string &get_uri(void) {
                return uri;
        }
        inline const map<string, string> &get_fields(void) {
                return fields;
        }
protected:
        string method;
        string uri;
        map<string, string> fields;
};

class _Responce {
public:
        enum status {STATUS_EMPTY, STATUS_BUSY, STATUS_OK};
        _Responce():_status(STATUS_EMPTY) {};
        inline void set_status(status st) {
                _status = st;
        }
        void add_field(const string &name, const string &value);
        void add_include(const string &include);
        string serialize(void);
protected:
        status _status;
        map<string, string> fields;
        string include;
};

class RTSP_Server {
public:
        enum event {
                EMPTY,
                DESCRIBE,
                PLAY,
                PAUSE,
                TEARDOWN
        };
        // if transport == NULL - wait for set_transport(), when client connected and ask DESCRIBE

        RTSP_Server(void (*h)(void *, RTSP_Server *, RTSP_Server::event), void *handler_data, Session *_session = NULL);
        ~RTSP_Server();
        
        // deprecated
        void main(void);
protected:
        bool process(Socket *s);
        string make_sdp(string uri);
        string make_transport(string req);
        Session *session;

        void (*handler_f)(void *, RTSP_Server *, RTSP_Server::event);
        void *handler_data;
        void handler(RTSP_Server::event event) {
                handler_f(handler_data, this, event);
        }
        void *_busy; // pointer to Socket of client, what use current unicast stream

        string part_of_request;
        // thread...
//      RTP *rtp;
};

#endif // _RTSP_H_

---