Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
c23d735e4c7c4f3d810f7f49deff17b63bcf5355
[simgrid.git] / src / s4u / s4u_mailbox.cpp
1 /* Copyright (c) 2006-2015. The SimGrid Team.
2  * All rights reserved.                                                     */
3
4 /* This program is free software; you can redistribute it and/or modify it
5  * under the terms of the license (GNU LGPL) which comes with this package. */
6
7 #include "xbt/log.h"
8 #include "src/msg/msg_private.h"
9 #include "src/simix/ActorImpl.hpp"
10 #include "src/simix/smx_network_private.h"
11 #include "simgrid/s4u/Mailbox.hpp"
12
13 XBT_LOG_EXTERNAL_CATEGORY(s4u);
14 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(s4u_channel,s4u,"S4U Communication Mailboxes");
15
16 namespace simgrid {
17 namespace s4u {
18
19 const char *Mailbox::getName() {
20   return pimpl_->name;
21 }
22
23 MailboxPtr Mailbox::byName(const char*name)
24 {
25   // FIXME: there is a race condition here where two actors run Mailbox::byName
26   // on a non-existent mailbox during the same scheduling round. Both will be
27   // interrupted in the simcall creating the underlying simix mbox.
28   // Only one simix object will be created, but two S4U objects will be created.
29   // Only one S4U object will be stored in the hashmap and used, and the other
30   // one will be leaked.
31   smx_mailbox_t mbox = SIMIX_mbox_get_by_name(name);
32   if (mbox == nullptr)
33     mbox = simcall_mbox_create(name);
34   return MailboxPtr(&mbox->piface_, true);
35 }
36
37 MailboxPtr Mailbox::byName(std::string name)
38 {
39   return byName(name.c_str());
40 }
41
42 bool Mailbox::empty()
43 {
44   return pimpl_->comm_queue.empty();
45 }
46
47 smx_activity_t Mailbox::front()
48 {
49   return pimpl_->comm_queue.empty() ? nullptr : pimpl_->comm_queue.front();
50 }
51
52 void Mailbox::setReceiver(ActorPtr actor) {
53   simcall_mbox_set_receiver(pimpl_, actor == nullptr ? nullptr : actor->pimpl_);
54 }
55
56 /** @brief get the receiver (process associated to the mailbox) */
57 ActorPtr Mailbox::receiver() {
58   if(pimpl_->permanent_receiver == nullptr)
59     return ActorPtr();
60   return ActorPtr(&pimpl_->permanent_receiver->getIface());
61 }
62
63 }
64 }