正在显示
4 个修改的文件
包含
15 行增加
和
21 行删除
| @@ -344,6 +344,7 @@ private: | @@ -344,6 +344,7 @@ private: | ||
| 344 | * if reload, reload the config file. | 344 | * if reload, reload the config file. |
| 345 | */ | 345 | */ |
| 346 | std::string config_file; | 346 | std::string config_file; |
| 347 | +protected: | ||
| 347 | /** | 348 | /** |
| 348 | * the directive root. | 349 | * the directive root. |
| 349 | */ | 350 | */ |
| @@ -72,6 +72,11 @@ int MockSrsConfig::parse(string buf) | @@ -72,6 +72,11 @@ int MockSrsConfig::parse(string buf) | ||
| 72 | if ((ret = parse_buffer(&buffer)) != ERROR_SUCCESS) { | 72 | if ((ret = parse_buffer(&buffer)) != ERROR_SUCCESS) { |
| 73 | return ret; | 73 | return ret; |
| 74 | } | 74 | } |
| 75 | + | ||
| 76 | + if ((ret = srs_config_transform_vhost(root)) != ERROR_SUCCESS) { | ||
| 77 | + srs_error("transform config failed. ret=%d", ret); | ||
| 78 | + return ret; | ||
| 79 | + } | ||
| 75 | 80 | ||
| 76 | return check_config(); | 81 | return check_config(); |
| 77 | } | 82 | } |
| @@ -52,10 +52,7 @@ void MockReloadHandler::reset() | @@ -52,10 +52,7 @@ void MockReloadHandler::reset() | ||
| 52 | vhost_http_updated_reloaded = false; | 52 | vhost_http_updated_reloaded = false; |
| 53 | vhost_added_reloaded = false; | 53 | vhost_added_reloaded = false; |
| 54 | vhost_removed_reloaded = false; | 54 | vhost_removed_reloaded = false; |
| 55 | - vhost_atc_reloaded = false; | ||
| 56 | - vhost_gop_cache_reloaded = false; | ||
| 57 | - vhost_queue_length_reloaded = false; | ||
| 58 | - vhost_time_jitter_reloaded = false; | 55 | + vhost_play_reloaded = false; |
| 59 | vhost_forward_reloaded = false; | 56 | vhost_forward_reloaded = false; |
| 60 | vhost_hls_reloaded = false; | 57 | vhost_hls_reloaded = false; |
| 61 | vhost_dvr_reloaded = false; | 58 | vhost_dvr_reloaded = false; |
| @@ -88,10 +85,7 @@ int MockReloadHandler::count_true() | @@ -88,10 +85,7 @@ int MockReloadHandler::count_true() | ||
| 88 | if (vhost_http_updated_reloaded) count_true++; | 85 | if (vhost_http_updated_reloaded) count_true++; |
| 89 | if (vhost_added_reloaded) count_true++; | 86 | if (vhost_added_reloaded) count_true++; |
| 90 | if (vhost_removed_reloaded) count_true++; | 87 | if (vhost_removed_reloaded) count_true++; |
| 91 | - if (vhost_atc_reloaded) count_true++; | ||
| 92 | - if (vhost_gop_cache_reloaded) count_true++; | ||
| 93 | - if (vhost_queue_length_reloaded) count_true++; | ||
| 94 | - if (vhost_time_jitter_reloaded) count_true++; | 88 | + if (vhost_play_reloaded) count_true++; |
| 95 | if (vhost_forward_reloaded) count_true++; | 89 | if (vhost_forward_reloaded) count_true++; |
| 96 | if (vhost_hls_reloaded) count_true++; | 90 | if (vhost_hls_reloaded) count_true++; |
| 97 | if (vhost_dvr_reloaded) count_true++; | 91 | if (vhost_dvr_reloaded) count_true++; |
| @@ -121,10 +115,7 @@ int MockReloadHandler::count_false() | @@ -121,10 +115,7 @@ int MockReloadHandler::count_false() | ||
| 121 | if (!vhost_http_updated_reloaded) count_false++; | 115 | if (!vhost_http_updated_reloaded) count_false++; |
| 122 | if (!vhost_added_reloaded) count_false++; | 116 | if (!vhost_added_reloaded) count_false++; |
| 123 | if (!vhost_removed_reloaded) count_false++; | 117 | if (!vhost_removed_reloaded) count_false++; |
| 124 | - if (!vhost_atc_reloaded) count_false++; | ||
| 125 | - if (!vhost_gop_cache_reloaded) count_false++; | ||
| 126 | - if (!vhost_queue_length_reloaded) count_false++; | ||
| 127 | - if (!vhost_time_jitter_reloaded) count_false++; | 118 | + if (!vhost_play_reloaded) count_false++; |
| 128 | if (!vhost_forward_reloaded) count_false++; | 119 | if (!vhost_forward_reloaded) count_false++; |
| 129 | if (!vhost_hls_reloaded) count_false++; | 120 | if (!vhost_hls_reloaded) count_false++; |
| 130 | if (!vhost_dvr_reloaded) count_false++; | 121 | if (!vhost_dvr_reloaded) count_false++; |
| @@ -232,7 +223,7 @@ int MockReloadHandler::on_reload_vhost_removed(string /*vhost*/) | @@ -232,7 +223,7 @@ int MockReloadHandler::on_reload_vhost_removed(string /*vhost*/) | ||
| 232 | 223 | ||
| 233 | int MockReloadHandler::on_reload_vhost_play(string /*vhost*/) | 224 | int MockReloadHandler::on_reload_vhost_play(string /*vhost*/) |
| 234 | { | 225 | { |
| 235 | - vhost_time_jitter_reloaded = true; | 226 | + vhost_play_reloaded = true; |
| 236 | return ERROR_SUCCESS; | 227 | return ERROR_SUCCESS; |
| 237 | } | 228 | } |
| 238 | 229 | ||
| @@ -664,7 +655,7 @@ VOID TEST(ConfigReloadTest, ReloadVhostAtc) | @@ -664,7 +655,7 @@ VOID TEST(ConfigReloadTest, ReloadVhostAtc) | ||
| 664 | handler.reset(); | 655 | handler.reset(); |
| 665 | 656 | ||
| 666 | EXPECT_TRUE(ERROR_SUCCESS == conf.do_reload(_MIN_OK_CONF"vhost a{atc on;}")); | 657 | EXPECT_TRUE(ERROR_SUCCESS == conf.do_reload(_MIN_OK_CONF"vhost a{atc on;}")); |
| 667 | - EXPECT_TRUE(handler.vhost_atc_reloaded); | 658 | + EXPECT_TRUE(handler.vhost_play_reloaded); |
| 668 | EXPECT_EQ(1, handler.count_true()); | 659 | EXPECT_EQ(1, handler.count_true()); |
| 669 | handler.reset(); | 660 | handler.reset(); |
| 670 | 661 | ||
| @@ -685,7 +676,7 @@ VOID TEST(ConfigReloadTest, ReloadVhostGopCache) | @@ -685,7 +676,7 @@ VOID TEST(ConfigReloadTest, ReloadVhostGopCache) | ||
| 685 | handler.reset(); | 676 | handler.reset(); |
| 686 | 677 | ||
| 687 | EXPECT_TRUE(ERROR_SUCCESS == conf.do_reload(_MIN_OK_CONF"vhost a{gop_cache on;}")); | 678 | EXPECT_TRUE(ERROR_SUCCESS == conf.do_reload(_MIN_OK_CONF"vhost a{gop_cache on;}")); |
| 688 | - EXPECT_TRUE(handler.vhost_gop_cache_reloaded); | 679 | + EXPECT_TRUE(handler.vhost_play_reloaded); |
| 689 | EXPECT_EQ(1, handler.count_true()); | 680 | EXPECT_EQ(1, handler.count_true()); |
| 690 | handler.reset(); | 681 | handler.reset(); |
| 691 | 682 | ||
| @@ -706,7 +697,7 @@ VOID TEST(ConfigReloadTest, ReloadVhostQueueLength) | @@ -706,7 +697,7 @@ VOID TEST(ConfigReloadTest, ReloadVhostQueueLength) | ||
| 706 | handler.reset(); | 697 | handler.reset(); |
| 707 | 698 | ||
| 708 | EXPECT_TRUE(ERROR_SUCCESS == conf.do_reload(_MIN_OK_CONF"vhost a{queue_length 20;}")); | 699 | EXPECT_TRUE(ERROR_SUCCESS == conf.do_reload(_MIN_OK_CONF"vhost a{queue_length 20;}")); |
| 709 | - EXPECT_TRUE(handler.vhost_queue_length_reloaded); | 700 | + EXPECT_TRUE(handler.vhost_play_reloaded); |
| 710 | EXPECT_EQ(1, handler.count_true()); | 701 | EXPECT_EQ(1, handler.count_true()); |
| 711 | handler.reset(); | 702 | handler.reset(); |
| 712 | 703 | ||
| @@ -727,7 +718,7 @@ VOID TEST(ConfigReloadTest, ReloadVhostTimeJitter) | @@ -727,7 +718,7 @@ VOID TEST(ConfigReloadTest, ReloadVhostTimeJitter) | ||
| 727 | handler.reset(); | 718 | handler.reset(); |
| 728 | 719 | ||
| 729 | EXPECT_TRUE(ERROR_SUCCESS == conf.do_reload(_MIN_OK_CONF"vhost a{time_jitter zero;}")); | 720 | EXPECT_TRUE(ERROR_SUCCESS == conf.do_reload(_MIN_OK_CONF"vhost a{time_jitter zero;}")); |
| 730 | - EXPECT_TRUE(handler.vhost_time_jitter_reloaded); | 721 | + EXPECT_TRUE(handler.vhost_play_reloaded); |
| 731 | EXPECT_EQ(1, handler.count_true()); | 722 | EXPECT_EQ(1, handler.count_true()); |
| 732 | handler.reset(); | 723 | handler.reset(); |
| 733 | 724 |
| @@ -49,10 +49,7 @@ public: | @@ -49,10 +49,7 @@ public: | ||
| 49 | bool vhost_http_updated_reloaded; | 49 | bool vhost_http_updated_reloaded; |
| 50 | bool vhost_added_reloaded; | 50 | bool vhost_added_reloaded; |
| 51 | bool vhost_removed_reloaded; | 51 | bool vhost_removed_reloaded; |
| 52 | - bool vhost_atc_reloaded; | ||
| 53 | - bool vhost_gop_cache_reloaded; | ||
| 54 | - bool vhost_queue_length_reloaded; | ||
| 55 | - bool vhost_time_jitter_reloaded; | 52 | + bool vhost_play_reloaded; |
| 56 | bool vhost_forward_reloaded; | 53 | bool vhost_forward_reloaded; |
| 57 | bool vhost_hls_reloaded; | 54 | bool vhost_hls_reloaded; |
| 58 | bool vhost_dvr_reloaded; | 55 | bool vhost_dvr_reloaded; |
-
请 注册 或 登录 后发表评论