diff options
Diffstat (limited to 'pjmedia/src/pjmedia/port.c')
-rw-r--r-- | pjmedia/src/pjmedia/port.c | 65 |
1 files changed, 54 insertions, 11 deletions
diff --git a/pjmedia/src/pjmedia/port.c b/pjmedia/src/pjmedia/port.c index 1db5c742..e838263a 100644 --- a/pjmedia/src/pjmedia/port.c +++ b/pjmedia/src/pjmedia/port.c @@ -21,6 +21,7 @@ #include <pjmedia/errno.h> #include <pj/assert.h> #include <pj/log.h> +#include <pj/pool.h> #define THIS_FILE "port.c" @@ -37,24 +38,53 @@ PJ_DEF(pj_status_t) pjmedia_port_info_init( pjmedia_port_info *info, unsigned bits_per_sample, unsigned samples_per_frame) { +#define USEC_IN_SEC (pj_uint64_t)1000000 + unsigned frame_time_usec, avg_bps; + pj_bzero(info, sizeof(*info)); + info->signature = signature; + info->dir = PJMEDIA_DIR_ENCODING_DECODING; info->name = *name; + + frame_time_usec = (unsigned)(samples_per_frame * USEC_IN_SEC / + channel_count / clock_rate); + avg_bps = clock_rate * channel_count * bits_per_sample; + + pjmedia_format_init_audio(&info->fmt, PJMEDIA_FORMAT_L16, clock_rate, + channel_count, bits_per_sample, frame_time_usec, + avg_bps, avg_bps); + + return PJ_SUCCESS; +} + +PJ_DEF(pj_status_t) pjmedia_port_info_init2( pjmedia_port_info *info, + const pj_str_t *name, + unsigned signature, + pjmedia_dir dir, + const pjmedia_format *fmt) +{ + pj_bzero(info, sizeof(*info)); info->signature = signature; - info->type = PJMEDIA_TYPE_AUDIO; - info->has_info = PJ_TRUE; - info->need_info = PJ_FALSE; - info->pt = 0xFF; - info->encoding_name = pj_str("pcm"); - info->clock_rate = clock_rate; - info->channel_count = channel_count; - info->bits_per_sample = bits_per_sample; - info->samples_per_frame = samples_per_frame; - info->bytes_per_frame = samples_per_frame * bits_per_sample / 8; + info->dir = dir; + info->name = *name; + + pjmedia_format_copy(&info->fmt, fmt); return PJ_SUCCESS; } +/** + * Get a clock source from the port. + */ +PJ_DEF(pjmedia_clock_src *) pjmedia_port_get_clock_src( pjmedia_port *port, + pjmedia_dir dir ) +{ + if (port && port->get_clock_src) + return port->get_clock_src(port, dir); + else + return NULL; +} /** * Get a frame from the port (and subsequent downstream ports). @@ -77,7 +107,7 @@ PJ_DEF(pj_status_t) pjmedia_port_get_frame( pjmedia_port *port, * Put a frame to the port (and subsequent downstream ports). */ PJ_DEF(pj_status_t) pjmedia_port_put_frame( pjmedia_port *port, - const pjmedia_frame *frame ) + pjmedia_frame *frame ) { PJ_ASSERT_RETURN(port && frame, PJ_EINVAL); @@ -87,6 +117,19 @@ PJ_DEF(pj_status_t) pjmedia_port_put_frame( pjmedia_port *port, return PJ_EINVALIDOP; } +/* + * Get event publisher + */ +PJ_DEF(pjmedia_event_publisher*) +pjmedia_port_get_event_publisher(pjmedia_port *port) +{ + PJ_ASSERT_RETURN(port, NULL); + + if (port->get_event_pub) + return (*port->get_event_pub)(port); + + return NULL; +} /** * Destroy port (and subsequent downstream ports) |