generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-11-10 08:08:33 +01:00
Code Issues Projects Releases Wiki Activity

Size of inproc hwm and swap is sum of peers' hwms and swaps

Browse Source 
The meat of the patch was contributed by Douglas Creager.
Martin Sustrik implemented storing peer options in inproc
endpoint repository.

Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
This commit is contained in:
Martin Sustrik
2011-01-10 13:53:30 +01:00
parent babdf48aac
commit bd0ba6e89a
6 changed files with 52 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/ctx.hpp
View File

@@ -34,9 +34,18 @@
#include "mutex.hpp"
#include "stdint.hpp"
#include "thread.hpp"
#include "options.hpp"
namespace zmq
{
// Information associated with inproc endpoint. Note that endpoint options
// are registered as well so that the peer can access them without a need
// for synchronisation, handshaking or similar.
struct endpoint_t
{
class socket_base_t *socket;
options_t options;
};
// Context object encapsulates all the global state associated with
// the library.
@@ -70,9 +79,9 @@ namespace zmq
class io_thread_t *choose_io_thread (uint64_t affinity_);
// Management of inproc endpoints.
int register_endpoint (const char *addr_, class socket_base_t *socket_);
int register_endpoint (const char *addr_, endpoint_t &endpoint_);
void unregister_endpoints (class socket_base_t *socket_);
class socket_base_t *find_endpoint (const char *addr_);
endpoint_t find_endpoint (const char *addr_);
// Logging.
void log (zmq_msg_t *msg_);
@@ -122,7 +131,7 @@ namespace zmq
mailbox_t **slots;
// List of inproc endpoints within this context.
typedef std::map <std::string, class socket_base_t*> endpoints_t;
typedef std::map <std::string, endpoint_t> endpoints_t;
endpoints_t endpoints;
// Synchronisation of access to the list of inproc endpoints.