| /system/core/init/ |
| D | action_manager.cpp | 28 for (const auto& action : actions_) { in CheckAllCommands() local
29 failures += action->CheckAllCommands(); in CheckAllCommands()
39 void ActionManager::AddAction(std::unique_ptr<Action> action) { in AddAction() argument
40 actions_.emplace_back(std::move(action)); in AddAction()
59 auto action = std::make_unique<Action>(true, nullptr, "<Builtin Action>", 0, name, in QueueBuiltinAction() local
61 action->AddCommand(std::move(func), {name}, 0); in QueueBuiltinAction()
63 event_queue_.emplace(action.get()); in QueueBuiltinAction()
64 actions_.emplace_back(std::move(action)); in QueueBuiltinAction()
70 // Loop through the event queue until we have an action to execute in ExecuteOneCommand()
72 for (const auto& action : actions_) { in ExecuteOneCommand() local
[all …]
|
| D | action.cpp | 17 #include "action.h"
99 Action::Action(bool oneshot, Subcontext* subcontext, const std::string& filename, int line, in Action() function in android::init::Action
109 const BuiltinFunctionMap* Action::function_map_ = nullptr;
111 Result<void> Action::AddCommand(std::vector<std::string>&& args, int line) { in AddCommand()
126 void Action::AddCommand(BuiltinFunction f, std::vector<std::string>&& args, int line) { in AddCommand()
130 std::size_t Action::NumCommands() const { in NumCommands()
134 size_t Action::CheckAllCommands() const { in CheckAllCommands()
146 void Action::ExecuteOneCommand(std::size_t command) const { in ExecuteOneCommand()
153 void Action::ExecuteAllCommands() const { in ExecuteAllCommands()
159 void Action::ExecuteCommand(const Command& command) const { in ExecuteCommand()
[all …]
|
| D | reboot_utils.cpp | 178 struct sigaction action; in InstallRebootSignalHandlers() local
179 memset(&action, 0, sizeof(action)); in InstallRebootSignalHandlers()
180 sigfillset(&action.sa_mask); in InstallRebootSignalHandlers()
181 action.sa_handler = [](int signal) { in InstallRebootSignalHandlers()
194 action.sa_flags = SA_RESTART; in InstallRebootSignalHandlers()
195 sigaction(SIGABRT, &action, nullptr); in InstallRebootSignalHandlers()
196 sigaction(SIGBUS, &action, nullptr); in InstallRebootSignalHandlers()
197 sigaction(SIGFPE, &action, nullptr); in InstallRebootSignalHandlers()
198 sigaction(SIGILL, &action, nullptr); in InstallRebootSignalHandlers()
199 sigaction(SIGSEGV, &action, nullptr); in InstallRebootSignalHandlers()
[all …]
|
| D | action_manager.h | 25 #include "action.h"
39 void AddAction(std::unique_ptr<Action> action);
58 std::vector<std::unique_ptr<Action>> actions_;
62 std::queue<const Action*> current_executing_actions_;
|
| /system/update_engine/common/ |
| D | action.h | 31 // The structure of these classes (Action, ActionPipe, ActionProcessor, etc.)
50 // code in the Action* classes and the code that is calls is non-blocking.
53 // ActionProcessor::StartProcessing() is called, it executes the first action.
54 // Each action tells the processor when it has completed, which causes the
55 // Processor to execute the next action. ActionProcessor may have a delegate
67 // InputObjectType. Each action class also has two typedefs of the same name
72 // Each concrete Action class derives from Action<T>. This means that during
73 // template instantiation of Action<T>, T is declared but not defined, which
76 // template instantiated first, so Action<T> *can* find the types it needs by
88 // Begin performing the action. Since this code is asynchronous, when this
[all …]
|
| D | action_processor.h | 30 // The structure of these classes (Action, ActionPipe, ActionProcessor, etc.)
36 // See action.h for an overview of this class and other Action* classes.
51 // Starts processing the first Action in the queue. If there's a delegate,
56 // Aborts processing. If an Action is running, it will have
57 // TerminateProcessing() called on it. The Action that was running and all the
62 // Suspend the processing. If an Action is running, it will have the
66 // processing is suspended or not running this method performs no action.
70 // or not running in the first place this method performs no action.
77 // Adds another Action to the end of the queue.
78 virtual void EnqueueAction(std::unique_ptr<AbstractAction> action);
[all …]
|
| D | action_unittest.cc | 17 #include "update_engine/common/action.h"
41 // This is a simple Action class for testing.
42 class ActionTestAction : public Action<ActionTestAction> {
62 auto action = std::make_unique<ActionTestAction>(); in TEST() local
63 auto action_ptr = action.get(); in TEST()
64 EXPECT_FALSE(action->in_pipe()); in TEST()
65 EXPECT_FALSE(action->out_pipe()); in TEST()
66 EXPECT_FALSE(action->processor()); in TEST()
67 EXPECT_FALSE(action->IsRunning()); in TEST()
70 action_processor.EnqueueAction(std::move(action)); in TEST()
|
| D | action_processor.cc | 24 #include "update_engine/common/action.h"
37 void ActionProcessor::EnqueueAction(unique_ptr<AbstractAction> action) { in EnqueueAction() argument
38 action->SetProcessor(this); in EnqueueAction()
39 actions_.push_back(std::move(action)); in EnqueueAction()
73 // No current_action_ when not suspended means that the action processor was in SuspendProcessing()
81 // If there's a current action we should notify it that it should suspend, but in SuspendProcessing()
82 // the action can ignore that and terminate at any point. in SuspendProcessing()
99 // The last action called ActionComplete while suspended, so there is in ResumeProcessing()
100 // already a log message with the type of the finished action. We simply in ResumeProcessing()
102 // start of the next action or processing completion. in ResumeProcessing()
[all …]
|
| D | action_pipe.h | 29 // The structure of these classes (Action, ActionPipe, ActionProcessor, etc.)
36 // from one Action and into another Action. It's templated so that it may
37 // contain any type of object that an Action outputs/inputs. Actions
42 // the two Action objects. a shared_ptr is used so that when the last Action
52 class Action; variable
59 // This should be called by an Action on its input pipe.
63 // This should be called by an Action on its output pipe.
69 // when the last Action is destroyed.
|
| D | mock_action_processor.h | 26 #include "update_engine/common/action.h"
33 MOCK_METHOD1(EnqueueAction, void(AbstractAction* action));
39 void EnqueueAction(std::unique_ptr<AbstractAction> action) override { in EnqueueAction() argument
40 EnqueueAction(action.get()); in EnqueueAction()
|
| D | action_processor_unittest.cc | 24 #include "update_engine/common/action.h"
42 // This is a simple Action class for testing.
43 class ActionProcessorTestAction : public Action<ActionProcessorTestAction> {
80 AbstractAction* action, in ActionCompleted() argument
200 // This test suspends and resume the action processor while running one action.
210 // Suspending the processor twice should not suspend the action twice. in TEST_F()
213 // IsRunning should return whether there's is an action doing some work, even in TEST_F()
226 // This test suspends an action that presumably doesn't support suspend/resume
238 // Simulate the action completion while suspended. No other call to in TEST_F()
|
| D | test_utils.h | 34 #include "update_engine/common/action.h"
175 // This is a simple Action class for testing. It feeds an object into
176 // another action.
178 class ObjectFeederAction final : public Action<ObjectFeederAction<T>> {
208 // This is a simple Action class for testing. It receives an object from
209 // another action.
211 class ObjectCollectorAction : public Action<ObjectCollectorAction<T>> {
|
| /system/netd/server/ |
| D | NetlinkHandler.cpp | 111 NetlinkEvent::Action action = evt->getAction(); in onEvent() local
113 if (action == NetlinkEvent::Action::kAdd) { in onEvent()
115 } else if (action == NetlinkEvent::Action::kRemove) { in onEvent()
117 } else if (action == NetlinkEvent::Action::kChange) { in onEvent()
120 } else if (action == NetlinkEvent::Action::kLinkUp) { in onEvent()
122 } else if (action == NetlinkEvent::Action::kLinkDown) { in onEvent()
124 } else if (action == NetlinkEvent::Action::kAddressUpdated || in onEvent()
125 action == NetlinkEvent::Action::kAddressRemoved) { in onEvent()
141 const bool addrUpdated = (action == NetlinkEvent::Action::kAddressUpdated); in onEvent()
144 } else { // action == NetlinkEvent::Action::kAddressRemoved in onEvent()
[all …]
|
| /system/chre/util/include/chre/util/ |
| D | throttle.h | 21 * Throttles an action to a given interval and maximum number of times.
22 * The action will be called at most maxCount in every interval.
24 * @param action The action to throttle
26 * @param maxCount The maximum number of times to call the action
29 #define CHRE_THROTTLE(action, interval, maxCount, getTime) \ argument
43 action; \
|
| /system/core/debuggerd/include/debuggerd/ |
| D | handler.h | 81 static void __attribute__((__unused__)) debuggerd_register_handlers(struct sigaction* action) { in debuggerd_register_handlers() argument
88 sigaction(SIGABRT, action, nullptr); in debuggerd_register_handlers()
89 sigaction(SIGBUS, action, nullptr); in debuggerd_register_handlers()
90 sigaction(SIGFPE, action, nullptr); in debuggerd_register_handlers()
91 sigaction(SIGILL, action, nullptr); in debuggerd_register_handlers()
92 sigaction(SIGSEGV, action, nullptr); in debuggerd_register_handlers()
93 sigaction(SIGSTKFLT, action, nullptr); in debuggerd_register_handlers()
94 sigaction(SIGSYS, action, nullptr); in debuggerd_register_handlers()
95 sigaction(SIGTRAP, action, nullptr); in debuggerd_register_handlers()
98 sigaction(BIONIC_SIGNAL_DEBUGGER, action, nullptr); in debuggerd_register_handlers()
|
| /system/extras/boottime_tools/bootanalyze/ |
| D | config.yaml | 19 late_init: processing action \(late-init\)
23 fs: processing action \(fs\)
24 post-fs: processing action \(post-fs\)
25 late-fs: processing action \(late-fs\)
26 post-fs-data: processing action \(post-fs-data\)
27 nonencrypted: processing action \(nonencrypted\)
31 load_persist_props_action: processing action \(load_persist_props_action\)
32 early-boot: processing action \(early-boot\)
33 boot: processing action \(boot\)
63 BootComplete_kernel: processing action \(sys\.boot_completed=1\)
[all …]
|
| /system/extras/verity/ |
| D | build_verity_metadata.py | 93 parser_size.add_argument('partition_size', type=int, action='store', help='partition size')
98 parser_build.add_argument('metadata_image', action='store', help='metadata image')
99 parser_build.add_argument('root_hash', action='store', help='root hash')
100 parser_build.add_argument('salt', action='store', help='salt')
101 parser_build.add_argument('block_device', action='store', help='block device')
102 parser_build.add_argument('signer_path', action='store', help='verity signer path')
103 parser_build.add_argument('signing_key', action='store', help='verity signing key')
104 parser_build.add_argument('--signer_args', action='store', help='verity signer args')
105 parser_build.add_argument('--verity_disable', action='store_true',
|
| /system/update_engine/payload_consumer/ |
| D | postinstall_runner_action_unittest.cc | 73 AbstractAction* action, in ActionCompleted() argument
75 if (action->Type() == PostinstallRunnerAction::StaticType()) { in ActionCompleted()
120 // Setup an action processor and run the PostinstallRunnerAction with a single
202 // A pointer to the posinstall_runner action and the processor.
265 PostinstallRunnerAction action(&fake_boot_control_, &fake_hardware_); in TEST_F() local
267 action.set_delegate(&mock_delegate_); in TEST_F()
269 action.current_partition_ = 1; in TEST_F()
270 action.partition_weight_ = {1, 2, 5}; in TEST_F()
271 action.accumulated_weight_ = 1; in TEST_F()
272 action.total_weight_ = 8; in TEST_F()
[all …]
|
| /system/extras/torq/src/ |
| D | utils.py | 86 for action in self._actions:
87 for opt in action.option_strings:
88 global_opts[opt] = action.nargs
96 for action in self._subparsers._actions:
97 if not isinstance(action, argparse._SubParsersAction):
99 for sp_name in action._name_parser_map.keys():
|
| /system/core/mini_keyctl/ |
| D | mini_keyctl.cpp | 40 fprintf(stderr, "usage: mini-keyctl <action> [args,]\n"); in Usage()
137 const std::string action = argv[1]; in main() local
139 if (action == "add") { in main()
146 } else if (action == "padd") { in main()
152 } else if (action == "restrict_keyring") { in main()
156 } else if (action == "unlink") { in main()
161 } else if (action == "security") { in main()
173 fprintf(stderr, "Unrecognized action: %s\n", action.c_str()); in main()
|
| /system/extras/simpleperf/ |
| D | cmd_boot_record.cpp | 31 enum class Action { enum
70 Action action_ = Action::NONE;
78 if (action_ == Action::ENABLE) { in Run()
86 if (action_ == Action::DISABLE) { in Run()
89 if (action_ == Action::RECORD) { in Run()
108 action_ = Action::ENABLE; in ParseOptions()
111 action_ = Action::DISABLE; in ParseOptions()
113 action_ = Action::RECORD; in ParseOptions()
|
| /system/extras/kcmdlinectrl/ |
| D | kcmdlinectrl.cc | 127 char *action, *property_name, *new_value; in main() local
130 action = argv[1]; in main()
134 action = argv[1]; in main()
138 action = argv[1]; in main()
146 if (!strcmp(action, "update-props") && property_name == NULL) { in main()
148 } else if (!strcmp(action, "get") && property_name != NULL && new_value == NULL) { in main()
150 } else if (!strcmp(action, "store") && property_name != NULL && new_value != NULL) { in main()
|
| /system/security/keystore2/tests/ |
| D | user_auth.rs | 200 // Action A: create a new auth-bound key which requires auth in the last 3 seconds, in test_auth_bound_timeout_with_gk()
241 // Action B: succeed when a valid HAT is available. in test_auth_bound_timeout_with_gk()
253 // Action C: fail again when the HAT is old enough to not even be checked. in test_auth_bound_timeout_with_gk()
291 info!("trigger child process action A and wait for completion"); in test_auth_bound_timeout_with_gk()
299 info!("trigger child process action B and wait for completion"); in test_auth_bound_timeout_with_gk()
303 info!("trigger child process action C and wait for completion"); in test_auth_bound_timeout_with_gk()
327 // Action A: create a new auth-bound key which requires auth in the last 3 seconds, in test_auth_bound_timeout_failure()
368 // Action B: fail again when an invalid HAT is available. in test_auth_bound_timeout_failure()
382 // Action C: fail again when the HAT is old enough to not even be checked. in test_auth_bound_timeout_failure()
416 info!("trigger child process action A and wait for completion"); in test_auth_bound_timeout_failure()
[all …]
|
| /system/tools/aidl/tests/ |
| D | golden_test.sh | 163 action=$1
167 if [ "$action" == "update" ]; then
171 _golden_test "$action" "$root" "false" true
172 _golden_test "$action" "$root" "true" false
174 _golden_test "$action" "$root" "true" true
175 _golden_test "$action" "$root" "false" false
178 _golden_test "$action" "$root" "$use_unfrozen" false "$*"
|
| /system/update_engine/scripts/ |
| D | update_device.py | 374 parser.add_argument('--file', action='store_true',
376 parser.add_argument('--no-push', action='store_true',
380 parser.add_argument('--no-verbose', action='store_true',
386 parser.add_argument('--secondary', action='store_true',
388 parser.add_argument('--no-slot-switch', action='store_true',
390 parser.add_argument('--no-postinstall', action='store_true',
392 parser.add_argument('--allocate-only', action='store_true',
395 parser.add_argument('--verify-only', action='store_true',
397 parser.add_argument('--no-care-map', action='store_true',
399 parser.add_argument('--perform-slot-switch', action='store_true',
[all …]
|