npv/pkt_q/public/code.frag.c

   1 STATIC void lock(struct pkt_q_t *this)
   2 {
   3         int r;
   4
   5         r = pthread_mutex_lock(&this->mutex);
   6         if (r != 0)
   7                 fatalx("%d:unable to lock packet queue\n", this, r);
   8 }
   9 STATIC void unlock(struct pkt_q_t *this)
  10 {
  11         int r;
  12
  13         r = pthread_mutex_unlock(&this->mutex);
  14         if (r != 0)
  15                 fatalx("%d:unable to unlock packet queue\n", this, r);
  16 }
  17 /* actually rotate the pkt ref ptrs  */
  18 STATIC void deq(struct pkt_q_t *this)
  19 {
  20         if (this->n > 1) {
  21                 avcodec_pkt_ref_t *save;
  22
  23                 save = this->q[0];
  24                 memmove(&this->q[0], &this->q[1], (this->n - 1)
  25                                                         * sizeof(this->q[0]));
  26                 this->q[this->n - 1] = save;
  27         }
  28         this->n--;
  29 }
  30 /* steal the pkt reference */
  31 STATIC void enq(struct pkt_q_t *this, avcodec_pkt_ref_t *pr)
  32 {
  33         if (this->n == this->n_max)
  34                 grow(this);
  35         avcodec_pkt_move_ref(this->q[this->n], pr);
  36         ++this->n;
  37 }
  38 STATIC void unref_all(struct pkt_q_t *this)
  39 {
  40         u32 pr;
  41
  42         pr = 0;
  43         loop {
  44                 if (pr == this->n)
  45                         break;
  46                 avcodec_pkt_unref(this->q[pr]);
  47                 ++pr;
  48         }
  49         this->n = 0;
  50 }
  51 STATIC struct pkt_q_t *new(u8 *msg_hdr)
  52 {
  53         int r;
  54         struct pkt_q_t *this;
  55
  56         this = malloc(sizeof(*this));
  57         if (this == 0)
  58                 fatal("unable to allocate memory for the %s packet queue\n", msg_hdr);
  59         this->q = 0;
  60         this->n = 0;
  61         this->n_max = 0;
  62         this->msg_hdr = strdup(msg_hdr);
  63         r = pthread_mutex_init(&this->mutex, 0);
  64         if (r != 0)
  65                 fatal("unable to init the mutex for the %s packet queue\n", msg_hdr);
  66         return this;
  67 }
  68 STATIC bool has_eof(struct pkt_q_t *this)
  69 {
  70         if (this->n != 0) {
  71                 avcodec_pkt_ref_t *last;
  72
  73                 last = this->q[this->n - 1];
  74                 if (last->data == 0 && last->sz == 0)
  75                         return true;
  76         }
  77         return false;
  78 }