个人简介
樽中酒不空
相关博文
- ·
- ·
- ·
- ·
- ·
- ·
- ·
- ·
- ·
- ·
分类： c/c
2013-04-24 14:22:08
librtmp库在rtmp_read阻塞，做成多线程时不方便，可以改成非阻塞：
跟踪代码，在
rtmp_read-->read_1_packet-->rtmp_getnextmediapacket里：
while (!bhasmediapacket && rtmp_isconnected(r)
&& rtmp_readpacket(r, packet))
{
...
bhasmediapacket = rtmp_clientpacket(r, packet);
if (!bhasmediapacket)
{
rtmppacket_free(packet);
}
...
}
当没有收到数据时，相当于执行while(1)，没有检测主动断开的事件。如果一直没有来数据，socket也不断，这就是个死循环了。rtmpdump是基于命令行的，可以直接ctrl-c退出了事，如果自己写一个重复的多路服务，这样不行，需要做非阻塞处理。
方法：
增加一个回调，检测是否需要中断:
在rtmp.h里增加一个结构体：
typedef struct aviointerruptcb {
int (*callback)(void*);
void *opaque;
} aviointerruptcb;
在rtmp里增加一个变量：
aviointerruptcb interrupt_callback;
rtmp_init的时候：
r->interrupt_callback.opaque = null;
r->interrupt_callback.callback = null;
在外面使用的时候，先定义一个函数：
static int decode_interrupt_cb(void *ctx)
{
myclass *is = (myclass *)ctx;
return is->abort_request;
}
rtmp初始化：
r->interrupt_callback.callback = decode_interrupt_cb;
r->interrupt_callback.opaque = this;
为了省事，回调方法从ffplay里拿来的。
跟踪代码，在
rtmp_read-->read_1_packet-->rtmp_getnextmediapacket里：
while (!bhasmediapacket && rtmp_isconnected(r)
&& rtmp_readpacket(r, packet))
{
...
bhasmediapacket = rtmp_clientpacket(r, packet);
if (!bhasmediapacket)
{
rtmppacket_free(packet);
}
...
}
当没有收到数据时，相当于执行while(1)，没有检测主动断开的事件。如果一直没有来数据，socket也不断，这就是个死循环了。rtmpdump是基于命令行的，可以直接ctrl-c退出了事，如果自己写一个重复的多路服务，这样不行，需要做非阻塞处理。
方法：
增加一个回调，检测是否需要中断:
在rtmp.h里增加一个结构体：
typedef struct aviointerruptcb {
int (*callback)(void*);
void *opaque;
} aviointerruptcb;
在rtmp里增加一个变量：
aviointerruptcb interrupt_callback;
rtmp_init的时候：
r->interrupt_callback.opaque = null;
r->interrupt_callback.callback = null;
在外面使用的时候，先定义一个函数：
static int decode_interrupt_cb(void *ctx)
{
myclass *is = (myclass *)ctx;
return is->abort_request;
}
rtmp初始化：
r->interrupt_callback.callback = decode_interrupt_cb;
r->interrupt_callback.opaque = this;
为了省事，回调方法从ffplay里拿来的。
给主人留下些什么吧！~~