| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "components/policy/core/common/remote_commands/remote_command_job.h" | 5 #include "components/policy/core/common/remote_commands/remote_command_job.h" |
| 6 | 6 |
| 7 #include <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/logging.h" | 10 #include "base/chromeos/logging.h" |
| 11 | 11 |
| 12 namespace policy { | 12 namespace policy { |
| 13 | 13 |
| 14 namespace { | 14 namespace { |
| 15 | 15 |
| 16 const int kDefaultCommandTimeoutInMinutes = 3; | 16 const int kDefaultCommandTimeoutInMinutes = 3; |
| 17 | 17 |
| 18 } // namespace | 18 } // namespace |
| 19 | 19 |
| 20 namespace em = enterprise_management; | 20 namespace em = enterprise_management; |
| (...skipping 20 matching lines...) Expand all Loading... |
| 41 if (command.has_age_of_command()) { | 41 if (command.has_age_of_command()) { |
| 42 // Use age of command provided by server to estimate the command issued time | 42 // Use age of command provided by server to estimate the command issued time |
| 43 // as a local TimeTick. We need to store issued time instead of age of | 43 // as a local TimeTick. We need to store issued time instead of age of |
| 44 // command, since the execution time of command might be different from the | 44 // command, since the execution time of command might be different from the |
| 45 // time we got it from server. | 45 // time we got it from server. |
| 46 // It's just an estimation since we lost the time the response was | 46 // It's just an estimation since we lost the time the response was |
| 47 // transmitted over the network. | 47 // transmitted over the network. |
| 48 issued_time_ = | 48 issued_time_ = |
| 49 now - base::TimeDelta::FromMilliseconds(command.age_of_command()); | 49 now - base::TimeDelta::FromMilliseconds(command.age_of_command()); |
| 50 } else { | 50 } else { |
| 51 LOG(WARNING) << "No age_of_command provided be server for command " | 51 CHROMEOS_SYSLOG(WARNING) |
| 52 << unique_id_ << "."; | 52 << "No age_of_command provided be server for command " << unique_id_ |
| 53 << "."; |
| 53 // Otherwise, assuming the command was issued just now. | 54 // Otherwise, assuming the command was issued just now. |
| 54 issued_time_ = now; | 55 issued_time_ = now; |
| 55 } | 56 } |
| 56 | 57 |
| 57 if (!ParseCommandPayload(command.payload())) | 58 if (!ParseCommandPayload(command.payload())) |
| 58 return false; | 59 return false; |
| 59 | 60 |
| 61 switch (command.type()) { |
| 62 case em::RemoteCommand_Type_COMMAND_ECHO_TEST: { |
| 63 CHROMEOS_SYSLOG(WARNING) << "Remote echo test command " << unique_id_ |
| 64 << " initialized."; |
| 65 break; |
| 66 } |
| 67 case em::RemoteCommand_Type_DEVICE_REBOOT: { |
| 68 CHROMEOS_SYSLOG(WARNING) << "Remote reboot command " << unique_id_ |
| 69 << " initialized."; |
| 70 break; |
| 71 } |
| 72 case em::RemoteCommand_Type_DEVICE_SCREENSHOT: { |
| 73 CHROMEOS_SYSLOG(WARNING) << "Remote screenshot command " << unique_id_ |
| 74 << " initialized."; |
| 75 break; |
| 76 } |
| 77 } |
| 60 status_ = NOT_STARTED; | 78 status_ = NOT_STARTED; |
| 61 return true; | 79 return true; |
| 62 } | 80 } |
| 63 | 81 |
| 64 bool RemoteCommandJob::Run(base::TimeTicks now, | 82 bool RemoteCommandJob::Run(base::TimeTicks now, |
| 65 const FinishedCallback& finished_callback) { | 83 const FinishedCallback& finished_callback) { |
| 66 DCHECK(thread_checker_.CalledOnValidThread()); | 84 DCHECK(thread_checker_.CalledOnValidThread()); |
| 67 | 85 |
| 68 if (status_ == INVALID) | 86 if (status_ == INVALID) { |
| 87 CHROMEOS_SYSLOG(ERROR) << "Remote command " << unique_id_ << " is invalid."; |
| 69 return false; | 88 return false; |
| 89 } |
| 70 | 90 |
| 71 DCHECK_EQ(NOT_STARTED, status_); | 91 DCHECK_EQ(NOT_STARTED, status_); |
| 72 | 92 |
| 73 if (IsExpired(now)) { | 93 if (IsExpired(now)) { |
| 94 CHROMEOS_SYSLOG(ERROR) << "Remote command " << unique_id_ |
| 95 << " expired (it was issued " << now - issued_time_ |
| 96 << " ago)."; |
| 74 status_ = EXPIRED; | 97 status_ = EXPIRED; |
| 75 return false; | 98 return false; |
| 76 } | 99 } |
| 77 | 100 |
| 78 execution_started_time_ = now; | 101 execution_started_time_ = now; |
| 79 status_ = RUNNING; | 102 status_ = RUNNING; |
| 80 finished_callback_ = finished_callback; | 103 finished_callback_ = finished_callback; |
| 81 | 104 |
| 82 RunImpl(base::Bind(&RemoteCommandJob::OnCommandExecutionFinishedWithResult, | 105 RunImpl(base::Bind(&RemoteCommandJob::OnCommandExecutionFinishedWithResult, |
| 83 weak_factory_.GetWeakPtr(), true), | 106 weak_factory_.GetWeakPtr(), true), |
| (...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 147 DCHECK_EQ(RUNNING, status_); | 170 DCHECK_EQ(RUNNING, status_); |
| 148 status_ = succeeded ? SUCCEEDED : FAILED; | 171 status_ = succeeded ? SUCCEEDED : FAILED; |
| 149 | 172 |
| 150 result_payload_ = std::move(result_payload); | 173 result_payload_ = std::move(result_payload); |
| 151 | 174 |
| 152 if (!finished_callback_.is_null()) | 175 if (!finished_callback_.is_null()) |
| 153 finished_callback_.Run(); | 176 finished_callback_.Run(); |
| 154 } | 177 } |
| 155 | 178 |
| 156 } // namespace policy | 179 } // namespace policy |
| OLD | NEW |