X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/72d32c4e88a57f4786f62fec48a1bfa454adbff9..da64c6383731d10c6174f81b4b6a20ff0ea186ae:/src/mc/remote/AppSide.hpp diff --git a/src/mc/remote/AppSide.hpp b/src/mc/remote/AppSide.hpp index 393f1ea4d4..57189e65f0 100644 --- a/src/mc/remote/AppSide.hpp +++ b/src/mc/remote/AppSide.hpp @@ -1,6 +1,6 @@ /* mc::remote::AppSide: the Application-side of the channel */ -/* Copyright (c) 2015-2022. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2015-2023. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -22,24 +22,31 @@ class XBT_PUBLIC AppSide { private: Channel channel_; static std::unique_ptr instance_; + bool need_memory_info_ = false; /* by default we don't send memory info, unless we got a NEED_MEMINFO */ + std::unordered_map child_statuses_; public: AppSide(); explicit AppSide(int fd) : channel_(fd) {} - void handle_messages() const; + void handle_messages(); private: void handle_deadlock_check(const s_mc_message_t* msg) const; void handle_simcall_execute(const s_mc_message_simcall_execute_t* message) const; - void handle_actor_enabled(const s_mc_message_actor_enabled_t* msg) const; void handle_finalize(const s_mc_message_int_t* msg) const; + void handle_fork(const s_mc_message_fork_t* msg); + void handle_wait_child(const s_mc_message_int_t* msg); + void handle_need_meminfo(); + void handle_actors_status() const; + void handle_actors_maxpid() const; public: Channel const& get_channel() const { return channel_; } Channel& get_channel() { return channel_; } - XBT_ATTRIB_NORETURN void main_loop() const; - void report_assertion_failure() const; + XBT_ATTRIB_NORETURN void main_loop(); + void report_assertion_failure(); void ignore_memory(void* addr, std::size_t size) const; + void unignore_memory(void* addr, std::size_t size) const; void ignore_heap(void* addr, std::size_t size) const; void unignore_heap(void* addr, std::size_t size) const; void declare_symbol(const char* name, int* value) const; @@ -47,10 +54,8 @@ public: void declare_stack(void* stack, size_t size, ucontext_t* context) const; #endif - // Singleton :/ // TODO, remove the singleton antipattern. - static AppSide* initialize(xbt_dynar_t actors_addr); - static AppSide* get() { return instance_.get(); } + static AppSide* get(); }; } // namespace simgrid::mc