winlin
|
11979229e6
|
Merge branch '2.0release' into develop
|
2015-10-26 13:34:44 +08:00 |
|
winlin
|
e08beba89e
|
fix the sed command for arm
|
2015-10-26 13:34:28 +08:00 |
|
winlin
|
45385241bb
|
fix the sed command for arm
|
2015-10-26 13:29:59 +08:00 |
|
winlin
|
b8f2ba4f0d
|
complete kafka
|
2015-10-23 14:42:05 +08:00 |
|
winlin
|
cbe4252b4d
|
refine code.
|
2015-10-23 14:42:04 +08:00 |
|
winlin
|
d2ca51ac50
|
notify kafka when client close
|
2015-10-23 14:42:04 +08:00 |
|
winlin
|
71451878c9
|
refine kafka, simplify code.
|
2015-10-23 14:42:04 +08:00 |
|
winlin
|
9a47390253
|
fix #467, support write log to kafka. 3.0.6
|
2015-10-23 14:42:04 +08:00 |
|
winlin
|
76cd3f8749
|
kafka convert json to producer message.
|
2015-10-23 14:42:04 +08:00 |
|
winlin
|
8e344f1c26
|
add producer api messages.
|
2015-10-23 14:42:04 +08:00 |
|
winlin
|
7a0aaf5900
|
kafka refine code
|
2015-10-23 14:42:04 +08:00 |
|
winlin
|
f9f5b56951
|
kakfa erase messages when wrote.
|
2015-10-23 14:42:04 +08:00 |
|
winlin
|
22fa9a0f1f
|
kafka use temp transport to fetch metadata.
|
2015-10-23 14:42:04 +08:00 |
|
winlin
|
531b658f8e
|
retry when metadata empty
|
2015-10-23 14:42:04 +08:00 |
|
winlin
|
61486a82aa
|
kafka use topic and partition cache
|
2015-10-23 14:42:04 +08:00 |
|
winlin
|
7013993c7a
|
kafka send the accept message.
|
2015-10-23 14:42:04 +08:00 |
|
winlin
|
de41c1c9d2
|
kafka refine comments.
|
2015-10-23 14:42:04 +08:00 |
|
winlin
|
31a77a83ed
|
convert metadata to partitions
|
2015-10-23 14:42:04 +08:00 |
|
winlin
|
f0e39cc330
|
support show the summary of kafka metadata.
|
2015-10-23 14:42:04 +08:00 |
|
winlin
|
d013374871
|
rename ISrsCodec size to nb_bytes.
|
2015-10-23 14:42:03 +08:00 |
|
winlin
|
33a015329d
|
add function to convert kafka array to vector
|
2015-10-23 14:42:03 +08:00 |
|
winlin
|
84b3981d47
|
refs #1670: support decode the metadata response.
|
2015-10-23 14:42:03 +08:00 |
|
winlin
|
7106934c3a
|
kafka producer use async interface to request metadata.
|
2015-10-23 14:42:03 +08:00 |
|
winlin
|
a108fa8d01
|
kafka recv and decode message.
|
2015-10-23 14:42:03 +08:00 |
|
winlin
|
493d282255
|
kafka refine array, to decode and create object.
|
2015-10-23 14:42:03 +08:00 |
|
winlin
|
c4862878d1
|
kafka rename message set to raw message set.
|
2015-10-23 14:42:03 +08:00 |
|
winlin
|
6e5ed11a00
|
for kafka, support correlation id cache.
|
2015-10-23 14:42:03 +08:00 |
|
winlin
|
2e67eb8786
|
refine comments for kafka messages.
|
2015-10-23 14:42:03 +08:00 |
|
winlin
|
3c64e4b957
|
kafka encode and send packet.
|
2015-10-23 14:42:03 +08:00 |
|
winlin
|
9117e1e918
|
extract ISrsCodec for code and decode object.
|
2015-10-23 14:42:03 +08:00 |
|
winlin
|
45755fd1e7
|
refine code for kakfa request/response, string/bytes.
|
2015-10-23 14:42:03 +08:00 |
|
winlin
|
8a4ec49064
|
add graph comments for size of request and response.
|
2015-10-23 14:42:03 +08:00 |
|
winlin
|
8974fe298b
|
connect to kafka and send metadata request.
|
2015-10-23 14:42:03 +08:00 |
|
winlin
|
a9fdb630d9
|
refine code, replace all rtmp connect by simple rtmp client.
|
2015-10-23 14:42:02 +08:00 |
|
winlin
|
a08d8f83d6
|
refine mpegts code, use simple rtmp client
|
2015-10-23 14:42:02 +08:00 |
|
winlin
|
ad9b377d96
|
refine forwarder code, use simple rtmp client.
|
2015-10-23 14:42:02 +08:00 |
|
winlin
|
0f4cb8ee00
|
refine code, remove the rtmp recv/send macro, use one macro.
|
2015-10-23 14:42:02 +08:00 |
|
winlin
|
12e013142d
|
refine code, use simple rtmp client.
|
2015-10-23 14:42:02 +08:00 |
|
winlin
|
bc27481886
|
refine code, use simple rtmp client.
|
2015-10-23 14:42:02 +08:00 |
|
winlin
|
e4c852945f
|
refine code, support override vhost
|
2015-10-23 14:42:02 +08:00 |
|
winlin
|
a9ad7b211b
|
refine simple rtmp client for post flv stream.
|
2015-10-23 14:42:02 +08:00 |
|
winlin
|
adb8f243bf
|
use simple rtmp client for raw connect app
|
2015-10-23 14:42:02 +08:00 |
|
winlin
|
24b3899972
|
use SrsTcpClient instead raw socket.
|
2015-10-23 14:42:02 +08:00 |
|
winlin
|
a9bb6061c3
|
use tcp client for raw connect.
|
2015-10-23 14:42:02 +08:00 |
|
winlin
|
20fcfb3eee
|
fix bug, use system utility
|
2015-10-23 14:42:02 +08:00 |
|
winlin
|
69cc01b696
|
use system utilities
|
2015-10-23 14:42:02 +08:00 |
|
winlin
|
908365a61a
|
use string for const char*
|
2015-10-23 14:42:02 +08:00 |
|
winlin
|
d9f991ed2f
|
use system utility for string finds
|
2015-10-23 14:42:02 +08:00 |
|
winlin
|
ca73534d7e
|
refine comments for api key
|
2015-10-23 14:42:01 +08:00 |
|
winlin
|
29122b6e70
|
fix #502, transcoder support snapshot.
|
2015-10-20 14:52:34 +08:00 |
|