int remote_move(sg_host_t host, const char* fullpath);
int unlink() const; /** Remove a file from the contents of a disk */
- void dump();
+ void dump() const;
};
class XBT_PUBLIC FileSystemDiskExt {
friend XBT_PUBLIC void intrusive_ptr_release(const Actor* actor);
#endif
/** Retrieve the amount of references on that object. Useful to debug the automatic refcounting */
- int get_refcount();
+ int get_refcount() const;
// ***** Actor creation *****
/** Retrieve a reference to myself */
void resume();
/** Returns true if the actor is suspended. */
- bool is_suspended();
+ bool is_suspended() const;
/** If set to true, the actor will automatically restart when its host reboots */
void set_auto_restart(bool autorestart);
register_function(name, std::move(code_factory));
}
- void load_deployment(const std::string& deploy);
+ void load_deployment(const std::string& deploy) const;
protected:
#ifndef DOXYGEN
});
}
-double ActorImpl::get_kill_time()
+double ActorImpl::get_kill_time() const
{
return kill_timer_ ? kill_timer_->get_date() : 0;
}
~ActorImpl();
static ActorImpl* self();
- double get_kill_time();
+ double get_kill_time() const;
void set_kill_time(double kill_time);
boost::intrusive::list_member_hook<> host_actor_list_hook; /* simgrid::simix::Host::process_list */
boost::intrusive::list_member_hook<> smx_destroy_list_hook; /* simix_global->actors_to_destroy */
xbt_assert(received_size == sizeof(_type_), "Unexpected size for " _name_ " (%zd != %zu)", received_size, \
sizeof(_type_))
-void AppSide::handle_messages()
+void AppSide::handle_messages() const
{
while (true) {
XBT_DEBUG("Waiting messages from model-checker");
}
}
-void AppSide::report_assertion_failure()
+void AppSide::report_assertion_failure() const
{
if (channel_.send(MC_MESSAGE_ASSERTION_FAILED))
xbt_die("Could not send assertion to model-checker");
public:
AppSide();
explicit AppSide(int fd) : channel_(fd) {}
- void handle_messages();
+ void handle_messages() const;
private:
void handle_deadlock_check(const s_mc_message_t* msg) const;
Channel const& get_channel() const { return channel_; }
Channel& get_channel() { return channel_; }
XBT_ATTRIB_NORETURN void main_loop();
- void report_assertion_failure();
+ void report_assertion_failure() const;
void ignore_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;
kernel::actor::simcall([this, desc_table] { desc_table->push_back(this->desc_id); });
}
-void File::dump()
+void File::dump() const
{
if (local_storage_)
XBT_INFO("File Descriptor information:\n"
{
intrusive_ptr_release(actor->pimpl_);
}
-int Actor::get_refcount()
+int Actor::get_refcount() const
{
return pimpl_->get_refcount();
}
s4u::Actor::on_resume(*this);
}
-bool Actor::is_suspended()
+bool Actor::is_suspended() const
{
return pimpl_->is_suspended();
}
* See also: :ref:`deploy`.
* \endrst
*/
-void Engine::load_deployment(const std::string& deploy)
+void Engine::load_deployment(const std::string& deploy) const
{
pimpl->load_deployment(deploy);
}
void add_rma_win(MPI_Win win);
void remove_rma_win(MPI_Win win);
- void finish_rma_calls();
+ void finish_rma_calls() const;
MPI_Comm split_type(int type, int key, const Info* info);
};
int flush_local_all();
int finish_comms();
int finish_comms(int rank);
- int shared_query(int rank, MPI_Aint* size, int* disp_unit, void* baseptr);
+ int shared_query(int rank, MPI_Aint* size, int* disp_unit, void* baseptr) const;
MPI_Errhandler errhandler();
void set_errhandler( MPI_Errhandler errhandler);
};
rma_wins_.remove(win);
}
-void Comm::finish_rma_calls(){
+void Comm::finish_rma_calls() const
+{
for (auto const& it : rma_wins_) {
if(it->rank()==this->rank()){//is it ours (for MPI_COMM_WORLD)?
int finished = it->finish_comms();
return size;
}
-int Win::shared_query(int rank, MPI_Aint* size, int* disp_unit, void* baseptr)
+int Win::shared_query(int rank, MPI_Aint* size, int* disp_unit, void* baseptr) const
{
const Win* target_win = rank != MPI_PROC_NULL ? connected_wins_[rank] : nullptr;
for (int i = 0; not target_win && i < comm_->size(); i++) {