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.

1751 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, ++rt->nb_invokes);
  527. ff_amf_write_null(&p);
  528. return rtmp_send_packet(rt, &pkt, 1);
  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. char *tracked_method = NULL;
  883. int level = AV_LOG_ERROR;
  884. uint8_t tmpstr[256];
  885. int ret;
  886. if ((ret = find_tracked_method(s, pkt, 9, &tracked_method)) < 0)
  887. return ret;
  888. if (!ff_amf_get_field_value(pkt->data + 9, data_end,
  889. "description", tmpstr, sizeof(tmpstr))) {
  890. if (tracked_method && !strcmp(tracked_method, "_checkbw")) {
  891. /* Ignore _checkbw errors. */
  892. level = AV_LOG_WARNING;
  893. ret = 0;
  894. } else
  895. ret = -1;
  896. av_log(s, level, "Server error: %s\n", tmpstr);
  897. }
  898. av_free(tracked_method);
  899. return ret;
  900. }
  901. static int handle_invoke_result(URLContext *s, RTMPPacket *pkt)
  902. {
  903. RTMPContext *rt = s->priv_data;
  904. char *tracked_method = NULL;
  905. int ret = 0;
  906. if ((ret = find_tracked_method(s, pkt, 10, &tracked_method)) < 0)
  907. return ret;
  908. if (!tracked_method) {
  909. /* Ignore this reply when the current method is not tracked. */
  910. return ret;
  911. }
  912. if (!memcmp(tracked_method, "connect", 7)) {
  913. if (!rt->is_input) {
  914. if ((ret = gen_release_stream(s, rt)) < 0)
  915. goto fail;
  916. if ((ret = gen_fcpublish_stream(s, rt)) < 0)
  917. goto fail;
  918. } else {
  919. if ((ret = gen_server_bw(s, rt)) < 0)
  920. goto fail;
  921. }
  922. if ((ret = gen_create_stream(s, rt)) < 0)
  923. goto fail;
  924. if (rt->is_input) {
  925. /* Send the FCSubscribe command when the name of live
  926. * stream is defined by the user or if it's a live stream. */
  927. if (rt->subscribe) {
  928. if ((ret = gen_fcsubscribe_stream(s, rt, rt->subscribe)) < 0)
  929. goto fail;
  930. } else if (rt->live == -1) {
  931. if ((ret = gen_fcsubscribe_stream(s, rt, rt->playpath)) < 0)
  932. goto fail;
  933. }
  934. }
  935. } else if (!memcmp(tracked_method, "createStream", 12)) {
  936. //extract a number from the result
  937. if (pkt->data[10] || pkt->data[19] != 5 || pkt->data[20]) {
  938. av_log(s, AV_LOG_WARNING, "Unexpected reply on connect()\n");
  939. } else {
  940. rt->main_channel_id = av_int2double(AV_RB64(pkt->data + 21));
  941. }
  942. if (!rt->is_input) {
  943. if ((ret = gen_publish(s, rt)) < 0)
  944. goto fail;
  945. } else {
  946. if ((ret = gen_play(s, rt)) < 0)
  947. goto fail;
  948. if ((ret = gen_buffer_time(s, rt)) < 0)
  949. goto fail;
  950. }
  951. }
  952. fail:
  953. av_free(tracked_method);
  954. return ret;
  955. }
  956. static int handle_invoke_status(URLContext *s, RTMPPacket *pkt)
  957. {
  958. RTMPContext *rt = s->priv_data;
  959. const uint8_t *data_end = pkt->data + pkt->data_size;
  960. const uint8_t *ptr = pkt->data + 11;
  961. uint8_t tmpstr[256];
  962. int i, t;
  963. for (i = 0; i < 2; i++) {
  964. t = ff_amf_tag_size(ptr, data_end);
  965. if (t < 0)
  966. return 1;
  967. ptr += t;
  968. }
  969. t = ff_amf_get_field_value(ptr, data_end, "level", tmpstr, sizeof(tmpstr));
  970. if (!t && !strcmp(tmpstr, "error")) {
  971. if (!ff_amf_get_field_value(ptr, data_end,
  972. "description", tmpstr, sizeof(tmpstr)))
  973. av_log(s, AV_LOG_ERROR, "Server error: %s\n", tmpstr);
  974. return -1;
  975. }
  976. t = ff_amf_get_field_value(ptr, data_end, "code", tmpstr, sizeof(tmpstr));
  977. if (!t && !strcmp(tmpstr, "NetStream.Play.Start")) rt->state = STATE_PLAYING;
  978. if (!t && !strcmp(tmpstr, "NetStream.Play.Stop")) rt->state = STATE_STOPPED;
  979. if (!t && !strcmp(tmpstr, "NetStream.Play.UnpublishNotify")) rt->state = STATE_STOPPED;
  980. if (!t && !strcmp(tmpstr, "NetStream.Publish.Start")) rt->state = STATE_PUBLISHING;
  981. return 0;
  982. }
  983. static int handle_invoke(URLContext *s, RTMPPacket *pkt)
  984. {
  985. RTMPContext *rt = s->priv_data;
  986. int ret = 0;
  987. //TODO: check for the messages sent for wrong state?
  988. if (!memcmp(pkt->data, "\002\000\006_error", 9)) {
  989. if ((ret = handle_invoke_error(s, pkt)) < 0)
  990. return ret;
  991. } else if (!memcmp(pkt->data, "\002\000\007_result", 10)) {
  992. if ((ret = handle_invoke_result(s, pkt)) < 0)
  993. return ret;
  994. } else if (!memcmp(pkt->data, "\002\000\010onStatus", 11)) {
  995. if ((ret = handle_invoke_status(s, pkt)) < 0)
  996. return ret;
  997. } else if (!memcmp(pkt->data, "\002\000\010onBWDone", 11)) {
  998. if ((ret = gen_check_bw(s, rt)) < 0)
  999. return ret;
  1000. }
  1001. return ret;
  1002. }
  1003. /**
  1004. * Parse received packet and possibly perform some action depending on
  1005. * the packet contents.
  1006. * @return 0 for no errors, negative values for serious errors which prevent
  1007. * further communications, positive values for uncritical errors
  1008. */
  1009. static int rtmp_parse_result(URLContext *s, RTMPContext *rt, RTMPPacket *pkt)
  1010. {
  1011. int ret;
  1012. #ifdef DEBUG
  1013. ff_rtmp_packet_dump(s, pkt);
  1014. #endif
  1015. switch (pkt->type) {
  1016. case RTMP_PT_BYTES_READ:
  1017. av_dlog(s, "received bytes read report\n");
  1018. break;
  1019. case RTMP_PT_CHUNK_SIZE:
  1020. if ((ret = handle_chunk_size(s, pkt)) < 0)
  1021. return ret;
  1022. break;
  1023. case RTMP_PT_PING:
  1024. if ((ret = handle_ping(s, pkt)) < 0)
  1025. return ret;
  1026. break;
  1027. case RTMP_PT_CLIENT_BW:
  1028. if ((ret = handle_client_bw(s, pkt)) < 0)
  1029. return ret;
  1030. break;
  1031. case RTMP_PT_SERVER_BW:
  1032. if ((ret = handle_server_bw(s, pkt)) < 0)
  1033. return ret;
  1034. break;
  1035. case RTMP_PT_INVOKE:
  1036. if ((ret = handle_invoke(s, pkt)) < 0)
  1037. return ret;
  1038. break;
  1039. case RTMP_PT_VIDEO:
  1040. case RTMP_PT_AUDIO:
  1041. case RTMP_PT_METADATA:
  1042. /* Audio, Video and Metadata packets are parsed in get_packet() */
  1043. break;
  1044. default:
  1045. av_log(s, AV_LOG_VERBOSE, "Unknown packet type received 0x%02X\n", pkt->type);
  1046. break;
  1047. }
  1048. return 0;
  1049. }
  1050. /**
  1051. * Interact with the server by receiving and sending RTMP packets until
  1052. * there is some significant data (media data or expected status notification).
  1053. *
  1054. * @param s reading context
  1055. * @param for_header non-zero value tells function to work until it
  1056. * gets notification from the server that playing has been started,
  1057. * otherwise function will work until some media data is received (or
  1058. * an error happens)
  1059. * @return 0 for successful operation, negative value in case of error
  1060. */
  1061. static int get_packet(URLContext *s, int for_header)
  1062. {
  1063. RTMPContext *rt = s->priv_data;
  1064. int ret;
  1065. uint8_t *p;
  1066. const uint8_t *next;
  1067. uint32_t data_size;
  1068. uint32_t ts, cts, pts=0;
  1069. if (rt->state == STATE_STOPPED)
  1070. return AVERROR_EOF;
  1071. for (;;) {
  1072. RTMPPacket rpkt = { 0 };
  1073. if ((ret = ff_rtmp_packet_read(rt->stream, &rpkt,
  1074. rt->in_chunk_size, rt->prev_pkt[0])) <= 0) {
  1075. if (ret == 0) {
  1076. return AVERROR(EAGAIN);
  1077. } else {
  1078. return AVERROR(EIO);
  1079. }
  1080. }
  1081. rt->bytes_read += ret;
  1082. if (rt->bytes_read > rt->last_bytes_read + rt->client_report_size) {
  1083. av_log(s, AV_LOG_DEBUG, "Sending bytes read report\n");
  1084. if ((ret = gen_bytes_read(s, rt, rpkt.timestamp + 1)) < 0)
  1085. return ret;
  1086. rt->last_bytes_read = rt->bytes_read;
  1087. }
  1088. ret = rtmp_parse_result(s, rt, &rpkt);
  1089. if (ret < 0) {//serious error in current packet
  1090. ff_rtmp_packet_destroy(&rpkt);
  1091. return ret;
  1092. }
  1093. if (rt->state == STATE_STOPPED) {
  1094. ff_rtmp_packet_destroy(&rpkt);
  1095. return AVERROR_EOF;
  1096. }
  1097. if (for_header && (rt->state == STATE_PLAYING || rt->state == STATE_PUBLISHING)) {
  1098. ff_rtmp_packet_destroy(&rpkt);
  1099. return 0;
  1100. }
  1101. if (!rpkt.data_size || !rt->is_input) {
  1102. ff_rtmp_packet_destroy(&rpkt);
  1103. continue;
  1104. }
  1105. if (rpkt.type == RTMP_PT_VIDEO || rpkt.type == RTMP_PT_AUDIO ||
  1106. (rpkt.type == RTMP_PT_NOTIFY && !memcmp("\002\000\012onMetaData", rpkt.data, 13))) {
  1107. ts = rpkt.timestamp;
  1108. // generate packet header and put data into buffer for FLV demuxer
  1109. rt->flv_off = 0;
  1110. rt->flv_size = rpkt.data_size + 15;
  1111. rt->flv_data = p = av_realloc(rt->flv_data, rt->flv_size);
  1112. bytestream_put_byte(&p, rpkt.type);
  1113. bytestream_put_be24(&p, rpkt.data_size);
  1114. bytestream_put_be24(&p, ts);
  1115. bytestream_put_byte(&p, ts >> 24);
  1116. bytestream_put_be24(&p, 0);
  1117. bytestream_put_buffer(&p, rpkt.data, rpkt.data_size);
  1118. bytestream_put_be32(&p, 0);
  1119. ff_rtmp_packet_destroy(&rpkt);
  1120. return 0;
  1121. } else if (rpkt.type == RTMP_PT_METADATA) {
  1122. // we got raw FLV data, make it available for FLV demuxer
  1123. rt->flv_off = 0;
  1124. rt->flv_size = rpkt.data_size;
  1125. rt->flv_data = av_realloc(rt->flv_data, rt->flv_size);
  1126. /* rewrite timestamps */
  1127. next = rpkt.data;
  1128. ts = rpkt.timestamp;
  1129. while (next - rpkt.data < rpkt.data_size - 11) {
  1130. next++;
  1131. data_size = bytestream_get_be24(&next);
  1132. p=next;
  1133. cts = bytestream_get_be24(&next);
  1134. cts |= bytestream_get_byte(&next) << 24;
  1135. if (pts==0)
  1136. pts=cts;
  1137. ts += cts - pts;
  1138. pts = cts;
  1139. bytestream_put_be24(&p, ts);
  1140. bytestream_put_byte(&p, ts >> 24);
  1141. next += data_size + 3 + 4;
  1142. }
  1143. memcpy(rt->flv_data, rpkt.data, rpkt.data_size);
  1144. ff_rtmp_packet_destroy(&rpkt);
  1145. return 0;
  1146. }
  1147. ff_rtmp_packet_destroy(&rpkt);
  1148. }
  1149. }
  1150. static int rtmp_close(URLContext *h)
  1151. {
  1152. RTMPContext *rt = h->priv_data;
  1153. int ret = 0;
  1154. if (!rt->is_input) {
  1155. rt->flv_data = NULL;
  1156. if (rt->out_pkt.data_size)
  1157. ff_rtmp_packet_destroy(&rt->out_pkt);
  1158. if (rt->state > STATE_FCPUBLISH)
  1159. ret = gen_fcunpublish_stream(h, rt);
  1160. }
  1161. if (rt->state > STATE_HANDSHAKED)
  1162. ret = gen_delete_stream(h, rt);
  1163. free_tracked_methods(rt);
  1164. av_freep(&rt->flv_data);
  1165. ffurl_close(rt->stream);
  1166. return ret;
  1167. }
  1168. /**
  1169. * Open RTMP connection and verify that the stream can be played.
  1170. *
  1171. * URL syntax: rtmp://server[:port][/app][/playpath]
  1172. * where 'app' is first one or two directories in the path
  1173. * (e.g. /ondemand/, /flash/live/, etc.)
  1174. * and 'playpath' is a file name (the rest of the path,
  1175. * may be prefixed with "mp4:")
  1176. */
  1177. static int rtmp_open(URLContext *s, const char *uri, int flags)
  1178. {
  1179. RTMPContext *rt = s->priv_data;
  1180. char proto[8], hostname[256], path[1024], *fname;
  1181. char *old_app;
  1182. uint8_t buf[2048];
  1183. int port;
  1184. AVDictionary *opts = NULL;
  1185. int ret;
  1186. rt->is_input = !(flags & AVIO_FLAG_WRITE);
  1187. av_url_split(proto, sizeof(proto), NULL, 0, hostname, sizeof(hostname), &port,
  1188. path, sizeof(path), s->filename);
  1189. if (!strcmp(proto, "rtmpt") || !strcmp(proto, "rtmpts")) {
  1190. if (!strcmp(proto, "rtmpts"))
  1191. av_dict_set(&opts, "ffrtmphttp_tls", "1", 1);
  1192. /* open the http tunneling connection */
  1193. ff_url_join(buf, sizeof(buf), "ffrtmphttp", NULL, hostname, port, NULL);
  1194. } else if (!strcmp(proto, "rtmps")) {
  1195. /* open the tls connection */
  1196. if (port < 0)
  1197. port = RTMPS_DEFAULT_PORT;
  1198. ff_url_join(buf, sizeof(buf), "tls", NULL, hostname, port, NULL);
  1199. } else if (!strcmp(proto, "rtmpe") || (!strcmp(proto, "rtmpte"))) {
  1200. if (!strcmp(proto, "rtmpte"))
  1201. av_dict_set(&opts, "ffrtmpcrypt_tunneling", "1", 1);
  1202. /* open the encrypted connection */
  1203. ff_url_join(buf, sizeof(buf), "ffrtmpcrypt", NULL, hostname, port, NULL);
  1204. rt->encrypted = 1;
  1205. } else {
  1206. /* open the tcp connection */
  1207. if (port < 0)
  1208. port = RTMP_DEFAULT_PORT;
  1209. ff_url_join(buf, sizeof(buf), "tcp", NULL, hostname, port, NULL);
  1210. }
  1211. if ((ret = ffurl_open(&rt->stream, buf, AVIO_FLAG_READ_WRITE,
  1212. &s->interrupt_callback, &opts)) < 0) {
  1213. av_log(s , AV_LOG_ERROR, "Cannot open connection %s\n", buf);
  1214. goto fail;
  1215. }
  1216. rt->state = STATE_START;
  1217. if ((ret = rtmp_handshake(s, rt)) < 0)
  1218. goto fail;
  1219. rt->out_chunk_size = 128;
  1220. rt->in_chunk_size = 128; // Probably overwritten later
  1221. rt->state = STATE_HANDSHAKED;
  1222. // Keep the application name when it has been defined by the user.
  1223. old_app = rt->app;
  1224. rt->app = av_malloc(APP_MAX_LENGTH);
  1225. if (!rt->app) {
  1226. ret = AVERROR(ENOMEM);
  1227. goto fail;
  1228. }
  1229. //extract "app" part from path
  1230. if (!strncmp(path, "/ondemand/", 10)) {
  1231. fname = path + 10;
  1232. memcpy(rt->app, "ondemand", 9);
  1233. } else {
  1234. char *next = *path ? path + 1 : path;
  1235. char *p = strchr(next, '/');
  1236. if (!p) {
  1237. fname = next;
  1238. rt->app[0] = '\0';
  1239. } else {
  1240. // make sure we do not mismatch a playpath for an application instance
  1241. char *c = strchr(p + 1, ':');
  1242. fname = strchr(p + 1, '/');
  1243. if (!fname || (c && c < fname)) {
  1244. fname = p + 1;
  1245. av_strlcpy(rt->app, path + 1, p - path);
  1246. } else {
  1247. fname++;
  1248. av_strlcpy(rt->app, path + 1, fname - path - 1);
  1249. }
  1250. }
  1251. }
  1252. if (old_app) {
  1253. // The name of application has been defined by the user, override it.
  1254. av_free(rt->app);
  1255. rt->app = old_app;
  1256. }
  1257. if (!rt->playpath) {
  1258. int len = strlen(fname);
  1259. rt->playpath = av_malloc(PLAYPATH_MAX_LENGTH);
  1260. if (!rt->playpath) {
  1261. ret = AVERROR(ENOMEM);
  1262. goto fail;
  1263. }
  1264. if (!strchr(fname, ':') && len >= 4 &&
  1265. (!strcmp(fname + len - 4, ".f4v") ||
  1266. !strcmp(fname + len - 4, ".mp4"))) {
  1267. memcpy(rt->playpath, "mp4:", 5);
  1268. } else if (len >= 4 && !strcmp(fname + len - 4, ".flv")) {
  1269. fname[len - 4] = '\0';
  1270. } else {
  1271. rt->playpath[0] = 0;
  1272. }
  1273. strncat(rt->playpath, fname, PLAYPATH_MAX_LENGTH - 5);
  1274. }
  1275. if (!rt->tcurl) {
  1276. rt->tcurl = av_malloc(TCURL_MAX_LENGTH);
  1277. if (!rt->tcurl) {
  1278. ret = AVERROR(ENOMEM);
  1279. goto fail;
  1280. }
  1281. ff_url_join(rt->tcurl, TCURL_MAX_LENGTH, proto, NULL, hostname,
  1282. port, "/%s", rt->app);
  1283. }
  1284. if (!rt->flashver) {
  1285. rt->flashver = av_malloc(FLASHVER_MAX_LENGTH);
  1286. if (!rt->flashver) {
  1287. ret = AVERROR(ENOMEM);
  1288. goto fail;
  1289. }
  1290. if (rt->is_input) {
  1291. snprintf(rt->flashver, FLASHVER_MAX_LENGTH, "%s %d,%d,%d,%d",
  1292. RTMP_CLIENT_PLATFORM, RTMP_CLIENT_VER1, RTMP_CLIENT_VER2,
  1293. RTMP_CLIENT_VER3, RTMP_CLIENT_VER4);
  1294. } else {
  1295. snprintf(rt->flashver, FLASHVER_MAX_LENGTH,
  1296. "FMLE/3.0 (compatible; %s)", LIBAVFORMAT_IDENT);
  1297. }
  1298. }
  1299. rt->client_report_size = 1048576;
  1300. rt->bytes_read = 0;
  1301. rt->last_bytes_read = 0;
  1302. rt->server_bw = 2500000;
  1303. av_log(s, AV_LOG_DEBUG, "Proto = %s, path = %s, app = %s, fname = %s\n",
  1304. proto, path, rt->app, rt->playpath);
  1305. if ((ret = gen_connect(s, rt)) < 0)
  1306. goto fail;
  1307. do {
  1308. ret = get_packet(s, 1);
  1309. } while (ret == EAGAIN);
  1310. if (ret < 0)
  1311. goto fail;
  1312. if (rt->is_input) {
  1313. // generate FLV header for demuxer
  1314. rt->flv_size = 13;
  1315. rt->flv_data = av_realloc(rt->flv_data, rt->flv_size);
  1316. rt->flv_off = 0;
  1317. memcpy(rt->flv_data, "FLV\1\5\0\0\0\011\0\0\0\0", rt->flv_size);
  1318. } else {
  1319. rt->flv_size = 0;
  1320. rt->flv_data = NULL;
  1321. rt->flv_off = 0;
  1322. rt->skip_bytes = 13;
  1323. }
  1324. s->max_packet_size = rt->stream->max_packet_size;
  1325. s->is_streamed = 1;
  1326. return 0;
  1327. fail:
  1328. av_dict_free(&opts);
  1329. rtmp_close(s);
  1330. return ret;
  1331. }
  1332. static int rtmp_read(URLContext *s, uint8_t *buf, int size)
  1333. {
  1334. RTMPContext *rt = s->priv_data;
  1335. int orig_size = size;
  1336. int ret;
  1337. while (size > 0) {
  1338. int data_left = rt->flv_size - rt->flv_off;
  1339. if (data_left >= size) {
  1340. memcpy(buf, rt->flv_data + rt->flv_off, size);
  1341. rt->flv_off += size;
  1342. return orig_size;
  1343. }
  1344. if (data_left > 0) {
  1345. memcpy(buf, rt->flv_data + rt->flv_off, data_left);
  1346. buf += data_left;
  1347. size -= data_left;
  1348. rt->flv_off = rt->flv_size;
  1349. return data_left;
  1350. }
  1351. if ((ret = get_packet(s, 0)) < 0)
  1352. return ret;
  1353. }
  1354. return orig_size;
  1355. }
  1356. static int rtmp_write(URLContext *s, const uint8_t *buf, int size)
  1357. {
  1358. RTMPContext *rt = s->priv_data;
  1359. int size_temp = size;
  1360. int pktsize, pkttype;
  1361. uint32_t ts;
  1362. const uint8_t *buf_temp = buf;
  1363. uint8_t c;
  1364. int ret;
  1365. do {
  1366. if (rt->skip_bytes) {
  1367. int skip = FFMIN(rt->skip_bytes, size_temp);
  1368. buf_temp += skip;
  1369. size_temp -= skip;
  1370. rt->skip_bytes -= skip;
  1371. continue;
  1372. }
  1373. if (rt->flv_header_bytes < 11) {
  1374. const uint8_t *header = rt->flv_header;
  1375. int copy = FFMIN(11 - rt->flv_header_bytes, size_temp);
  1376. bytestream_get_buffer(&buf_temp, rt->flv_header + rt->flv_header_bytes, copy);
  1377. rt->flv_header_bytes += copy;
  1378. size_temp -= copy;
  1379. if (rt->flv_header_bytes < 11)
  1380. break;
  1381. pkttype = bytestream_get_byte(&header);
  1382. pktsize = bytestream_get_be24(&header);
  1383. ts = bytestream_get_be24(&header);
  1384. ts |= bytestream_get_byte(&header) << 24;
  1385. bytestream_get_be24(&header);
  1386. rt->flv_size = pktsize;
  1387. //force 12bytes header
  1388. if (((pkttype == RTMP_PT_VIDEO || pkttype == RTMP_PT_AUDIO) && ts == 0) ||
  1389. pkttype == RTMP_PT_NOTIFY) {
  1390. if (pkttype == RTMP_PT_NOTIFY)
  1391. pktsize += 16;
  1392. rt->prev_pkt[1][RTMP_SOURCE_CHANNEL].channel_id = 0;
  1393. }
  1394. //this can be a big packet, it's better to send it right here
  1395. if ((ret = ff_rtmp_packet_create(&rt->out_pkt, RTMP_SOURCE_CHANNEL,
  1396. pkttype, ts, pktsize)) < 0)
  1397. return ret;
  1398. rt->out_pkt.extra = rt->main_channel_id;
  1399. rt->flv_data = rt->out_pkt.data;
  1400. if (pkttype == RTMP_PT_NOTIFY)
  1401. ff_amf_write_string(&rt->flv_data, "@setDataFrame");
  1402. }
  1403. if (rt->flv_size - rt->flv_off > size_temp) {
  1404. bytestream_get_buffer(&buf_temp, rt->flv_data + rt->flv_off, size_temp);
  1405. rt->flv_off += size_temp;
  1406. size_temp = 0;
  1407. } else {
  1408. bytestream_get_buffer(&buf_temp, rt->flv_data + rt->flv_off, rt->flv_size - rt->flv_off);
  1409. size_temp -= rt->flv_size - rt->flv_off;
  1410. rt->flv_off += rt->flv_size - rt->flv_off;
  1411. }
  1412. if (rt->flv_off == rt->flv_size) {
  1413. rt->skip_bytes = 4;
  1414. if ((ret = rtmp_send_packet(rt, &rt->out_pkt, 0)) < 0)
  1415. return ret;
  1416. rt->flv_size = 0;
  1417. rt->flv_off = 0;
  1418. rt->flv_header_bytes = 0;
  1419. rt->flv_nb_packets++;
  1420. }
  1421. } while (buf_temp - buf < size);
  1422. if (rt->flv_nb_packets < rt->flush_interval)
  1423. return size;
  1424. rt->flv_nb_packets = 0;
  1425. /* set stream into nonblocking mode */
  1426. rt->stream->flags |= AVIO_FLAG_NONBLOCK;
  1427. /* try to read one byte from the stream */
  1428. ret = ffurl_read(rt->stream, &c, 1);
  1429. /* switch the stream back into blocking mode */
  1430. rt->stream->flags &= ~AVIO_FLAG_NONBLOCK;
  1431. if (ret == AVERROR(EAGAIN)) {
  1432. /* no incoming data to handle */
  1433. return size;
  1434. } else if (ret < 0) {
  1435. return ret;
  1436. } else if (ret == 1) {
  1437. RTMPPacket rpkt = { 0 };
  1438. if ((ret = ff_rtmp_packet_read_internal(rt->stream, &rpkt,
  1439. rt->in_chunk_size,
  1440. rt->prev_pkt[0], c)) <= 0)
  1441. return ret;
  1442. if ((ret = rtmp_parse_result(s, rt, &rpkt)) < 0)
  1443. return ret;
  1444. ff_rtmp_packet_destroy(&rpkt);
  1445. }
  1446. return size;
  1447. }
  1448. #define OFFSET(x) offsetof(RTMPContext, x)
  1449. #define DEC AV_OPT_FLAG_DECODING_PARAM
  1450. #define ENC AV_OPT_FLAG_ENCODING_PARAM
  1451. static const AVOption rtmp_options[] = {
  1452. {"rtmp_app", "Name of application to connect to on the RTMP server", OFFSET(app), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC|ENC},
  1453. {"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},
  1454. {"rtmp_conn", "Append arbitrary AMF data to the Connect message", OFFSET(conn), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC|ENC},
  1455. {"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},
  1456. {"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},
  1457. {"rtmp_live", "Specify that the media is a live stream.", OFFSET(live), AV_OPT_TYPE_INT, {-2}, INT_MIN, INT_MAX, DEC, "rtmp_live"},
  1458. {"any", "both", 0, AV_OPT_TYPE_CONST, {-2}, 0, 0, DEC, "rtmp_live"},
  1459. {"live", "live stream", 0, AV_OPT_TYPE_CONST, {-1}, 0, 0, DEC, "rtmp_live"},
  1460. {"recorded", "recorded stream", 0, AV_OPT_TYPE_CONST, {0}, 0, 0, DEC, "rtmp_live"},
  1461. {"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},
  1462. {"rtmp_playpath", "Stream identifier to play or to publish", OFFSET(playpath), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC|ENC},
  1463. {"rtmp_subscribe", "Name of live stream to subscribe to. Defaults to rtmp_playpath.", OFFSET(subscribe), AV_OPT_TYPE_STRING, {.str = NULL }, 0, 0, DEC},
  1464. {"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},
  1465. {"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},
  1466. { NULL },
  1467. };
  1468. #define RTMP_PROTOCOL(flavor) \
  1469. static const AVClass flavor##_class = { \
  1470. .class_name = #flavor, \
  1471. .item_name = av_default_item_name, \
  1472. .option = rtmp_options, \
  1473. .version = LIBAVUTIL_VERSION_INT, \
  1474. }; \
  1475. \
  1476. URLProtocol ff_##flavor##_protocol = { \
  1477. .name = #flavor, \
  1478. .url_open = rtmp_open, \
  1479. .url_read = rtmp_read, \
  1480. .url_write = rtmp_write, \
  1481. .url_close = rtmp_close, \
  1482. .priv_data_size = sizeof(RTMPContext), \
  1483. .flags = URL_PROTOCOL_FLAG_NETWORK, \
  1484. .priv_data_class= &flavor##_class, \
  1485. };
  1486. RTMP_PROTOCOL(rtmp)
  1487. RTMP_PROTOCOL(rtmpe)
  1488. RTMP_PROTOCOL(rtmps)
  1489. RTMP_PROTOCOL(rtmpt)
  1490. RTMP_PROTOCOL(rtmpte)
  1491. RTMP_PROTOCOL(rtmpts)