Asterisk mod sample

astmod.c

static void *rtp_thread(void *args)
{
        struct ap_info* thread_info = args;
        struct ast_frame *f = NULL;
        struct ast_rtp *astRtp = NULL;                  // XXX <-- Replaced by rtp_engine
        int pktCnt=0;
        int res = 0;

        astRtp = ast_rtp_new_fd(thread_info->sockFd);   // XXX <-- Doesn't event exist anymore

        fd_flush(thread_info->timerFd);

        ast_log(LOG_WARNING, "NEW rtpthread has started - Network Port: %d TimerPort: %d\n", thread_info->sockFd, thread_info->timerFd);
        for(;;) {
                f = ast_rtp_read(astRtp);               // XXX <-- Yea not really the same anymore

                if( !f ) {
                        ast_log(LOG_WARNING, "%d - Ending Thread on Frame(%d) size-%d to ztc\n", thread_info->sockFd, f->subclass.integer, f->datalen);
                        break;
                }

/* ... */