Tvheadend

  dvr_config_t *cfg = dvr_config_find_by_name_default(de->de_config_name);

  streaming_tsbuf_t pat_pmt_tsbuf;

  struct mk_ts_pat_pmt pat_pmt_buf;

  int run = 1;

  pthread_mutex_lock(&sq->sq_mutex);

      if (strcmp(cfg->dvr_format, "mpegts") == 0) {

        struct streaming_start *ss = sm->sm_data;

        run = mk_ts_build_pat_pmt(&pat_pmt_buf, ss, de->de_s->ths_service->s_pmt_pid, de->de_s->ths_service->s_pcr_pid);

        pat_pmt_tsbuf.ts_data = (uint8_t *)&pat_pmt_buf;

        pat_pmt_tsbuf.ts_cnt = 2;

      }

        if(de->de_mkts != NULL) {

          streaming_tsbuf_t *tsbuf = sm->sm_data;

          if(ts_packets_cnt >= 1000) {

            ts_packets_cnt = 0;

            mk_ts_write(de->de_mkts, &pat_pmt_tsbuf);

          }

          mk_ts_write(de->de_mkts, tsbuf);

        }

  streaming_message_t *sm;

  mk_mux_t *mkm = NULL;

  struct mk_ts_pat_pmt pat_pmt_buf;

  int run = 1;

  int timeouts = 0;

  uint32_t event_id = 0;

        streaming_tsbuf_t *tsbuf = sm->sm_data;

        uint32_t size = tsbuf->ts_cnt * 188;

        if (ts_packets_cnt >= 1000) {

          ts_packets_cnt = 0;

          run = write(hc->hc_fd, pat_pmt_buf.pat_ts, 188) == 188;

          run = write(hc->hc_fd, pat_pmt_buf.pmt_ts, 188) == 188;

        }

        if(!run)

          break;