ZMQAddressUtils Class Reference

Summary of some address helpers. More...

#include <ZMQAddressUtils.h>

Static Public Member Functions
static std::string	randomSocketName (const std::string &hostname)
	Generate a random socket name in the form tcp://hostname:port.
static std::string	randomSocketName ()
	Generate a random socket name in the form ipc:///socketname.
static std::string	getSocketAddress (const std::string &socketAddress, ZMQAddressType socketPart)
	Create a full socket address for the given type from a random socket address, ba adding a suffix.

Detailed Description

Summary of some address helpers.

Definition at line 27 of file ZMQAddressUtils.h.

Member Function Documentation

getSocketAddress()

std::string getSocketAddress ( const std::string &  socketAddress, ZMQAddressType  socketPart  )

static

Create a full socket address for the given type from a random socket address, ba adding a suffix.

Definition at line 55 of file ZMQAddressUtils.cc.

{
  const std::string& prefix = "tcp://";
  if (socketAddress.compare(0, prefix.size(), prefix) == 0) {
    if (socketPart == ZMQAddressType::c_input) {
      return socketAddress + "0";
    } else if (socketPart == ZMQAddressType::c_output) {
      return socketAddress + "1";
    } else if (socketPart == ZMQAddressType::c_pub) {
      return socketAddress + "2";
    } else if (socketPart == ZMQAddressType::c_sub) {
      return socketAddress + "3";
    } else if (socketPart == ZMQAddressType::c_control) {
      return socketAddress + "4";
    }
  } else {
    if (socketPart == ZMQAddressType::c_input) {
      return socketAddress + "_input";
    } else if (socketPart == ZMQAddressType::c_output) {
      return socketAddress + "_output";
    } else if (socketPart == ZMQAddressType::c_pub) {
      return socketAddress + "_pub";
    } else if (socketPart == ZMQAddressType::c_sub) {
      return socketAddress + "_sub";
    } else if (socketPart == ZMQAddressType::c_control) {
      return socketAddress + "_control";
    }
  }
  return socketAddress;
}

randomSocketName() [1/2]

std::string randomSocketName ( )

static

Generate a random socket name in the form ipc:///socketname.

Definition at line 44 of file ZMQAddressUtils.cc.

{
  //  std::string socket_name = "ipc://basf2_socket_" + randomName() + ".socket";
  std::string socket_name = "ipc:///tmp/basf2_socket_" + randomName() + ".socket";
  while (std::ifstream(socket_name)) {
    socket_name = "ipc://basf2_socket_" + randomName() + ".socket";
  }
 
  return socket_name;
}

randomSocketName() [2/2]

std::string randomSocketName ( const std::string &  hostname )

static

Generate a random socket name in the form tcp://hostname:port.

Definition at line 38 of file ZMQAddressUtils.cc.

{
  std::string socket_name = "tcp://" + hostname + ":" + randomPort();
  return socket_name;
}

---

The documentation for this class was generated from the following files:

• framework/pcore/zmq/utils/include/ZMQAddressUtils.h
• framework/pcore/zmq/utils/src/ZMQAddressUtils.cc