rtmpchunks.h

Go to the documentation of this file.

#pragma once
#include <map>
#include <string.h>
#include <stdlib.h>
#include <sys/time.h>
#include <string>
#include <arpa/inet.h>
#include "socket.h"

//forward declaration of FLV::Tag to avoid circular dependencies.
namespace FLV {
  class Tag;
}

namespace RTMPStream {

  extern unsigned int chunk_rec_max; 
  extern unsigned int chunk_snd_max; 
  extern unsigned int rec_window_size; 
  extern unsigned int snd_window_size; 
  extern unsigned int rec_window_at; 
  extern unsigned int snd_window_at; 
  extern unsigned int rec_cnt; 
  extern unsigned int snd_cnt; 

  extern timeval lastrec; 

  class Chunk {
    public:
      unsigned char headertype; 
      unsigned int cs_id; 
      unsigned int timestamp; 
      unsigned int ts_delta; 
      unsigned int ts_header; 
      unsigned int len; 
      unsigned int real_len; 
      unsigned int len_left; 
      unsigned char msg_type_id; 
      unsigned int msg_stream_id; 
      std::string data; 

      Chunk();
      bool Parse(Socket::Buffer & data);
      std::string & Pack();
  };
  //RTMPStream::Chunk

  extern std::map<unsigned int, Chunk> lastsend;
  extern std::map<unsigned int, Chunk> lastrecv;

  std::string & SendChunk(unsigned int cs_id, unsigned char msg_type_id, unsigned int msg_stream_id, std::string data);
  std::string & SendMedia(unsigned char msg_type_id, unsigned char * data, int len, unsigned int ts);
  std::string & SendMedia(FLV::Tag & tag);
  std::string & SendCTL(unsigned char type, unsigned int data);
  std::string & SendCTL(unsigned char type, unsigned int data, unsigned char data2);
  std::string & SendUSR(unsigned char type, unsigned int data);
  std::string & SendUSR(unsigned char type, unsigned int data, unsigned int data2);

  extern std::string handshake_in;
  extern std::string handshake_out;
  bool doHandshake();
} //RTMPStream namespace