| Alex Deymo | aea4c1c | 2015-08-19 20:24:43 -0700 | [diff] [blame] | 1 | // | 
|  | 2 | // Copyright (C) 2013 The Android Open Source Project | 
|  | 3 | // | 
|  | 4 | // Licensed under the Apache License, Version 2.0 (the "License"); | 
|  | 5 | // you may not use this file except in compliance with the License. | 
|  | 6 | // You may obtain a copy of the License at | 
|  | 7 | // | 
|  | 8 | //      http://www.apache.org/licenses/LICENSE-2.0 | 
|  | 9 | // | 
|  | 10 | // Unless required by applicable law or agreed to in writing, software | 
|  | 11 | // distributed under the License is distributed on an "AS IS" BASIS, | 
|  | 12 | // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | 
|  | 13 | // See the License for the specific language governing permissions and | 
|  | 14 | // limitations under the License. | 
|  | 15 | // | 
| David Zeuthen | 27a48bc | 2013-08-06 12:06:29 -0700 | [diff] [blame] | 16 |  | 
| Gilad Arnold | cf175a0 | 2014-07-10 16:48:47 -0700 | [diff] [blame] | 17 | #ifndef UPDATE_ENGINE_FAKE_P2P_MANAGER_CONFIGURATION_H_ | 
|  | 18 | #define UPDATE_ENGINE_FAKE_P2P_MANAGER_CONFIGURATION_H_ | 
| David Zeuthen | 27a48bc | 2013-08-06 12:06:29 -0700 | [diff] [blame] | 19 |  | 
|  | 20 | #include "update_engine/p2p_manager.h" | 
| David Zeuthen | 27a48bc | 2013-08-06 12:06:29 -0700 | [diff] [blame] | 21 |  | 
| Alex Vakulenko | d2779df | 2014-06-16 13:19:00 -0700 | [diff] [blame] | 22 | #include <string> | 
|  | 23 | #include <vector> | 
|  | 24 |  | 
| Sen Jiang | 371615b | 2016-04-13 15:54:29 -0700 | [diff] [blame] | 25 | #include <base/files/scoped_temp_dir.h> | 
| Alex Deymo | 39910dc | 2015-11-09 17:04:30 -0800 | [diff] [blame] | 26 | #include <base/strings/string_util.h> | 
| Sen Jiang | 371615b | 2016-04-13 15:54:29 -0700 | [diff] [blame] | 27 | #include <gtest/gtest.h> | 
| David Zeuthen | 27a48bc | 2013-08-06 12:06:29 -0700 | [diff] [blame] | 28 |  | 
|  | 29 | namespace chromeos_update_engine { | 
|  | 30 |  | 
|  | 31 | // Configuration for P2PManager for use in unit tests. Instead of | 
|  | 32 | // /var/cache/p2p, a temporary directory is used. | 
|  | 33 | class FakeP2PManagerConfiguration : public P2PManager::Configuration { | 
| Alex Vakulenko | d2779df | 2014-06-16 13:19:00 -0700 | [diff] [blame] | 34 | public: | 
| Alex Deymo | b339155 | 2015-07-10 10:48:06 -0700 | [diff] [blame] | 35 | FakeP2PManagerConfiguration() { | 
| Sen Jiang | 371615b | 2016-04-13 15:54:29 -0700 | [diff] [blame] | 36 | EXPECT_TRUE(p2p_dir_.CreateUniqueTempDir()); | 
| David Zeuthen | 27a48bc | 2013-08-06 12:06:29 -0700 | [diff] [blame] | 37 | } | 
|  | 38 |  | 
|  | 39 | // P2PManager::Configuration override | 
| Alex Deymo | 610277e | 2014-11-11 21:18:11 -0800 | [diff] [blame] | 40 | base::FilePath GetP2PDir() override { | 
| Sen Jiang | 371615b | 2016-04-13 15:54:29 -0700 | [diff] [blame] | 41 | return p2p_dir_.path(); | 
| Alex Vakulenko | d2779df | 2014-06-16 13:19:00 -0700 | [diff] [blame] | 42 | } | 
| David Zeuthen | 27a48bc | 2013-08-06 12:06:29 -0700 | [diff] [blame] | 43 |  | 
|  | 44 | // P2PManager::Configuration override | 
| Alex Deymo | 610277e | 2014-11-11 21:18:11 -0800 | [diff] [blame] | 45 | std::vector<std::string> GetInitctlArgs(bool is_start) override { | 
| David Zeuthen | 27a48bc | 2013-08-06 12:06:29 -0700 | [diff] [blame] | 46 | return is_start ? initctl_start_args_ : initctl_stop_args_; | 
|  | 47 | } | 
|  | 48 |  | 
|  | 49 | // P2PManager::Configuration override | 
| Alex Deymo | 610277e | 2014-11-11 21:18:11 -0800 | [diff] [blame] | 50 | std::vector<std::string> GetP2PClientArgs(const std::string &file_id, | 
|  | 51 | size_t minimum_size) override { | 
| Alex Deymo | b339155 | 2015-07-10 10:48:06 -0700 | [diff] [blame] | 52 | std::vector<std::string> formatted_command = p2p_client_cmd_format_; | 
| Alex Deymo | 8ad6da9 | 2014-07-15 17:17:45 -0700 | [diff] [blame] | 53 | // Replace {variable} on the passed string. | 
| Alex Deymo | c00c98a | 2015-03-17 17:38:00 -0700 | [diff] [blame] | 54 | std::string str_minimum_size = std::to_string(minimum_size); | 
| Alex Deymo | b339155 | 2015-07-10 10:48:06 -0700 | [diff] [blame] | 55 | for (std::string& arg : formatted_command) { | 
| Alex Vakulenko | 0057daa | 2016-01-23 16:22:50 -0800 | [diff] [blame] | 56 | base::ReplaceSubstringsAfterOffset(&arg, 0, "{file_id}", file_id); | 
|  | 57 | base::ReplaceSubstringsAfterOffset(&arg, 0, "{minsize}", | 
|  | 58 | str_minimum_size); | 
| Alex Deymo | b339155 | 2015-07-10 10:48:06 -0700 | [diff] [blame] | 59 | } | 
|  | 60 | return formatted_command; | 
| David Zeuthen | 27a48bc | 2013-08-06 12:06:29 -0700 | [diff] [blame] | 61 | } | 
|  | 62 |  | 
|  | 63 | // Use |command_line| instead of "initctl start p2p" when attempting | 
|  | 64 | // to start the p2p service. | 
| Alex Deymo | b339155 | 2015-07-10 10:48:06 -0700 | [diff] [blame] | 65 | void SetInitctlStartCommand(const std::vector<std::string>& command) { | 
|  | 66 | initctl_start_args_ = command; | 
| David Zeuthen | 27a48bc | 2013-08-06 12:06:29 -0700 | [diff] [blame] | 67 | } | 
|  | 68 |  | 
|  | 69 | // Use |command_line| instead of "initctl stop p2p" when attempting | 
|  | 70 | // to stop the p2p service. | 
| Alex Deymo | b339155 | 2015-07-10 10:48:06 -0700 | [diff] [blame] | 71 | void SetInitctlStopCommand(const std::vector<std::string>& command) { | 
|  | 72 | initctl_stop_args_ = command; | 
| David Zeuthen | 27a48bc | 2013-08-06 12:06:29 -0700 | [diff] [blame] | 73 | } | 
|  | 74 |  | 
| Alex Deymo | b339155 | 2015-07-10 10:48:06 -0700 | [diff] [blame] | 75 | // Use |command_format| instead of "p2p-client --get-url={file_id} | 
| Alex Deymo | 8ad6da9 | 2014-07-15 17:17:45 -0700 | [diff] [blame] | 76 | // --minimum-size={minsize}" when attempting to look up a file using | 
| David Zeuthen | 27a48bc | 2013-08-06 12:06:29 -0700 | [diff] [blame] | 77 | // p2p-client(1). | 
|  | 78 | // | 
| Alex Deymo | b339155 | 2015-07-10 10:48:06 -0700 | [diff] [blame] | 79 | // The passed |command_format| argument can have "{file_id}" and "{minsize}" | 
|  | 80 | // as substrings of any of its elements, that will be replaced by the | 
|  | 81 | // corresponding values passed to GetP2PClientArgs(). | 
|  | 82 | void SetP2PClientCommand(const std::vector<std::string>& command_format) { | 
|  | 83 | p2p_client_cmd_format_ = command_format; | 
| David Zeuthen | 27a48bc | 2013-08-06 12:06:29 -0700 | [diff] [blame] | 84 | } | 
|  | 85 |  | 
| Alex Vakulenko | d2779df | 2014-06-16 13:19:00 -0700 | [diff] [blame] | 86 | private: | 
| David Zeuthen | 27a48bc | 2013-08-06 12:06:29 -0700 | [diff] [blame] | 87 | // The temporary directory used for p2p. | 
| Sen Jiang | 371615b | 2016-04-13 15:54:29 -0700 | [diff] [blame] | 88 | base::ScopedTempDir p2p_dir_; | 
| David Zeuthen | 27a48bc | 2013-08-06 12:06:29 -0700 | [diff] [blame] | 89 |  | 
|  | 90 | // Argument vector for starting p2p. | 
| Alex Deymo | b339155 | 2015-07-10 10:48:06 -0700 | [diff] [blame] | 91 | std::vector<std::string> initctl_start_args_{"initctl", "start", "p2p"}; | 
| David Zeuthen | 27a48bc | 2013-08-06 12:06:29 -0700 | [diff] [blame] | 92 |  | 
|  | 93 | // Argument vector for stopping p2p. | 
| Alex Deymo | b339155 | 2015-07-10 10:48:06 -0700 | [diff] [blame] | 94 | std::vector<std::string> initctl_stop_args_{"initctl", "stop", "p2p"}; | 
| David Zeuthen | 27a48bc | 2013-08-06 12:06:29 -0700 | [diff] [blame] | 95 |  | 
| Alex Deymo | 8ad6da9 | 2014-07-15 17:17:45 -0700 | [diff] [blame] | 96 | // A string for generating the p2p-client command. See the | 
|  | 97 | // SetP2PClientCommandLine() for details. | 
| Alex Deymo | b339155 | 2015-07-10 10:48:06 -0700 | [diff] [blame] | 98 | std::vector<std::string> p2p_client_cmd_format_{ | 
|  | 99 | "p2p-client", "--get-url={file_id}", "--minimum-size={minsize}"}; | 
| David Zeuthen | 27a48bc | 2013-08-06 12:06:29 -0700 | [diff] [blame] | 100 |  | 
|  | 101 | DISALLOW_COPY_AND_ASSIGN(FakeP2PManagerConfiguration); | 
|  | 102 | }; | 
|  | 103 |  | 
|  | 104 | }  // namespace chromeos_update_engine | 
|  | 105 |  | 
| Gilad Arnold | cf175a0 | 2014-07-10 16:48:47 -0700 | [diff] [blame] | 106 | #endif  // UPDATE_ENGINE_FAKE_P2P_MANAGER_CONFIGURATION_H_ |