#include <stdio.h>
#include "rtpsession.h"
#include "rtppacket.h"

// 錯誤處理函數(shù)
void checkerror(int err)
{
  if (err < 0) {
    char* errstr = RTPGetErrorString(err);
    printf("Error:%s\\n", errstr);
    exit(-1);
  }
}

int main(int argc, char** argv)
{
#ifdef WIN32
	WSADATA dat;
	WSAStartup(MAKEWORD(2,2),&dat);
#endif
  RTPSession sess;
  int localport;
  int status;

  if (argc != 2) {
    printf("Usage: ./sender localport\\n");
    return -1;
  }

   // 獲得用戶指定的端口號
  localport = atoi(argv[1]);

  // 創(chuàng)建RTP會話
  status = sess.Create(localport);
  checkerror(status);

  do {
    // 接受RTP數(shù)據(jù)
    status = sess.PollData();
	// 檢索RTP數(shù)據(jù)源
    if (sess.GotoFirstSourceWithData()) {
      do {
        RTPPacket* packet;
        // 獲取RTP數(shù)據(jù)報
        while ((packet = sess.GetNextPacket()) != NULL) {
          printf("Got packet !\\n");
          // 刪除RTP數(shù)據(jù)報
          delete packet;
        }
      } while (sess.GotoNextSourceWithData());
    }
  } while(1);

  return 0;
}