9180546fc6
Currently this supports pause/resume, and speed control. FF up to 4x uses full frame output, faster than that or reverse uses i-frame only output. This causes problems with some players and needs work. Also buffers are done at the subscription level which means the disk space is not shared even if it holds the same content. And more importantly this means you cannot yet record the timeshift buffer like on a standard PVR.
116 lines
2.5 KiB
C
116 lines
2.5 KiB
C
/*
|
|
* Packet nanagement
|
|
* Copyright (C) 2008 Andreas Öman
|
|
*
|
|
* This program is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation, either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
#ifndef PACKET_H_
|
|
#define PACKET_H_
|
|
|
|
|
|
typedef struct pktbuf {
|
|
int pb_refcount;
|
|
uint8_t *pb_data;
|
|
size_t pb_size;
|
|
} pktbuf_t;
|
|
|
|
|
|
|
|
/**
|
|
* Packets
|
|
*/
|
|
#define PKT_I_FRAME 1
|
|
#define PKT_P_FRAME 2
|
|
#define PKT_B_FRAME 3
|
|
#define PKT_NTYPES 4
|
|
|
|
static inline char pkt_frametype_to_char ( int frametype )
|
|
{
|
|
if (frametype == PKT_I_FRAME) return 'I';
|
|
if (frametype == PKT_P_FRAME) return 'P';
|
|
if (frametype == PKT_B_FRAME) return 'B';
|
|
return ' ';
|
|
}
|
|
|
|
typedef struct th_pkt {
|
|
int64_t pkt_dts;
|
|
int64_t pkt_pts;
|
|
int pkt_duration;
|
|
int pkt_refcount;
|
|
|
|
uint8_t pkt_commercial;
|
|
uint8_t pkt_componentindex;
|
|
uint8_t pkt_frametype;
|
|
uint8_t pkt_field; // Set if packet is only a half frame (a field)
|
|
|
|
uint8_t pkt_channels;
|
|
uint8_t pkt_sri;
|
|
uint8_t pkt_err;
|
|
|
|
uint16_t pkt_aspect_num;
|
|
uint16_t pkt_aspect_den;
|
|
|
|
pktbuf_t *pkt_payload;
|
|
pktbuf_t *pkt_header;
|
|
|
|
} th_pkt_t;
|
|
|
|
|
|
/**
|
|
* A packet reference
|
|
*/
|
|
typedef struct th_pktref {
|
|
TAILQ_ENTRY(th_pktref) pr_link;
|
|
th_pkt_t *pr_pkt;
|
|
} th_pktref_t;
|
|
|
|
|
|
/**
|
|
*
|
|
*/
|
|
void pkt_ref_dec(th_pkt_t *pkt);
|
|
|
|
void pkt_ref_inc(th_pkt_t *pkt);
|
|
|
|
void pkt_ref_inc_poly(th_pkt_t *pkt, int n);
|
|
|
|
void pktref_clear_queue(struct th_pktref_queue *q);
|
|
|
|
// Reference count is transfered to queue
|
|
void pktref_enqueue(struct th_pktref_queue *q, th_pkt_t *pkt);
|
|
|
|
void pktref_remove(struct th_pktref_queue *q, th_pktref_t *pr);
|
|
|
|
|
|
th_pkt_t *pkt_alloc(const void *data, size_t datalen, int64_t pts, int64_t dts);
|
|
|
|
th_pkt_t *pkt_merge_header(th_pkt_t *pkt);
|
|
|
|
th_pkt_t *pkt_copy_shallow(th_pkt_t *pkt);
|
|
|
|
th_pktref_t *pktref_create(th_pkt_t *pkt);
|
|
|
|
void pktbuf_ref_dec(pktbuf_t *pb);
|
|
|
|
void pktbuf_ref_inc(pktbuf_t *pb);
|
|
|
|
pktbuf_t *pktbuf_alloc(const void *data, size_t size);
|
|
|
|
pktbuf_t *pktbuf_make(void *data, size_t size);
|
|
|
|
#define pktbuf_len(pb) ((pb)->pb_size)
|
|
#define pktbuf_ptr(pb) ((pb)->pb_data)
|
|
|
|
#endif /* PACKET_H_ */
|