Lines Matching defs:ret
200 int ret;
204 if ((ret = ff_amf_read_number(&gbc, &pkt_id)) < 0)
205 return ret;
232 int ret;
241 if ((ret = ff_amf_read_string(&gbc, name, sizeof(name), &len)) < 0)
244 if ((ret = ff_amf_read_number(&gbc, &pkt_id)) < 0)
247 if ((ret = add_tracked_method(rt, name, pkt_id)) < 0)
251 ret = ff_rtmp_packet_write(rt->stream, pkt, rt->out_chunk_size,
255 return ret;
325 int ret;
327 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE,
329 return ret;
391 if ((ret = rtmp_write_amf_data(s, param, &p)) < 0) {
394 return ret;
417 int ret;
426 if ((ret = ff_rtmp_packet_read(rt->stream, &pkt, rt->in_chunk_size,
428 return ret;
433 if ((ret = handle_chunk_size(s, &pkt)) < 0) {
435 return ret;
444 if ((ret = handle_window_ack_size(s, &pkt)) < 0) {
446 return ret;
449 if ((ret = handle_set_peer_bw(s, &pkt)) < 0) {
451 return ret;
474 ret = ff_amf_read_number(&gbc, &seqnum);
475 if (ret)
478 ret = ff_amf_get_field_value(gbc.buffer,
481 if (ret)
483 if (!ret && strcmp(tmpstr, rt->app))
489 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL,
491 return ret;
497 ret = ff_rtmp_packet_write(rt->stream, &pkt, rt->out_chunk_size,
500 if (ret < 0)
501 return ret;
503 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL,
505 return ret;
512 ret = ff_rtmp_packet_write(rt->stream, &pkt, rt->out_chunk_size,
515 if (ret < 0)
516 return ret;
519 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL,
521 return ret;
526 ret = ff_rtmp_packet_write(rt->stream, &pkt, rt->out_chunk_size,
529 if (ret < 0)
530 return ret;
533 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL,
535 return ret;
539 ret = ff_rtmp_packet_write(rt->stream, &pkt, rt->out_chunk_size,
542 if (ret < 0)
543 return ret;
546 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL,
549 return ret;
574 ret = ff_rtmp_packet_write(rt->stream, &pkt, rt->out_chunk_size,
577 if (ret < 0)
578 return ret;
580 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL,
582 return ret;
589 ret = ff_rtmp_packet_write(rt->stream, &pkt, rt->out_chunk_size,
593 return ret;
604 int ret;
606 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE,
608 return ret;
628 int ret;
630 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE,
632 return ret;
652 int ret;
654 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE,
656 return ret;
676 int ret;
680 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE,
682 return ret;
701 int ret;
705 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE,
707 return ret;
727 int ret;
729 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SOURCE_CHANNEL, RTMP_PT_INVOKE,
731 return ret;
749 int ret;
751 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL, RTMP_PT_USER_CONTROL,
753 return ret;
771 int ret;
775 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SOURCE_CHANNEL, RTMP_PT_INVOKE,
777 return ret;
795 int ret;
800 if ((ret = ff_rtmp_packet_create(&pkt, 3, RTMP_PT_INVOKE, 0, 26)) < 0)
801 return ret;
821 int ret;
826 if ((ret = ff_rtmp_packet_create(&pkt, 3, RTMP_PT_INVOKE, 0, 29)) < 0)
827 return ret;
848 int ret;
852 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SOURCE_CHANNEL, RTMP_PT_INVOKE,
854 return ret;
875 int ret;
883 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL,RTMP_PT_USER_CONTROL,
885 return ret;
901 int ret;
904 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL, RTMP_PT_USER_CONTROL,
906 return ret;
922 int ret;
924 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL, RTMP_PT_WINDOW_ACK_SIZE,
926 return ret;
941 int ret;
943 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE,
945 return ret;
962 int ret;
964 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL, RTMP_PT_BYTES_READ,
966 return ret;
979 int ret;
981 if ((ret = ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE,
983 return ret;
1004 int ret, digest_pos;
1011 ret = ff_rtmp_calc_digest(buf, RTMP_HANDSHAKE_PACKET_SIZE, digest_pos,
1014 if (ret < 0)
1015 return ret;
1030 int ret, digest_pos;
1034 ret = ff_rtmp_calc_digest(buf, RTMP_HANDSHAKE_PACKET_SIZE, digest_pos,
1037 if (ret < 0)
1038 return ret;
1049 int ret;
1063 if ((ret = ff_rtmp_calc_digest(rt->swfhash, 32, 0, buf, 32, p)) < 0)
1064 return ret;
1076 int ret = 0;
1080 ret = inflateInit(&zs);
1081 if (ret != Z_OK)
1090 ret = inflate(&zs, Z_NO_FLUSH);
1091 if (ret != Z_OK && ret != Z_STREAM_END) {
1092 ret = AVERROR_UNKNOWN;
1098 ret = AVERROR(ENOMEM);
1109 return ret;
1121 int ret = 0;
1124 if ((ret = ffurl_open_whitelist(&stream, rt->swfverify, AVIO_FLAG_READ,
1132 ret = AVERROR(EIO);
1137 ret = AVERROR(ENOMEM);
1141 if ((ret = ffurl_read_complete(stream, in_data, in_size)) < 0)
1145 ret = AVERROR_INVALIDDATA;
1154 ret = AVERROR(ENOMEM);
1161 if ((ret = rtmp_uncompress_swfplayer(in_data + 8, in_size - 8,
1169 ret = AVERROR(EINVAL);
1178 if ((ret = ff_rtmp_calc_digest(swfdata, swfsize, 0,
1191 return ret;
1216 int ret, type = 0;
1237 if ((ret = ff_rtmpe_gen_pub_key(rt->stream, tosend + 1)) < 0)
1238 return ret;
1245 if ((ret = ffurl_write(rt->stream, tosend,
1248 return ret;
1251 if ((ret = ffurl_read_complete(rt->stream, serverdata,
1254 return ret;
1257 if ((ret = ffurl_read_complete(rt->stream, clientdata,
1260 return ret;
1287 if ((ret = rtmp_calc_swf_verification(s, rt, serverdata + 1 +
1289 return ret;
1292 ret = ff_rtmp_calc_digest(tosend + 1 + client_pos, 32, 0,
1295 if (ret < 0)
1296 return ret;
1298 ret = ff_rtmp_calc_digest(clientdata, RTMP_HANDSHAKE_PACKET_SIZE - 32,
1300 if (ret < 0)
1301 return ret;
1306 if ((ret = ff_rtmpe_compute_secret_key(rt->stream, serverdata + 1,
1308 return ret;
1321 ret = ff_rtmp_calc_digest(serverdata + 1 + server_pos, 32, 0,
1324 if (ret < 0)
1325 return ret;
1327 ret = ff_rtmp_calc_digest(tosend, RTMP_HANDSHAKE_PACKET_SIZE - 32, 0,
1330 if (ret < 0)
1331 return ret;
1341 if ((ret = ffurl_write(rt->stream, tosend,
1343 return ret;
1347 if ((ret = ff_rtmpe_update_keystream(rt->stream)) < 0)
1348 return ret;
1354 if ((ret = ff_rtmpe_compute_secret_key(rt->stream, serverdata + 1,
1356 return ret;
1365 if ((ret = ffurl_write(rt->stream, serverdata + 1,
1367 return ret;
1371 if ((ret = ff_rtmpe_update_keystream(rt->stream)) < 0)
1372 return ret;
1431 int ret;
1449 ret = rtmp_receive_hs_packet(rt, &hs_epoch, &zeroes, hs_c1,
1451 if (ret) {
1453 return ret;
1463 ret = rtmp_send_hs_packet(rt, hs_my_epoch, 0, hs_s1,
1465 if (ret) {
1467 return ret;
1470 ret = rtmp_send_hs_packet(rt, hs_epoch, 0, hs_c1,
1472 if (ret) {
1474 return ret;
1477 ret = rtmp_receive_hs_packet(rt, &temp, &zeroes, buffer,
1479 if (ret) {
1481 return ret;
1497 int ret;
1509 if ((ret = ff_rtmp_packet_write(rt->stream, pkt, rt->out_chunk_size,
1511 return ret;
1530 int t, ret;
1540 if ((ret = gen_pong(s, rt, pkt)) < 0)
1541 return ret;
1544 if ((ret = gen_swf_verification(s, rt)) < 0)
1545 return ret;
1707 int i = 0, ret = 0;
1783 if ((ret = do_adobe_auth(rt, user, salt, opaque, challenge)) < 0)
1784 return ret;
1786 if ((ret = do_llnw_auth(rt, user, nonce)) < 0)
1787 return ret;
1801 int ret;
1803 if ((ret = find_tracked_method(s, pkt, 9, &tracked_method)) < 0)
1804 return ret;
1814 ret = 0;
1817 ret = 0;
1819 ret = handle_connect_error(s, tmpstr);
1820 if (!ret) {
1825 ret = AVERROR_UNKNOWN;
1830 return ret;
1838 int ret;
1841 if ((ret = ff_rtmp_packet_create(&spkt, RTMP_NETWORK_CHANNEL,
1844 return ret;
1851 ret = ff_rtmp_packet_write(rt->stream, &spkt, rt->out_chunk_size,
1856 return ret;
1865 int ret;
1867 if ((ret = ff_rtmp_packet_create(&spkt, RTMP_SYSTEM_CHANNEL,
1871 return ret;
1894 ret = ff_rtmp_packet_write(rt->stream, &spkt, rt->out_chunk_size,
1898 return ret;
1913 int ret;
1922 ret = ff_amf_read_number(&gbc, &seqnum);
1923 if (ret)
1924 return ret;
1925 ret = ff_amf_read_null(&gbc);
1926 if (ret)
1927 return ret;
1930 ret = ff_amf_read_string(&gbc, filename,
1932 if (ret) {
1933 if (ret == AVERROR(EINVAL))
1937 return ret;
1957 if ((ret = ff_rtmp_packet_create(&spkt, RTMP_SYSTEM_CHANNEL,
1961 return ret;
1968 ret = write_begin(s);
1969 if (ret < 0)
1970 return ret;
1976 ret = write_begin(s);
1977 if (ret < 0)
1978 return ret;
1983 if ((ret = ff_rtmp_packet_create(&spkt, RTMP_SYSTEM_CHANNEL,
1987 return ret;
2004 ret = ff_rtmp_packet_write(rt->stream, &spkt, rt->out_chunk_size,
2007 return ret;
2053 int ret = 0;
2055 if ((ret = find_tracked_method(s, pkt, 10, &tracked_method)) < 0)
2056 return ret;
2060 return ret;
2065 if ((ret = gen_release_stream(s, rt)) < 0)
2068 if ((ret = gen_fcpublish_stream(s, rt)) < 0)
2071 if ((ret = gen_window_ack_size(s, rt)) < 0)
2075 if ((ret = gen_create_stream(s, rt)) < 0)
2082 if ((ret = gen_fcsubscribe_stream(s, rt, rt->subscribe)) < 0)
2085 if ((ret = gen_fcsubscribe_stream(s, rt, rt->playpath)) < 0)
2098 if ((ret = gen_publish(s, rt)) < 0)
2102 if ((ret = gen_get_stream_length(s, rt)) < 0)
2105 if ((ret = gen_play(s, rt)) < 0)
2107 if ((ret = gen_buffer_time(s, rt)) < 0)
2118 return ret;
2161 int ret = 0;
2165 if ((ret = handle_invoke_error(s, pkt)) < 0)
2166 return ret;
2168 if ((ret = handle_invoke_result(s, pkt)) < 0)
2169 return ret;
2171 if ((ret = handle_invoke_status(s, pkt)) < 0)
2172 return ret;
2174 if ((ret = gen_check_bw(s, rt)) < 0)
2175 return ret;
2182 if ((ret = send_invoke_response(s, pkt)) < 0)
2183 return ret;
2186 return ret;
2210 int old_flv_size, ret;
2224 if ((ret = av_reallocp(&rt->flv_data, rt->flv_size)) < 0) {
2226 return ret;
2246 int stringlen, ret, skip = 0;
2289 ret = ff_amf_read_string(&gbc, statusmsg,
2291 if (ret < 0)
2306 int ret;
2317 if ((ret = handle_chunk_size(s, pkt)) < 0)
2318 return ret;
2321 if ((ret = handle_user_control(s, pkt)) < 0)
2322 return ret;
2325 if ((ret = handle_set_peer_bw(s, pkt)) < 0)
2326 return ret;
2329 if ((ret = handle_window_ack_size(s, pkt)) < 0)
2330 return ret;
2333 if ((ret = handle_invoke(s, pkt)) < 0)
2334 return ret;
2351 int ret, old_flv_size, type;
2359 if ((ret = av_reallocp(&rt->flv_data, rt->flv_size)) < 0) {
2361 return ret;
2413 int ret;
2420 if ((ret = ff_rtmp_packet_read(rt->stream, &rpkt,
2423 if (ret == 0) {
2433 rt->bytes_read += ret;
2436 if ((ret = gen_bytes_read(s, rt, rpkt.timestamp + 1)) < 0) {
2438 return ret;
2443 ret = rtmp_parse_result(s, rt, &rpkt);
2455 if (ret < 0) {//serious error in current packet
2457 return ret;
2479 ret = append_flv_data(rt, &rpkt, 0);
2481 return ret;
2483 ret = handle_notify(s, &rpkt);
2485 return ret;
2487 ret = handle_metadata(rt, &rpkt);
2489 return ret;
2498 int ret = 0, i, j;
2505 ret = gen_fcunpublish_stream(h, rt);
2508 ret = gen_delete_stream(h, rt);
2518 return ret;
2601 int ret;
2666 if ((ret = ffurl_open_whitelist(&rt->stream, buf, AVIO_FLAG_READ_WRITE,
2674 if ((ret = rtmp_calc_swfhash(s)) < 0)
2679 if (!rt->listen && (ret = rtmp_handshake(s, rt)) < 0)
2681 if (rt->listen && (ret = rtmp_server_handshake(s, rt)) < 0)
2693 ret = AVERROR(ENOMEM);
2743 ret = AVERROR(EINVAL);
2756 ret = AVERROR(ENOMEM);
2780 ret = AVERROR(ENOMEM);
2790 ret = AVERROR(ENOMEM);
2815 if ((ret = gen_connect(s, rt)) < 0)
2818 if ((ret = read_connect(s, s->priv_data)) < 0)
2823 ret = get_packet(s, 1);
2824 } while (ret == AVERROR(EAGAIN));
2825 if (ret < 0)
2843 if ((ret = av_reallocp(&rt->flv_data, rt->flv_size)) < 0)
2854 if ((ret = get_packet(s, 0)) < 0)
2872 if ((ret = inject_fake_duration_metadata(rt)) < 0)
2892 return ret;
2899 int ret;
2916 if ((ret = get_packet(s, 0)) < 0)
2917 return ret;
2926 int ret;
2930 if ((ret = gen_seek(s, rt, timestamp)) < 0) {
2935 return ret;
2945 int ret;
2948 if ((ret = gen_pause(s, rt, pause, rt->last_timestamp)) < 0) {
2951 return ret;
2964 int ret;
2998 if ((ret = ff_rtmp_check_alloc_array(&rt->prev_pkt[1],
3001 return ret;
3009 if ((ret = ff_rtmp_packet_create(&rt->out_pkt, channel,
3011 return ret;
3040 if ((ret = av_reallocp(&rt->out_pkt.data, rt->out_pkt.size + 16)) < 0) {
3042 return ret;
3052 if ((ret = rtmp_send_packet(rt, &rt->out_pkt, 0)) < 0)
3053 return ret;
3069 ret = ffurl_read(rt->stream, &c, 1);
3074 if (ret == AVERROR(EAGAIN)) {
3077 } else if (ret < 0) {
3078 return ret;
3079 } else if (ret == 1) {
3082 if ((ret = ff_rtmp_packet_read_internal(rt->stream, &rpkt,
3086 return ret;
3088 if ((ret = rtmp_parse_result(s, rt, &rpkt)) < 0)
3089 return ret;