You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

1739 lines
56KB

  1. /*
  2. * RTMP network protocol
  3. * Copyright (c) 2009 Kostya Shishkov
  4. *
  5. * This file is part of Libav.
  6. *
  7. * Libav is free software; you can redistribute it and/or
  8. * modify it under the terms of the GNU Lesser General Public
  9. * License as published by the Free Software Foundation; either
  10. * version 2.1 of the License, or (at your option) any later version.
  11. *
  12. * Libav is distributed in the hope that it will be useful,
  13. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  14. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  15. * Lesser General Public License for more details.
  16. *
  17. * You should have received a copy of the GNU Lesser General Public
  18. * License along with Libav; if not, write to the Free Software
  19. * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
  20. */
  21. /**
  22. * @file
  23. * RTMP protocol
  24. */
  25. #include "libavcodec/bytestream.h"
  26. #include "libavutil/avstring.h"
  27. #include "libavutil/intfloat.h"
  28. #include "libavutil/lfg.h"
  29. #include "libavutil/opt.h"
  30. #include "libavutil/sha.h"
  31. #include "avformat.h"
  32. #include "internal.h"
  33. #include "network.h"
  34. #include "flv.h"
  35. #include "rtmp.h"
  36. #include "rtmpcrypt.h"
  37. #include "rtmppkt.h"
  38. #include "url.h"
  39. //#define DEBUG
  40. #define APP_MAX_LENGTH 128
  41. #define PLAYPATH_MAX_LENGTH 256
  42. #define TCURL_MAX_LENGTH 512
  43. #define FLASHVER_MAX_LENGTH 64
  44. /** RTMP protocol handler state */
  45. typedef enum {
  46. STATE_START, ///< client has not done anything yet
  47. STATE_HANDSHAKED, ///< client has performed handshake
  48. STATE_FCPUBLISH, ///< client FCPublishing stream (for output)
  49. STATE_PLAYING, ///< client has started receiving multimedia data from server
  50. STATE_PUBLISHING, ///< client has started sending multimedia data to server (for output)
  51. STATE_STOPPED, ///< the broadcast has been stopped
  52. } ClientState;
  53. typedef struct TrackedMethod {
  54. char *name;
  55. int id;
  56. } TrackedMethod;
  57. /** protocol handler context */
  58. typedef struct RTMPContext {
  59. const AVClass *class;
  60. URLContext* stream; ///< TCP stream used in interactions with RTMP server
  61. RTMPPacket prev_pkt[2][RTMP_CHANNELS]; ///< packet history used when reading and sending packets
  62. int in_chunk_size; ///< size of the chunks incoming RTMP packets are divided into
  63. int out_chunk_size; ///< size of the chunks outgoing RTMP packets are divided into
  64. int is_input; ///< input/output flag
  65. char *playpath; ///< stream identifier to play (with possible "mp4:" prefix)
  66. int live; ///< 0: recorded, -1: live, -2: both
  67. char *app; ///< name of application
  68. char *conn; ///< append arbitrary AMF data to the Connect message
  69. ClientState state; ///< current state
  70. int main_channel_id; ///< an additional channel ID which is used for some invocations
  71. uint8_t* flv_data; ///< buffer with data for demuxer
  72. int flv_size; ///< current buffer size
  73. int flv_off; ///< number of bytes read from current buffer
  74. int flv_nb_packets; ///< number of flv packets published
  75. RTMPPacket out_pkt; ///< rtmp packet, created from flv a/v or metadata (for output)
  76. uint32_t client_report_size; ///< number of bytes after which client should report to server
  77. uint32_t bytes_read; ///< number of bytes read from server
  78. uint32_t last_bytes_read; ///< number of bytes read last reported to server
  79. int skip_bytes; ///< number of bytes to skip from the input FLV stream in the next write call
  80. uint8_t flv_header[11]; ///< partial incoming flv packet header
  81. int flv_header_bytes; ///< number of initialized bytes in flv_header
  82. int nb_invokes; ///< keeps track of invoke messages
  83. char* tcurl; ///< url of the target stream
  84. char* flashver; ///< version of the flash plugin
  85. char* swfurl; ///< url of the swf player
  86. char* pageurl; ///< url of the web page
  87. char* subscribe; ///< name of live stream to subscribe
  88. int server_bw; ///< server bandwidth
  89. int client_buffer_time; ///< client buffer time in ms
  90. int flush_interval; ///< number of packets flushed in the same request (RTMPT only)
  91. int encrypted; ///< use an encrypted connection (RTMPE only)
  92. TrackedMethod*tracked_methods; ///< tracked methods buffer
  93. int nb_tracked_methods; ///< number of tracked methods
  94. int tracked_methods_size; ///< size of the tracked methods buffer
  95. } RTMPContext;
  96. #define PLAYER_KEY_OPEN_PART_LEN 30 ///< length of partial key used for first client digest signing
  97. /** Client key used for digest signing */
  98. static const uint8_t rtmp_player_key[] = {
  99. 'G', 'e', 'n', 'u', 'i', 'n', 'e', ' ', 'A', 'd', 'o', 'b', 'e', ' ',
  100. 'F', 'l', 'a', 's', 'h', ' ', 'P', 'l', 'a', 'y', 'e', 'r', ' ', '0', '0', '1',
  101. 0xF0, 0xEE, 0xC2, 0x4A, 0x80, 0x68, 0xBE, 0xE8, 0x2E, 0x00, 0xD0, 0xD1, 0x02,
  102. 0x9E, 0x7E, 0x57, 0x6E, 0xEC, 0x5D, 0x2D, 0x29, 0x80, 0x6F, 0xAB, 0x93, 0xB8,
  103. 0xE6, 0x36, 0xCF, 0xEB, 0x31, 0xAE
  104. };
  105. #define SERVER_KEY_OPEN_PART_LEN 36 ///< length of partial key used for first server digest signing
  106. /** Key used for RTMP server digest signing */
  107. static const uint8_t rtmp_server_key[] = {
  108. 'G', 'e', 'n', 'u', 'i', 'n', 'e', ' ', 'A', 'd', 'o', 'b', 'e', ' ',
  109. 'F', 'l', 'a', 's', 'h', ' ', 'M', 'e', 'd', 'i', 'a', ' ',
  110. 'S', 'e', 'r', 'v', 'e', 'r', ' ', '0', '0', '1',
  111. 0xF0, 0xEE, 0xC2, 0x4A, 0x80, 0x68, 0xBE, 0xE8, 0x2E, 0x00, 0xD0, 0xD1, 0x02,
  112. 0x9E, 0x7E, 0x57, 0x6E, 0xEC, 0x5D, 0x2D, 0x29, 0x80, 0x6F, 0xAB, 0x93, 0xB8,
  113. 0xE6, 0x36, 0xCF, 0xEB, 0x31, 0xAE
  114. };
  115. static int add_tracked_method(RTMPContext *rt, const char *name, int id)
  116. {
  117. void *ptr;
  118. if (rt->nb_tracked_methods + 1 > rt->tracked_methods_size) {
  119. rt->tracked_methods_size = (rt->nb_tracked_methods + 1) * 2;
  120. ptr = av_realloc(rt->tracked_methods,
  121. rt->tracked_methods_size * sizeof(*rt->tracked_methods));
  122. if (!ptr)
  123. return AVERROR(ENOMEM);
  124. rt->tracked_methods = ptr;
  125. }
  126. rt->tracked_methods[rt->nb_tracked_methods].name = av_strdup(name);
  127. if (!rt->tracked_methods[rt->nb_tracked_methods].name)
  128. return AVERROR(ENOMEM);
  129. rt->tracked_methods[rt->nb_tracked_methods].id = id;
  130. rt->nb_tracked_methods++;
  131. return 0;
  132. }
  133. static void del_tracked_method(RTMPContext *rt, int index)
  134. {
  135. memmove(&rt->tracked_methods[index], &rt->tracked_methods[index + 1],
  136. sizeof(*rt->tracked_methods) * (rt->nb_tracked_methods - index - 1));
  137. rt->nb_tracked_methods--;
  138. }
  139. static int find_tracked_method(URLContext *s, RTMPPacket *pkt, int offset,
  140. char **tracked_method)
  141. {
  142. RTMPContext *rt = s->priv_data;
  143. GetByteContext gbc;
  144. double pkt_id;
  145. int ret;
  146. int i;
  147. bytestream2_init(&gbc, pkt->data + offset, pkt->data_size - offset);
  148. if ((ret = ff_amf_read_number(&gbc, &pkt_id)) < 0)
  149. return ret;
  150. for (i = 0; i < rt->nb_tracked_methods; i++) {
  151. if (rt->tracked_methods[i].id != pkt_id)
  152. continue;
  153. *tracked_method = rt->tracked_methods[i].name;
  154. del_tracked_method(rt, i);
  155. break;
  156. }
  157. return 0;
  158. }
  159. static void free_tracked_methods(RTMPContext *rt)
  160. {
  161. int i;
  162. for (i = 0; i < rt->nb_tracked_methods; i ++)
  163. av_free(rt->tracked_methods[i].name);
  164. av_free(rt->tracked_methods);
  165. }
  166. static int rtmp_send_packet(RTMPContext *rt, RTMPPacket *pkt, int track)
  167. {
  168. int ret;
  169. if (pkt->type == RTMP_PT_INVOKE && track) {
  170. GetByteContext gbc;
  171. char name[128];
  172. double pkt_id;
  173. int len;
  174. bytestream2_init(&gbc, pkt->data, pkt->data_size);
  175. if ((ret = ff_amf_read_string(&gbc, name, sizeof(name), &len)) < 0)
  176. goto fail;
  177. if ((ret = ff_amf_read_number(&gbc, &pkt_id)) < 0)
  178. goto fail;
  179. if ((ret = add_tracked_method(rt, name, pkt_id)) < 0)
  180. goto fail;
  181. }
  182. ret = ff_rtmp_packet_write(rt->stream, pkt, rt->out_chunk_size,
  183. rt->prev_pkt[1]);
  184. fail:
  185. ff_rtmp_packet_destroy(pkt);
  186. return ret;
  187. }
  188. static int rtmp_write_amf_data(URLContext *s, char *param, uint8_t **p)
  189. {
  190. char *field, *value;
  191. char type;
  192. /* The type must be B for Boolean, N for number, S for string, O for
  193. * object, or Z for null. For Booleans the data must be either 0 or 1 for
  194. * FALSE or TRUE, respectively. Likewise for Objects the data must be
  195. * 0 or 1 to end or begin an object, respectively. Data items in subobjects
  196. * may be named, by prefixing the type with 'N' and specifying the name
  197. * before the value (ie. NB:myFlag:1). This option may be used multiple times
  198. * to construct arbitrary AMF sequences. */
  199. if (param[0] && param[1] == ':') {
  200. type = param[0];
  201. value = param + 2;
  202. } else if (param[0] == 'N' && param[1] && param[2] == ':') {
  203. type = param[1];
  204. field = param + 3;
  205. value = strchr(field, ':');
  206. if (!value)
  207. goto fail;
  208. *value = '\0';
  209. value++;
  210. if (!field || !value)
  211. goto fail;
  212. ff_amf_write_field_name(p, field);
  213. } else {
  214. goto fail;
  215. }
  216. switch (type) {
  217. case 'B':
  218. ff_amf_write_bool(p, value[0] != '0');
  219. break;
  220. case 'S':
  221. ff_amf_write_string(p, value);
  222. break;
  223. case 'N':
  224. ff_amf_write_number(p, strtod(value, NULL));
  225. break;
  226. case 'Z':
  227. ff_amf_write_null(p);
  228. break;
  229. case 'O':
  230. if (value[0] != '0')
  231. ff_amf_write_object_start(p);
  232. else
  233. ff_amf_write_object_end(p);
  234. break;
  235. default:
  236. goto fail;
  237. break;
  238. }
  239. return 0;
  240. fail:
  241. av_log(s, AV_LOG_ERROR, "Invalid AMF parameter: %s\n", param);
  242. return AVERROR(EINVAL);
  243. }
  244. /**
  245. * Generate 'connect' call and send it to the server.
  246. */
  247. static int gen_connect(URLContext *s, RTMPContext *rt)
  248. {
  249. RTMPPacket pkt;
  250. uint8_t *p;
  251. int ret;
  252. if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE,
  253. 0, 4096)) < 0)
  254. return ret;
  255. p = pkt.data;
  256. ff_amf_write_string(&p, "connect");
  257. ff_amf_write_number(&p, ++rt->nb_invokes);
  258. ff_amf_write_object_start(&p);
  259. ff_amf_write_field_name(&p, "app");
  260. ff_amf_write_string(&p, rt->app);
  261. if (!rt->is_input) {
  262. ff_amf_write_field_name(&p, "type");
  263. ff_amf_write_string(&p, "nonprivate");
  264. }
  265. ff_amf_write_field_name(&p, "flashVer");
  266. ff_amf_write_string(&p, rt->flashver);
  267. if (rt->swfurl) {
  268. ff_amf_write_field_name(&p, "swfUrl");
  269. ff_amf_write_string(&p, rt->swfurl);
  270. }
  271. ff_amf_write_field_name(&p, "tcUrl");
  272. ff_amf_write_string(&p, rt->tcurl);
  273. if (rt->is_input) {
  274. ff_amf_write_field_name(&p, "fpad");
  275. ff_amf_write_bool(&p, 0);
  276. ff_amf_write_field_name(&p, "capabilities");
  277. ff_amf_write_number(&p, 15.0);
  278. /* Tell the server we support all the audio codecs except
  279. * SUPPORT_SND_INTEL (0x0008) and SUPPORT_SND_UNUSED (0x0010)
  280. * which are unused in the RTMP protocol implementation. */
  281. ff_amf_write_field_name(&p, "audioCodecs");
  282. ff_amf_write_number(&p, 4071.0);
  283. ff_amf_write_field_name(&p, "videoCodecs");
  284. ff_amf_write_number(&p, 252.0);
  285. ff_amf_write_field_name(&p, "videoFunction");
  286. ff_amf_write_number(&p, 1.0);
  287. if (rt->pageurl) {
  288. ff_amf_write_field_name(&p, "pageUrl");
  289. ff_amf_write_string(&p, rt->pageurl);
  290. }
  291. }
  292. ff_amf_write_object_end(&p);
  293. if (rt->conn) {
  294. char *param = rt->conn;
  295. // Write arbitrary AMF data to the Connect message.
  296. while (param != NULL) {
  297. char *sep;
  298. param += strspn(param, " ");
  299. if (!*param)
  300. break;
  301. sep = strchr(param, ' ');
  302. if (sep)
  303. *sep = '\0';
  304. if ((ret = rtmp_write_amf_data(s, param, &p)) < 0) {
  305. // Invalid AMF parameter.
  306. ff_rtmp_packet_destroy(&pkt);
  307. return ret;
  308. }
  309. if (sep)
  310. param = sep + 1;
  311. else
  312. break;
  313. }
  314. }
  315. pkt.data_size = p - pkt.data;
  316. return rtmp_send_packet(rt, &pkt, 1);
  317. }
  318. /**
  319. * Generate 'releaseStream' call and send it to the server. It should make
  320. * the server release some channel for media streams.
  321. */
  322. static int gen_release_stream(URLContext *s, RTMPContext *rt)
  323. {
  324. RTMPPacket pkt;
  325. uint8_t *p;
  326. int ret;
  327. if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE,
  328. 0, 29 + strlen(rt->playpath))) < 0)
  329. return ret;
  330. av_log(s, AV_LOG_DEBUG, "Releasing stream...\n");
  331. p = pkt.data;
  332. ff_amf_write_string(&p, "releaseStream");
  333. ff_amf_write_number(&p, ++rt->nb_invokes);
  334. ff_amf_write_null(&p);
  335. ff_amf_write_string(&p, rt->playpath);
  336. return rtmp_send_packet(rt, &pkt, 0);
  337. }
  338. /**
  339. * Generate 'FCPublish' call and send it to the server. It should make
  340. * the server preapare for receiving media streams.
  341. */
  342. static int gen_fcpublish_stream(URLContext *s, RTMPContext *rt)
  343. {
  344. RTMPPacket pkt;
  345. uint8_t *p;
  346. int ret;
  347. if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE,
  348. 0, 25 + strlen(rt->playpath))) < 0)
  349. return ret;
  350. av_log(s, AV_LOG_DEBUG, "FCPublish stream...\n");
  351. p = pkt.data;
  352. ff_amf_write_string(&p, "FCPublish");
  353. ff_amf_write_number(&p, ++rt->nb_invokes);
  354. ff_amf_write_null(&p);
  355. ff_amf_write_string(&p, rt->playpath);
  356. return rtmp_send_packet(rt, &pkt, 0);
  357. }
  358. /**
  359. * Generate 'FCUnpublish' call and send it to the server. It should make
  360. * the server destroy stream.
  361. */
  362. static int gen_fcunpublish_stream(URLContext *s, RTMPContext *rt)
  363. {
  364. RTMPPacket pkt;
  365. uint8_t *p;
  366. int ret;
  367. if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE,
  368. 0, 27 + strlen(rt->playpath))) < 0)
  369. return ret;
  370. av_log(s, AV_LOG_DEBUG, "UnPublishing stream...\n");
  371. p = pkt.data;
  372. ff_amf_write_string(&p, "FCUnpublish");
  373. ff_amf_write_number(&p, ++rt->nb_invokes);
  374. ff_amf_write_null(&p);
  375. ff_amf_write_string(&p, rt->playpath);
  376. return rtmp_send_packet(rt, &pkt, 0);
  377. }
  378. /**
  379. * Generate 'createStream' call and send it to the server. It should make
  380. * the server allocate some channel for media streams.
  381. */
  382. static int gen_create_stream(URLContext *s, RTMPContext *rt)
  383. {
  384. RTMPPacket pkt;
  385. uint8_t *p;
  386. int ret;
  387. av_log(s, AV_LOG_DEBUG, "Creating stream...\n");
  388. if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE,
  389. 0, 25)) < 0)
  390. return ret;
  391. p = pkt.data;
  392. ff_amf_write_string(&p, "createStream");
  393. ff_amf_write_number(&p, ++rt->nb_invokes);
  394. ff_amf_write_null(&p);
  395. return rtmp_send_packet(rt, &pkt, 1);
  396. }
  397. /**
  398. * Generate 'deleteStream' call and send it to the server. It should make
  399. * the server remove some channel for media streams.
  400. */
  401. static int gen_delete_stream(URLContext *s, RTMPContext *rt)
  402. {
  403. RTMPPacket pkt;
  404. uint8_t *p;
  405. int ret;
  406. av_log(s, AV_LOG_DEBUG, "Deleting stream...\n");
  407. if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE,
  408. 0, 34)) < 0)
  409. return ret;
  410. p = pkt.data;
  411. ff_amf_write_string(&p, "deleteStream");
  412. ff_amf_write_number(&p, ++rt->nb_invokes);
  413. ff_amf_write_null(&p);
  414. ff_amf_write_number(&p, rt->main_channel_id);
  415. return rtmp_send_packet(rt, &pkt, 0);
  416. }
  417. /**
  418. * Generate client buffer time and send it to the server.
  419. */
  420. static int gen_buffer_time(URLContext *s, RTMPContext *rt)
  421. {
  422. RTMPPacket pkt;
  423. uint8_t *p;
  424. int ret;
  425. if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL, RTMP_PT_PING,
  426. 1, 10)) < 0)
  427. return ret;
  428. p = pkt.data;
  429. bytestream_put_be16(&p, 3);
  430. bytestream_put_be32(&p, rt->main_channel_id);
  431. bytestream_put_be32(&p, rt->client_buffer_time);
  432. return rtmp_send_packet(rt, &pkt, 0);
  433. }
  434. /**
  435. * Generate 'play' call and send it to the server, then ping the server
  436. * to start actual playing.
  437. */
  438. static int gen_play(URLContext *s, RTMPContext *rt)
  439. {
  440. RTMPPacket pkt;
  441. uint8_t *p;
  442. int ret;
  443. av_log(s, AV_LOG_DEBUG, "Sending play command for '%s'\n", rt->playpath);
  444. if ((ret = ff_rtmp_packet_create(&pkt, RTMP_VIDEO_CHANNEL, RTMP_PT_INVOKE,
  445. 0, 29 + strlen(rt->playpath))) < 0)
  446. return ret;
  447. pkt.extra = rt->main_channel_id;
  448. p = pkt.data;
  449. ff_amf_write_string(&p, "play");
  450. ff_amf_write_number(&p, ++rt->nb_invokes);
  451. ff_amf_write_null(&p);
  452. ff_amf_write_string(&p, rt->playpath);
  453. ff_amf_write_number(&p, rt->live);
  454. return rtmp_send_packet(rt, &pkt, 1);
  455. }
  456. /**
  457. * Generate 'publish' call and send it to the server.
  458. */
  459. static int gen_publish(URLContext *s, RTMPContext *rt)
  460. {
  461. RTMPPacket pkt;
  462. uint8_t *p;
  463. int ret;
  464. av_log(s, AV_LOG_DEBUG, "Sending publish command for '%s'\n", rt->playpath);
  465. if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SOURCE_CHANNEL, RTMP_PT_INVOKE,
  466. 0, 30 + strlen(rt->playpath))) < 0)
  467. return ret;
  468. pkt.extra = rt->main_channel_id;
  469. p = pkt.data;
  470. ff_amf_write_string(&p, "publish");
  471. ff_amf_write_number(&p, ++rt->nb_invokes);
  472. ff_amf_write_null(&p);
  473. ff_amf_write_string(&p, rt->playpath);
  474. ff_amf_write_string(&p, "live");
  475. return rtmp_send_packet(rt, &pkt, 1);
  476. }
  477. /**
  478. * Generate ping reply and send it to the server.
  479. */
  480. static int gen_pong(URLContext *s, RTMPContext *rt, RTMPPacket *ppkt)
  481. {
  482. RTMPPacket pkt;
  483. uint8_t *p;
  484. int ret;
  485. if (ppkt->data_size < 6) {
  486. av_log(s, AV_LOG_ERROR, "Too short ping packet (%d)\n",
  487. ppkt->data_size);
  488. return AVERROR_INVALIDDATA;
  489. }
  490. if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL, RTMP_PT_PING,
  491. ppkt->timestamp + 1, 6)) < 0)
  492. return ret;
  493. p = pkt.data;
  494. bytestream_put_be16(&p, 7);
  495. bytestream_put_be32(&p, AV_RB32(ppkt->data+2));
  496. return rtmp_send_packet(rt, &pkt, 0);
  497. }
  498. /**
  499. * Generate server bandwidth message and send it to the server.
  500. */
  501. static int gen_server_bw(URLContext *s, RTMPContext *rt)
  502. {
  503. RTMPPacket pkt;
  504. uint8_t *p;
  505. int ret;
  506. if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL, RTMP_PT_SERVER_BW,
  507. 0, 4)) < 0)
  508. return ret;
  509. p = pkt.data;
  510. bytestream_put_be32(&p, rt->server_bw);
  511. return rtmp_send_packet(rt, &pkt, 0);
  512. }
  513. /**
  514. * Generate check bandwidth message and send it to the server.
  515. */
  516. static int gen_check_bw(URLContext *s, RTMPContext *rt)
  517. {
  518. RTMPPacket pkt;
  519. uint8_t *p;
  520. int ret;
  521. if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE,
  522. 0, 21)) < 0)
  523. return ret;
  524. p = pkt.data;
  525. ff_amf_write_string(&p, "_checkbw");
  526. ff_amf_write_number(&p, RTMP_NOTIFICATION);
  527. ff_amf_write_null(&p);
  528. return rtmp_send_packet(rt, &pkt, 0);
  529. }
  530. /**
  531. * Generate report on bytes read so far and send it to the server.
  532. */
  533. static int gen_bytes_read(URLContext *s, RTMPContext *rt, uint32_t ts)
  534. {
  535. RTMPPacket pkt;
  536. uint8_t *p;
  537. int ret;
  538. if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL, RTMP_PT_BYTES_READ,
  539. ts, 4)) < 0)
  540. return ret;
  541. p = pkt.data;
  542. bytestream_put_be32(&p, rt->bytes_read);
  543. return rtmp_send_packet(rt, &pkt, 0);
  544. }
  545. static int gen_fcsubscribe_stream(URLContext *s, RTMPContext *rt,
  546. const char *subscribe)
  547. {
  548. RTMPPacket pkt;
  549. uint8_t *p;
  550. int ret;
  551. if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE,
  552. 0, 27 + strlen(subscribe))) < 0)
  553. return ret;
  554. p = pkt.data;
  555. ff_amf_write_string(&p, "FCSubscribe");
  556. ff_amf_write_number(&p, ++rt->nb_invokes);
  557. ff_amf_write_null(&p);
  558. ff_amf_write_string(&p, subscribe);
  559. return rtmp_send_packet(rt, &pkt, 1);
  560. }
  561. int ff_rtmp_calc_digest(const uint8_t *src, int len, int gap,
  562. const uint8_t *key, int keylen, uint8_t *dst)
  563. {
  564. struct AVSHA *sha;
  565. uint8_t hmac_buf[64+32] = {0};
  566. int i;
  567. sha = av_mallocz(av_sha_size);
  568. if (!sha)
  569. return AVERROR(ENOMEM);
  570. if (keylen < 64) {
  571. memcpy(hmac_buf, key, keylen);
  572. } else {
  573. av_sha_init(sha, 256);
  574. av_sha_update(sha,key, keylen);
  575. av_sha_final(sha, hmac_buf);
  576. }
  577. for (i = 0; i < 64; i++)
  578. hmac_buf[i] ^= HMAC_IPAD_VAL;
  579. av_sha_init(sha, 256);
  580. av_sha_update(sha, hmac_buf, 64);
  581. if (gap <= 0) {
  582. av_sha_update(sha, src, len);
  583. } else { //skip 32 bytes used for storing digest
  584. av_sha_update(sha, src, gap);
  585. av_sha_update(sha, src + gap + 32, len - gap - 32);
  586. }
  587. av_sha_final(sha, hmac_buf + 64);
  588. for (i = 0; i < 64; i++)
  589. hmac_buf[i] ^= HMAC_IPAD_VAL ^ HMAC_OPAD_VAL; //reuse XORed key for opad
  590. av_sha_init(sha, 256);
  591. av_sha_update(sha, hmac_buf, 64+32);
  592. av_sha_final(sha, dst);
  593. av_free(sha);
  594. return 0;
  595. }
  596. int ff_rtmp_calc_digest_pos(const uint8_t *buf, int off, int mod_val,
  597. int add_val)
  598. {
  599. int i, digest_pos = 0;
  600. for (i = 0; i < 4; i++)
  601. digest_pos += buf[i + off];
  602. digest_pos = digest_pos % mod_val + add_val;
  603. return digest_pos;
  604. }
  605. /**
  606. * Put HMAC-SHA2 digest of packet data (except for the bytes where this digest
  607. * will be stored) into that packet.
  608. *
  609. * @param buf handshake data (1536 bytes)
  610. * @param encrypted use an encrypted connection (RTMPE)
  611. * @return offset to the digest inside input data
  612. */
  613. static int rtmp_handshake_imprint_with_digest(uint8_t *buf, int encrypted)
  614. {
  615. int ret, digest_pos;
  616. if (encrypted)
  617. digest_pos = ff_rtmp_calc_digest_pos(buf, 772, 728, 776);
  618. else
  619. digest_pos = ff_rtmp_calc_digest_pos(buf, 8, 728, 12);
  620. ret = ff_rtmp_calc_digest(buf, RTMP_HANDSHAKE_PACKET_SIZE, digest_pos,
  621. rtmp_player_key, PLAYER_KEY_OPEN_PART_LEN,
  622. buf + digest_pos);
  623. if (ret < 0)
  624. return ret;
  625. return digest_pos;
  626. }
  627. /**
  628. * Verify that the received server response has the expected digest value.
  629. *
  630. * @param buf handshake data received from the server (1536 bytes)
  631. * @param off position to search digest offset from
  632. * @return 0 if digest is valid, digest position otherwise
  633. */
  634. static int rtmp_validate_digest(uint8_t *buf, int off)
  635. {
  636. uint8_t digest[32];
  637. int ret, digest_pos;
  638. digest_pos = ff_rtmp_calc_digest_pos(buf, off, 728, off + 4);
  639. ret = ff_rtmp_calc_digest(buf, RTMP_HANDSHAKE_PACKET_SIZE, digest_pos,
  640. rtmp_server_key, SERVER_KEY_OPEN_PART_LEN,
  641. digest);
  642. if (ret < 0)
  643. return ret;
  644. if (!memcmp(digest, buf + digest_pos, 32))
  645. return digest_pos;
  646. return 0;
  647. }
  648. /**
  649. * Perform handshake with the server by means of exchanging pseudorandom data
  650. * signed with HMAC-SHA2 digest.
  651. *
  652. * @return 0 if handshake succeeds, negative value otherwise
  653. */
  654. static int rtmp_handshake(URLContext *s, RTMPContext *rt)
  655. {
  656. AVLFG rnd;
  657. uint8_t tosend [RTMP_HANDSHAKE_PACKET_SIZE+1] = {
  658. 3, // unencrypted data
  659. 0, 0, 0, 0, // client uptime
  660. RTMP_CLIENT_VER1,
  661. RTMP_CLIENT_VER2,
  662. RTMP_CLIENT_VER3,
  663. RTMP_CLIENT_VER4,
  664. };
  665. uint8_t clientdata[RTMP_HANDSHAKE_PACKET_SIZE];
  666. uint8_t serverdata[RTMP_HANDSHAKE_PACKET_SIZE+1];
  667. int i;
  668. int server_pos, client_pos;
  669. uint8_t digest[32], signature[32];
  670. int ret, type = 0;
  671. av_log(s, AV_LOG_DEBUG, "Handshaking...\n");
  672. av_lfg_init(&rnd, 0xDEADC0DE);
  673. // generate handshake packet - 1536 bytes of pseudorandom data
  674. for (i = 9; i <= RTMP_HANDSHAKE_PACKET_SIZE; i++)
  675. tosend[i] = av_lfg_get(&rnd) >> 24;
  676. if (rt->encrypted && CONFIG_FFRTMPCRYPT_PROTOCOL) {
  677. /* When the client wants to use RTMPE, we have to change the command
  678. * byte to 0x06 which means to use encrypted data and we have to set
  679. * the flash version to at least 9.0.115.0. */
  680. tosend[0] = 6;
  681. tosend[5] = 128;
  682. tosend[6] = 0;
  683. tosend[7] = 3;
  684. tosend[8] = 2;
  685. /* Initialize the Diffie-Hellmann context and generate the public key
  686. * to send to the server. */
  687. if ((ret = ff_rtmpe_gen_pub_key(rt->stream, tosend + 1)) < 0)
  688. return ret;
  689. }
  690. client_pos = rtmp_handshake_imprint_with_digest(tosend + 1, rt->encrypted);
  691. if (client_pos < 0)
  692. return client_pos;
  693. if ((ret = ffurl_write(rt->stream, tosend,
  694. RTMP_HANDSHAKE_PACKET_SIZE + 1)) < 0) {
  695. av_log(s, AV_LOG_ERROR, "Cannot write RTMP handshake request\n");
  696. return ret;
  697. }
  698. if ((ret = ffurl_read_complete(rt->stream, serverdata,
  699. RTMP_HANDSHAKE_PACKET_SIZE + 1)) < 0) {
  700. av_log(s, AV_LOG_ERROR, "Cannot read RTMP handshake response\n");
  701. return ret;
  702. }
  703. if ((ret = ffurl_read_complete(rt->stream, clientdata,
  704. RTMP_HANDSHAKE_PACKET_SIZE)) < 0) {
  705. av_log(s, AV_LOG_ERROR, "Cannot read RTMP handshake response\n");
  706. return ret;
  707. }
  708. av_log(s, AV_LOG_DEBUG, "Type answer %d\n", serverdata[0]);
  709. av_log(s, AV_LOG_DEBUG, "Server version %d.%d.%d.%d\n",
  710. serverdata[5], serverdata[6], serverdata[7], serverdata[8]);
  711. if (rt->is_input && serverdata[5] >= 3) {
  712. server_pos = rtmp_validate_digest(serverdata + 1, 772);
  713. if (server_pos < 0)
  714. return server_pos;
  715. if (!server_pos) {
  716. type = 1;
  717. server_pos = rtmp_validate_digest(serverdata + 1, 8);
  718. if (server_pos < 0)
  719. return server_pos;
  720. if (!server_pos) {
  721. av_log(s, AV_LOG_ERROR, "Server response validating failed\n");
  722. return AVERROR(EIO);
  723. }
  724. }
  725. ret = ff_rtmp_calc_digest(tosend + 1 + client_pos, 32, 0,
  726. rtmp_server_key, sizeof(rtmp_server_key),
  727. digest);
  728. if (ret < 0)
  729. return ret;
  730. ret = ff_rtmp_calc_digest(clientdata, RTMP_HANDSHAKE_PACKET_SIZE - 32,
  731. 0, digest, 32, signature);
  732. if (ret < 0)
  733. return ret;
  734. if (rt->encrypted && CONFIG_FFRTMPCRYPT_PROTOCOL) {
  735. /* Compute the shared secret key sent by the server and initialize
  736. * the RC4 encryption. */
  737. if ((ret = ff_rtmpe_compute_secret_key(rt->stream, serverdata + 1,
  738. tosend + 1, type)) < 0)
  739. return ret;
  740. /* Encrypt the signature received by the server. */
  741. ff_rtmpe_encrypt_sig(rt->stream, signature, digest, serverdata[0]);
  742. }
  743. if (memcmp(signature, clientdata + RTMP_HANDSHAKE_PACKET_SIZE - 32, 32)) {
  744. av_log(s, AV_LOG_ERROR, "Signature mismatch\n");
  745. return AVERROR(EIO);
  746. }
  747. for (i = 0; i < RTMP_HANDSHAKE_PACKET_SIZE; i++)
  748. tosend[i] = av_lfg_get(&rnd) >> 24;
  749. ret = ff_rtmp_calc_digest(serverdata + 1 + server_pos, 32, 0,
  750. rtmp_player_key, sizeof(rtmp_player_key),
  751. digest);
  752. if (ret < 0)
  753. return ret;
  754. ret = ff_rtmp_calc_digest(tosend, RTMP_HANDSHAKE_PACKET_SIZE - 32, 0,
  755. digest, 32,
  756. tosend + RTMP_HANDSHAKE_PACKET_SIZE - 32);
  757. if (ret < 0)
  758. return ret;
  759. if (rt->encrypted && CONFIG_FFRTMPCRYPT_PROTOCOL) {
  760. /* Encrypt the signature to be send to the server. */
  761. ff_rtmpe_encrypt_sig(rt->stream, tosend +
  762. RTMP_HANDSHAKE_PACKET_SIZE - 32, digest,
  763. serverdata[0]);
  764. }
  765. // write reply back to the server
  766. if ((ret = ffurl_write(rt->stream, tosend,
  767. RTMP_HANDSHAKE_PACKET_SIZE)) < 0)
  768. return ret;
  769. if (rt->encrypted && CONFIG_FFRTMPCRYPT_PROTOCOL) {
  770. /* Set RC4 keys for encryption and update the keystreams. */
  771. if ((ret = ff_rtmpe_update_keystream(rt->stream)) < 0)
  772. return ret;
  773. }
  774. } else {
  775. if (rt->encrypted && CONFIG_FFRTMPCRYPT_PROTOCOL) {
  776. /* Compute the shared secret key sent by the server and initialize
  777. * the RC4 encryption. */
  778. if ((ret = ff_rtmpe_compute_secret_key(rt->stream, serverdata + 1,
  779. tosend + 1, 1)) < 0)
  780. return ret;
  781. if (serverdata[0] == 9) {
  782. /* Encrypt the signature received by the server. */
  783. ff_rtmpe_encrypt_sig(rt->stream, signature, digest,
  784. serverdata[0]);
  785. }
  786. }
  787. if ((ret = ffurl_write(rt->stream, serverdata + 1,
  788. RTMP_HANDSHAKE_PACKET_SIZE)) < 0)
  789. return ret;
  790. if (rt->encrypted && CONFIG_FFRTMPCRYPT_PROTOCOL) {
  791. /* Set RC4 keys for encryption and update the keystreams. */
  792. if ((ret = ff_rtmpe_update_keystream(rt->stream)) < 0)
  793. return ret;
  794. }
  795. }
  796. return 0;
  797. }
  798. static int handle_chunk_size(URLContext *s, RTMPPacket *pkt)
  799. {
  800. RTMPContext *rt = s->priv_data;
  801. int ret;
  802. if (pkt->data_size < 4) {
  803. av_log(s, AV_LOG_ERROR,
  804. "Too short chunk size change packet (%d)\n",
  805. pkt->data_size);
  806. return AVERROR_INVALIDDATA;
  807. }
  808. if (!rt->is_input) {
  809. /* Send the same chunk size change packet back to the server,
  810. * setting the outgoing chunk size to the same as the incoming one. */
  811. if ((ret = ff_rtmp_packet_write(rt->stream, pkt, rt->out_chunk_size,
  812. rt->prev_pkt[1])) < 0)
  813. return ret;
  814. rt->out_chunk_size = AV_RB32(pkt->data);
  815. }
  816. rt->in_chunk_size = AV_RB32(pkt->data);
  817. if (rt->in_chunk_size <= 0) {
  818. av_log(s, AV_LOG_ERROR, "Incorrect chunk size %d\n",
  819. rt->in_chunk_size);
  820. return AVERROR_INVALIDDATA;
  821. }
  822. av_log(s, AV_LOG_DEBUG, "New incoming chunk size = %d\n",
  823. rt->in_chunk_size);
  824. return 0;
  825. }
  826. static int handle_ping(URLContext *s, RTMPPacket *pkt)
  827. {
  828. RTMPContext *rt = s->priv_data;
  829. int t, ret;
  830. if (pkt->data_size < 2) {
  831. av_log(s, AV_LOG_ERROR, "Too short ping packet (%d)\n",
  832. pkt->data_size);
  833. return AVERROR_INVALIDDATA;
  834. }
  835. t = AV_RB16(pkt->data);
  836. if (t == 6) {
  837. if ((ret = gen_pong(s, rt, pkt)) < 0)
  838. return ret;
  839. }
  840. return 0;
  841. }
  842. static int handle_client_bw(URLContext *s, RTMPPacket *pkt)
  843. {
  844. RTMPContext *rt = s->priv_data;
  845. if (pkt->data_size < 4) {
  846. av_log(s, AV_LOG_ERROR,
  847. "Client bandwidth report packet is less than 4 bytes long (%d)\n",
  848. pkt->data_size);
  849. return AVERROR_INVALIDDATA;
  850. }
  851. rt->client_report_size = AV_RB32(pkt->data);
  852. if (rt->client_report_size <= 0) {
  853. av_log(s, AV_LOG_ERROR, "Incorrect client bandwidth %d\n",
  854. rt->client_report_size);
  855. return AVERROR_INVALIDDATA;
  856. }
  857. av_log(s, AV_LOG_DEBUG, "Client bandwidth = %d\n", rt->client_report_size);
  858. rt->client_report_size >>= 1;
  859. return 0;
  860. }
  861. static int handle_server_bw(URLContext *s, RTMPPacket *pkt)
  862. {
  863. RTMPContext *rt = s->priv_data;
  864. if (pkt->data_size < 4) {
  865. av_log(s, AV_LOG_ERROR,
  866. "Too short server bandwidth report packet (%d)\n",
  867. pkt->data_size);
  868. return AVERROR_INVALIDDATA;
  869. }
  870. rt->server_bw = AV_RB32(pkt->data);
  871. if (rt->server_bw <= 0) {
  872. av_log(s, AV_LOG_ERROR, "Incorrect server bandwidth %d\n",
  873. rt->server_bw);
  874. return AVERROR_INVALIDDATA;
  875. }
  876. av_log(s, AV_LOG_DEBUG, "Server bandwidth = %d\n", rt->server_bw);
  877. return 0;
  878. }
  879. static int handle_invoke_error(URLContext *s, RTMPPacket *pkt)
  880. {
  881. const uint8_t *data_end = pkt->data + pkt->data_size;
  882. uint8_t tmpstr[256];
  883. if (!ff_amf_get_field_value(pkt->data + 9, data_end,
  884. "description", tmpstr, sizeof(tmpstr))) {
  885. av_log(s, AV_LOG_ERROR, "Server error: %s\n", tmpstr);
  886. return -1;
  887. }
  888. return 0;
  889. }
  890. static int handle_invoke_result(URLContext *s, RTMPPacket *pkt)
  891. {
  892. RTMPContext *rt = s->priv_data;
  893. char *tracked_method = NULL;
  894. int ret = 0;
  895. if ((ret = find_tracked_method(s, pkt, 10, &tracked_method)) < 0)
  896. return ret;
  897. if (!tracked_method) {
  898. /* Ignore this reply when the current method is not tracked. */
  899. return ret;
  900. }
  901. if (!memcmp(tracked_method, "connect", 7)) {
  902. if (!rt->is_input) {
  903. if ((ret = gen_release_stream(s, rt)) < 0)
  904. goto fail;
  905. if ((ret = gen_fcpublish_stream(s, rt)) < 0)
  906. goto fail;
  907. } else {
  908. if ((ret = gen_server_bw(s, rt)) < 0)
  909. goto fail;
  910. }
  911. if ((ret = gen_create_stream(s, rt)) < 0)
  912. goto fail;
  913. if (rt->is_input) {
  914. /* Send the FCSubscribe command when the name of live
  915. * stream is defined by the user or if it's a live stream. */
  916. if (rt->subscribe) {
  917. if ((ret = gen_fcsubscribe_stream(s, rt, rt->subscribe)) < 0)
  918. goto fail;
  919. } else if (rt->live == -1) {
  920. if ((ret = gen_fcsubscribe_stream(s, rt, rt->playpath)) < 0)
  921. goto fail;
  922. }
  923. }
  924. } else if (!memcmp(tracked_method, "createStream", 12)) {
  925. //extract a number from the result
  926. if (pkt->data[10] || pkt->data[19] != 5 || pkt->data[20]) {
  927. av_log(s, AV_LOG_WARNING, "Unexpected reply on connect()\n");
  928. } else {
  929. rt->main_channel_id = av_int2double(AV_RB64(pkt->data + 21));
  930. }
  931. if (!rt->is_input) {
  932. if ((ret = gen_publish(s, rt)) < 0)
  933. goto fail;
  934. } else {
  935. if ((ret = gen_play(s, rt)) < 0)
  936. goto fail;
  937. if ((ret = gen_buffer_time(s, rt)) < 0)
  938. goto fail;
  939. }
  940. }
  941. fail:
  942. av_free(tracked_method);
  943. return ret;
  944. }
  945. static int handle_invoke_status(URLContext *s, RTMPPacket *pkt)
  946. {
  947. RTMPContext *rt = s->priv_data;
  948. const uint8_t *data_end = pkt->data + pkt->data_size;
  949. const uint8_t *ptr = pkt->data + 11;
  950. uint8_t tmpstr[256];
  951. int i, t;
  952. for (i = 0; i < 2; i++) {
  953. t = ff_amf_tag_size(ptr, data_end);
  954. if (t < 0)
  955. return 1;
  956. ptr += t;
  957. }
  958. t = ff_amf_get_field_value(ptr, data_end, "level", tmpstr, sizeof(tmpstr));
  959. if (!t && !strcmp(tmpstr, "error")) {
  960. if (!ff_amf_get_field_value(ptr, data_end,
  961. "description", tmpstr, sizeof(tmpstr)))
  962. av_log(s, AV_LOG_ERROR, "Server error: %s\n", tmpstr);
  963. return -1;
  964. }
  965. t = ff_amf_get_field_value(ptr, data_end, "code", tmpstr, sizeof(tmpstr));
  966. if (!t && !strcmp(tmpstr, "NetStream.Play.Start")) rt->state = STATE_PLAYING;
  967. if (!t && !strcmp(tmpstr, "NetStream.Play.Stop")) rt->state = STATE_STOPPED;
  968. if (!t && !strcmp(tmpstr, "NetStream.Play.UnpublishNotify")) rt->state = STATE_STOPPED;
  969. if (!t && !strcmp(tmpstr, "NetStream.Publish.Start")) rt->state = STATE_PUBLISHING;
  970. return 0;
  971. }
  972. static int handle_invoke(URLContext *s, RTMPPacket *pkt)
  973. {
  974. RTMPContext *rt = s->priv_data;
  975. int ret = 0;
  976. //TODO: check for the messages sent for wrong state?
  977. if (!memcmp(pkt->data, "\002\000\006_error", 9)) {
  978. if ((ret = handle_invoke_error(s, pkt)) < 0)
  979. return ret;
  980. } else if (!memcmp(pkt->data, "\002\000\007_result", 10)) {
  981. if ((ret = handle_invoke_result(s, pkt)) < 0)
  982. return ret;
  983. } else if (!memcmp(pkt->data, "\002\000\010onStatus", 11)) {
  984. if ((ret = handle_invoke_status(s, pkt)) < 0)
  985. return ret;
  986. } else if (!memcmp(pkt->data, "\002\000\010onBWDone", 11)) {
  987. if ((ret = gen_check_bw(s, rt)) < 0)
  988. return ret;
  989. }
  990. return ret;
  991. }
  992. /**
  993. * Parse received packet and possibly perform some action depending on
  994. * the packet contents.
  995. * @return 0 for no errors, negative values for serious errors which prevent
  996. * further communications, positive values for uncritical errors
  997. */
  998. static int rtmp_parse_result(URLContext *s, RTMPContext *rt, RTMPPacket *pkt)
  999. {
  1000. int ret;
  1001. #ifdef DEBUG
  1002. ff_rtmp_packet_dump(s, pkt);
  1003. #endif
  1004. switch (pkt->type) {
  1005. case RTMP_PT_BYTES_READ:
  1006. av_dlog(s, "received bytes read report\n");
  1007. break;
  1008. case RTMP_PT_CHUNK_SIZE:
  1009. if ((ret = handle_chunk_size(s, pkt)) < 0)
  1010. return ret;
  1011. break;
  1012. case RTMP_PT_PING:
  1013. if ((ret = handle_ping(s, pkt)) < 0)
  1014. return ret;
  1015. break;
  1016. case RTMP_PT_CLIENT_BW:
  1017. if ((ret = handle_client_bw(s, pkt)) < 0)
  1018. return ret;
  1019. break;
  1020. case RTMP_PT_SERVER_BW:
  1021. if ((ret = handle_server_bw(s, pkt)) < 0)
  1022. return ret;
  1023. break;
  1024. case RTMP_PT_INVOKE:
  1025. if ((ret = handle_invoke(s, pkt)) < 0)
  1026. return ret;
  1027. break;
  1028. case RTMP_PT_VIDEO:
  1029. case RTMP_PT_AUDIO:
  1030. case RTMP_PT_METADATA:
  1031. /* Audio, Video and Metadata packets are parsed in get_packet() */
  1032. break;
  1033. default:
  1034. av_log(s, AV_LOG_VERBOSE, "Unknown packet type received 0x%02X\n", pkt->type);
  1035. break;
  1036. }
  1037. return 0;
  1038. }
  1039. /**
  1040. * Interact with the server by receiving and sending RTMP packets until
  1041. * there is some significant data (media data or expected status notification).
  1042. *
  1043. * @param s reading context
  1044. * @param for_header non-zero value tells function to work until it
  1045. * gets notification from the server that playing has been started,
  1046. * otherwise function will work until some media data is received (or
  1047. * an error happens)
  1048. * @return 0 for successful operation, negative value in case of error
  1049. */
  1050. static int get_packet(URLContext *s, int for_header)
  1051. {
  1052. RTMPContext *rt = s->priv_data;
  1053. int ret;
  1054. uint8_t *p;
  1055. const uint8_t *next;
  1056. uint32_t data_size;
  1057. uint32_t ts, cts, pts=0;
  1058. if (rt->state == STATE_STOPPED)
  1059. return AVERROR_EOF;
  1060. for (;;) {
  1061. RTMPPacket rpkt = { 0 };
  1062. if ((ret = ff_rtmp_packet_read(rt->stream, &rpkt,
  1063. rt->in_chunk_size, rt->prev_pkt[0])) <= 0) {
  1064. if (ret == 0) {
  1065. return AVERROR(EAGAIN);
  1066. } else {
  1067. return AVERROR(EIO);
  1068. }
  1069. }
  1070. rt->bytes_read += ret;
  1071. if (rt->bytes_read > rt->last_bytes_read + rt->client_report_size) {
  1072. av_log(s, AV_LOG_DEBUG, "Sending bytes read report\n");
  1073. if ((ret = gen_bytes_read(s, rt, rpkt.timestamp + 1)) < 0)
  1074. return ret;
  1075. rt->last_bytes_read = rt->bytes_read;
  1076. }
  1077. ret = rtmp_parse_result(s, rt, &rpkt);
  1078. if (ret < 0) {//serious error in current packet
  1079. ff_rtmp_packet_destroy(&rpkt);
  1080. return ret;
  1081. }
  1082. if (rt->state == STATE_STOPPED) {
  1083. ff_rtmp_packet_destroy(&rpkt);
  1084. return AVERROR_EOF;
  1085. }
  1086. if (for_header && (rt->state == STATE_PLAYING || rt->state == STATE_PUBLISHING)) {
  1087. ff_rtmp_packet_destroy(&rpkt);
  1088. return 0;
  1089. }
  1090. if (!rpkt.data_size || !rt->is_input) {
  1091. ff_rtmp_packet_destroy(&rpkt);
  1092. continue;
  1093. }
  1094. if (rpkt.type == RTMP_PT_VIDEO || rpkt.type == RTMP_PT_AUDIO ||
  1095. (rpkt.type == RTMP_PT_NOTIFY && !memcmp("\002\000\012onMetaData", rpkt.data, 13))) {
  1096. ts = rpkt.timestamp;
  1097. // generate packet header and put data into buffer for FLV demuxer
  1098. rt->flv_off = 0;
  1099. rt->flv_size = rpkt.data_size + 15;
  1100. rt->flv_data = p = av_realloc(rt->flv_data, rt->flv_size);
  1101. bytestream_put_byte(&p, rpkt.type);
  1102. bytestream_put_be24(&p, rpkt.data_size);
  1103. bytestream_put_be24(&p, ts);
  1104. bytestream_put_byte(&p, ts >> 24);
  1105. bytestream_put_be24(&p, 0);
  1106. bytestream_put_buffer(&p, rpkt.data, rpkt.data_size);
  1107. bytestream_put_be32(&p, 0);
  1108. ff_rtmp_packet_destroy(&rpkt);
  1109. return 0;
  1110. } else if (rpkt.type == RTMP_PT_METADATA) {
  1111. // we got raw FLV data, make it available for FLV demuxer
  1112. rt->flv_off = 0;
  1113. rt->flv_size = rpkt.data_size;
  1114. rt->flv_data = av_realloc(rt->flv_data, rt->flv_size);
  1115. /* rewrite timestamps */
  1116. next = rpkt.data;
  1117. ts = rpkt.timestamp;
  1118. while (next - rpkt.data < rpkt.data_size - 11) {
  1119. next++;
  1120. data_size = bytestream_get_be24(&next);
  1121. p=next;
  1122. cts = bytestream_get_be24(&next);
  1123. cts |= bytestream_get_byte(&next) << 24;
  1124. if (pts==0)
  1125. pts=cts;
  1126. ts += cts - pts;
  1127. pts = cts;
  1128. bytestream_put_be24(&p, ts);
  1129. bytestream_put_byte(&p, ts >> 24);
  1130. next += data_size + 3 + 4;
  1131. }
  1132. memcpy(rt->flv_data, rpkt.data, rpkt.data_size);
  1133. ff_rtmp_packet_destroy(&rpkt);
  1134. return 0;
  1135. }
  1136. ff_rtmp_packet_destroy(&rpkt);
  1137. }
  1138. }
  1139. static int rtmp_close(URLContext *h)
  1140. {
  1141. RTMPContext *rt = h->priv_data;
  1142. int ret = 0;
  1143. if (!rt->is_input) {
  1144. rt->flv_data = NULL;
  1145. if (rt->out_pkt.data_size)
  1146. ff_rtmp_packet_destroy(&rt->out_pkt);
  1147. if (rt->state > STATE_FCPUBLISH)
  1148. ret = gen_fcunpublish_stream(h, rt);
  1149. }
  1150. if (rt->state > STATE_HANDSHAKED)
  1151. ret = gen_delete_stream(h, rt);
  1152. free_tracked_methods(rt);
  1153. av_freep(&rt->flv_data);
  1154. ffurl_close(rt->stream);
  1155. return ret;
  1156. }
  1157. /**
  1158. * Open RTMP connection and verify that the stream can be played.
  1159. *
  1160. * URL syntax: rtmp://server[:port][/app][/playpath]
  1161. * where 'app' is first one or two directories in the path
  1162. * (e.g. /ondemand/, /flash/live/, etc.)
  1163. * and 'playpath' is a file name (the rest of the path,
  1164. * may be prefixed with "mp4:")
  1165. */
  1166. static int rtmp_open(URLContext *s, const char *uri, int flags)
  1167. {
  1168. RTMPContext *rt = s->priv_data;
  1169. char proto[8], hostname[256], path[1024], *fname;
  1170. char *old_app;
  1171. uint8_t buf[2048];
  1172. int port;
  1173. AVDictionary *opts = NULL;
  1174. int ret;
  1175. rt->is_input = !(flags & AVIO_FLAG_WRITE);
  1176. av_url_split(proto, sizeof(proto), NULL, 0, hostname, sizeof(hostname), &port,
  1177. path, sizeof(path), s->filename);
  1178. if (!strcmp(proto, "rtmpt") || !strcmp(proto, "rtmpts")) {
  1179. if (!strcmp(proto, "rtmpts"))
  1180. av_dict_set(&opts, "ffrtmphttp_tls", "1", 1);
  1181. /* open the http tunneling connection */
  1182. ff_url_join(buf, sizeof(buf), "ffrtmphttp", NULL, hostname, port, NULL);
  1183. } else if (!strcmp(proto, "rtmps")) {
  1184. /* open the tls connection */
  1185. if (port < 0)
  1186. port = RTMPS_DEFAULT_PORT;
  1187. ff_url_join(buf, sizeof(buf), "tls", NULL, hostname, port, NULL);
  1188. } else if (!strcmp(proto, "rtmpe") || (!strcmp(proto, "rtmpte"))) {
  1189. if (!strcmp(proto, "rtmpte"))
  1190. av_dict_set(&opts, "ffrtmpcrypt_tunneling", "1", 1);
  1191. /* open the encrypted connection */
  1192. ff_url_join(buf, sizeof(buf), "ffrtmpcrypt", NULL, hostname, port, NULL);
  1193. rt->encrypted = 1;
  1194. } else {
  1195. /* open the tcp connection */
  1196. if (port < 0)
  1197. port = RTMP_DEFAULT_PORT;
  1198. ff_url_join(buf, sizeof(buf), "tcp", NULL, hostname, port, NULL);
  1199. }
  1200. if ((ret = ffurl_open(&rt->stream, buf, AVIO_FLAG_READ_WRITE,
  1201. &s->interrupt_callback, &opts)) < 0) {
  1202. av_log(s , AV_LOG_ERROR, "Cannot open connection %s\n", buf);
  1203. goto fail;
  1204. }
  1205. rt->state = STATE_START;
  1206. if ((ret = rtmp_handshake(s, rt)) < 0)
  1207. goto fail;
  1208. rt->out_chunk_size = 128;
  1209. rt->in_chunk_size = 128; // Probably overwritten later
  1210. rt->state = STATE_HANDSHAKED;
  1211. // Keep the application name when it has been defined by the user.
  1212. old_app = rt->app;
  1213. rt->app = av_malloc(APP_MAX_LENGTH);
  1214. if (!rt->app) {
  1215. ret = AVERROR(ENOMEM);
  1216. goto fail;
  1217. }
  1218. //extract "app" part from path
  1219. if (!strncmp(path, "/ondemand/", 10)) {
  1220. fname = path + 10;
  1221. memcpy(rt->app, "ondemand", 9);
  1222. } else {
  1223. char *next = *path ? path + 1 : path;
  1224. char *p = strchr(next, '/');
  1225. if (!p) {
  1226. fname = next;
  1227. rt->app[0] = '\0';
  1228. } else {
  1229. // make sure we do not mismatch a playpath for an application instance
  1230. char *c = strchr(p + 1, ':');
  1231. fname = strchr(p + 1, '/');
  1232. if (!fname || (c && c < fname)) {
  1233. fname = p + 1;
  1234. av_strlcpy(rt->app, path + 1, p - path);
  1235. } else {
  1236. fname++;
  1237. av_strlcpy(rt->app, path + 1, fname - path - 1);
  1238. }
  1239. }
  1240. }
  1241. if (old_app) {
  1242. // The name of application has been defined by the user, override it.
  1243. av_free(rt->app);
  1244. rt->app = old_app;
  1245. }
  1246. if (!rt->playpath) {
  1247. int len = strlen(fname);
  1248. rt->playpath = av_malloc(PLAYPATH_MAX_LENGTH);
  1249. if (!rt->playpath) {
  1250. ret = AVERROR(ENOMEM);
  1251. goto fail;
  1252. }
  1253. if (!strchr(fname, ':') && len >= 4 &&
  1254. (!strcmp(fname + len - 4, ".f4v") ||
  1255. !strcmp(fname + len - 4, ".mp4"))) {
  1256. memcpy(rt->playpath, "mp4:", 5);
  1257. } else if (len >= 4 && !strcmp(fname + len - 4, ".flv")) {
  1258. fname[len - 4] = '\0';
  1259. } else {
  1260. rt->playpath[0] = 0;
  1261. }
  1262. strncat(rt->playpath, fname, PLAYPATH_MAX_LENGTH - 5);
  1263. }
  1264. if (!rt->tcurl) {
  1265. rt->tcurl = av_malloc(TCURL_MAX_LENGTH);
  1266. if (!rt->tcurl) {
  1267. ret = AVERROR(ENOMEM);
  1268. goto fail;
  1269. }
  1270. ff_url_join(rt->tcurl, TCURL_MAX_LENGTH, proto, NULL, hostname,
  1271. port, "/%s", rt->app);
  1272. }
  1273. if (!rt->flashver) {
  1274. rt->flashver = av_malloc(FLASHVER_MAX_LENGTH);
  1275. if (!rt->flashver) {
  1276. ret = AVERROR(ENOMEM);
  1277. goto fail;
  1278. }
  1279. if (rt->is_input) {
  1280. snprintf(rt->flashver, FLASHVER_MAX_LENGTH, "%s %d,%d,%d,%d",
  1281. RTMP_CLIENT_PLATFORM, RTMP_CLIENT_VER1, RTMP_CLIENT_VER2,
  1282. RTMP_CLIENT_VER3, RTMP_CLIENT_VER4);
  1283. } else {
  1284. snprintf(rt->flashver, FLASHVER_MAX_LENGTH,
  1285. "FMLE/3.0 (compatible; %s)", LIBAVFORMAT_IDENT);
  1286. }
  1287. }
  1288. rt->client_report_size = 1048576;
  1289. rt->bytes_read = 0;
  1290. rt->last_bytes_read = 0;
  1291. rt->server_bw = 2500000;
  1292. av_log(s, AV_LOG_DEBUG, "Proto = %s, path = %s, app = %s, fname = %s\n",
  1293. proto, path, rt->app, rt->playpath);
  1294. if ((ret = gen_connect(s, rt)) < 0)
  1295. goto fail;
  1296. do {
  1297. ret = get_packet(s, 1);
  1298. } while (ret == EAGAIN);
  1299. if (ret < 0)
  1300. goto fail;
  1301. if (rt->is_input) {
  1302. // generate FLV header for demuxer
  1303. rt->flv_size = 13;
  1304. rt->flv_data = av_realloc(rt->flv_data, rt->flv_size);
  1305. rt->flv_off = 0;
  1306. memcpy(rt->flv_data, "FLV\1\5\0\0\0\011\0\0\0\0", rt->flv_size);
  1307. } else {
  1308. rt->flv_size = 0;
  1309. rt->flv_data = NULL;
  1310. rt->flv_off = 0;
  1311. rt->skip_bytes = 13;
  1312. }
  1313. s->max_packet_size = rt->stream->max_packet_size;
  1314. s->is_streamed = 1;
  1315. return 0;
  1316. fail:
  1317. av_dict_free(&opts);
  1318. rtmp_close(s);
  1319. return ret;
  1320. }
  1321. static int rtmp_read(URLContext *s, uint8_t *buf, int size)
  1322. {
  1323. RTMPContext *rt = s->priv_data;
  1324. int orig_size = size;
  1325. int ret;
  1326. while (size > 0) {
  1327. int data_left = rt->flv_size - rt->flv_off;
  1328. if (data_left >= size) {
  1329. memcpy(buf, rt->flv_data + rt->flv_off, size);
  1330. rt->flv_off += size;
  1331. return orig_size;
  1332. }
  1333. if (data_left > 0) {
  1334. memcpy(buf, rt->flv_data + rt->flv_off, data_left);
  1335. buf += data_left;
  1336. size -= data_left;
  1337. rt->flv_off = rt->flv_size;
  1338. return data_left;
  1339. }
  1340. if ((ret = get_packet(s, 0)) < 0)
  1341. return ret;
  1342. }
  1343. return orig_size;
  1344. }
  1345. static int rtmp_write(URLContext *s, const uint8_t *buf, int size)
  1346. {
  1347. RTMPContext *rt = s->priv_data;
  1348. int size_temp = size;
  1349. int pktsize, pkttype;
  1350. uint32_t ts;
  1351. const uint8_t *buf_temp = buf;
  1352. uint8_t c;
  1353. int ret;
  1354. do {
  1355. if (rt->skip_bytes) {
  1356. int skip = FFMIN(rt->skip_bytes, size_temp);
  1357. buf_temp += skip;
  1358. size_temp -= skip;
  1359. rt->skip_bytes -= skip;
  1360. continue;
  1361. }
  1362. if (rt->flv_header_bytes < 11) {
  1363. const uint8_t *header = rt->flv_header;
  1364. int copy = FFMIN(11 - rt->flv_header_bytes, size_temp);
  1365. bytestream_get_buffer(&buf_temp, rt->flv_header + rt->flv_header_bytes, copy);
  1366. rt->flv_header_bytes += copy;
  1367. size_temp -= copy;
  1368. if (rt->flv_header_bytes < 11)
  1369. break;
  1370. pkttype = bytestream_get_byte(&header);
  1371. pktsize = bytestream_get_be24(&header);
  1372. ts = bytestream_get_be24(&header);
  1373. ts |= bytestream_get_byte(&header) << 24;
  1374. bytestream_get_be24(&header);
  1375. rt->flv_size = pktsize;
  1376. //force 12bytes header
  1377. if (((pkttype == RTMP_PT_VIDEO || pkttype == RTMP_PT_AUDIO) && ts == 0) ||
  1378. pkttype == RTMP_PT_NOTIFY) {
  1379. if (pkttype == RTMP_PT_NOTIFY)
  1380. pktsize += 16;
  1381. rt->prev_pkt[1][RTMP_SOURCE_CHANNEL].channel_id = 0;
  1382. }
  1383. //this can be a big packet, it's better to send it right here
  1384. if ((ret = ff_rtmp_packet_create(&rt->out_pkt, RTMP_SOURCE_CHANNEL,
  1385. pkttype, ts, pktsize)) < 0)
  1386. return ret;
  1387. rt->out_pkt.extra = rt->main_channel_id;
  1388. rt->flv_data = rt->out_pkt.data;
  1389. if (pkttype == RTMP_PT_NOTIFY)
  1390. ff_amf_write_string(&rt->flv_data, "@setDataFrame");
  1391. }
  1392. if (rt->flv_size - rt->flv_off > size_temp) {
  1393. bytestream_get_buffer(&buf_temp, rt->flv_data + rt->flv_off, size_temp);
  1394. rt->flv_off += size_temp;
  1395. size_temp = 0;
  1396. } else {
  1397. bytestream_get_buffer(&buf_temp, rt->flv_data + rt->flv_off, rt->flv_size - rt->flv_off);
  1398. size_temp -= rt->flv_size - rt->flv_off;
  1399. rt->flv_off += rt->flv_size - rt->flv_off;
  1400. }
  1401. if (rt->flv_off == rt->flv_size) {
  1402. rt->skip_bytes = 4;
  1403. if ((ret = rtmp_send_packet(rt, &rt->out_pkt, 0)) < 0)
  1404. return ret;
  1405. rt->flv_size = 0;
  1406. rt->flv_off = 0;
  1407. rt->flv_header_bytes = 0;
  1408. rt->flv_nb_packets++;
  1409. }
  1410. } while (buf_temp - buf < size);
  1411. if (rt->flv_nb_packets < rt->flush_interval)
  1412. return size;
  1413. rt->flv_nb_packets = 0;
  1414. /* set stream into nonblocking mode */
  1415. rt->stream->flags |= AVIO_FLAG_NONBLOCK;
  1416. /* try to read one byte from the stream */
  1417. ret = ffurl_read(rt->stream, &c, 1);
  1418. /* switch the stream back into blocking mode */
  1419. rt->stream->flags &= ~AVIO_FLAG_NONBLOCK;
  1420. if (ret == AVERROR(EAGAIN)) {
  1421. /* no incoming data to handle */
  1422. return size;
  1423. } else if (ret < 0) {
  1424. return ret;
  1425. } else if (ret == 1) {
  1426. RTMPPacket rpkt = { 0 };
  1427. if ((ret = ff_rtmp_packet_read_internal(rt->stream, &rpkt,
  1428. rt->in_chunk_size,
  1429. rt->prev_pkt[0], c)) <= 0)
  1430. return ret;
  1431. if ((ret = rtmp_parse_result(s, rt, &rpkt)) < 0)
  1432. return ret;
  1433. ff_rtmp_packet_destroy(&rpkt);
  1434. }
  1435. return size;
  1436. }
  1437. #define OFFSET(x) offsetof(RTMPContext, x)
  1438. #define DEC AV_OPT_FLAG_DECODING_PARAM
  1439. #define ENC AV_OPT_FLAG_ENCODING_PARAM
  1440. static const AVOption rtmp_options[] = {
  1441. {"rtmp_app", "Name of application to connect to on the RTMP server", OFFSET(app), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC|ENC},
  1442. {"rtmp_buffer", "Set buffer time in milliseconds. The default is 3000.", OFFSET(client_buffer_time), AV_OPT_TYPE_INT, {3000}, 0, INT_MAX, DEC|ENC},
  1443. {"rtmp_conn", "Append arbitrary AMF data to the Connect message", OFFSET(conn), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC|ENC},
  1444. {"rtmp_flashver", "Version of the Flash plugin used to run the SWF player.", OFFSET(flashver), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC|ENC},
  1445. {"rtmp_flush_interval", "Number of packets flushed in the same request (RTMPT only).", OFFSET(flush_interval), AV_OPT_TYPE_INT, {10}, 0, INT_MAX, ENC},
  1446. {"rtmp_live", "Specify that the media is a live stream.", OFFSET(live), AV_OPT_TYPE_INT, {-2}, INT_MIN, INT_MAX, DEC, "rtmp_live"},
  1447. {"any", "both", 0, AV_OPT_TYPE_CONST, {-2}, 0, 0, DEC, "rtmp_live"},
  1448. {"live", "live stream", 0, AV_OPT_TYPE_CONST, {-1}, 0, 0, DEC, "rtmp_live"},
  1449. {"recorded", "recorded stream", 0, AV_OPT_TYPE_CONST, {0}, 0, 0, DEC, "rtmp_live"},
  1450. {"rtmp_pageurl", "URL of the web page in which the media was embedded. By default no value will be sent.", OFFSET(pageurl), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC},
  1451. {"rtmp_playpath", "Stream identifier to play or to publish", OFFSET(playpath), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC|ENC},
  1452. {"rtmp_subscribe", "Name of live stream to subscribe to. Defaults to rtmp_playpath.", OFFSET(subscribe), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC},
  1453. {"rtmp_swfurl", "URL of the SWF player. By default no value will be sent", OFFSET(swfurl), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC|ENC},
  1454. {"rtmp_tcurl", "URL of the target stream. Defaults to proto://host[:port]/app.", OFFSET(tcurl), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC|ENC},
  1455. { NULL },
  1456. };
  1457. #define RTMP_PROTOCOL(flavor) \
  1458. static const AVClass flavor##_class = { \
  1459. .class_name = #flavor, \
  1460. .item_name = av_default_item_name, \
  1461. .option = rtmp_options, \
  1462. .version = LIBAVUTIL_VERSION_INT, \
  1463. }; \
  1464. \
  1465. URLProtocol ff_##flavor##_protocol = { \
  1466. .name = #flavor, \
  1467. .url_open = rtmp_open, \
  1468. .url_read = rtmp_read, \
  1469. .url_write = rtmp_write, \
  1470. .url_close = rtmp_close, \
  1471. .priv_data_size = sizeof(RTMPContext), \
  1472. .flags = URL_PROTOCOL_FLAG_NETWORK, \
  1473. .priv_data_class= &flavor##_class, \
  1474. };
  1475. RTMP_PROTOCOL(rtmp)
  1476. RTMP_PROTOCOL(rtmpe)
  1477. RTMP_PROTOCOL(rtmps)
  1478. RTMP_PROTOCOL(rtmpt)
  1479. RTMP_PROTOCOL(rtmpte)
  1480. RTMP_PROTOCOL(rtmpts)