* \brief find the env value. * User-defined env vars first. If not found, check system's environment * \param k the environment key * \retur

\brief get debug string */

@brief release the memory */

* \brief Waits until a push or pull has been finished * * Sample usage: * \code * int ts = w.Pull(keys, &vals); * Wait(ts); *

* \brief Pushes a list of key-value pairs to all server nodes. * * This function pushes a KV list specified by \a keys and \a vals to all * s

* @brief Resizes the array to size elements * * If size <= capacity_, then only change the size. otherwise, append size - * current_size entr

* \brief start the system * * This function will block until every nodes are started. * \param argv0 the program name, used for logging */

* \brief return the globally unique application id */

* \brief terminate the system * * All nodes should call this function before existing. * \param do_barrier whether to block until every node is fi

\brief get short debug string */

* \brief wait until pop an element from the beginning, threadsafe * \param value the poped value */

* \brief return the locally unique customer id */

\brief return true is empty */

\brief Returns the number of server nodes */

* @brief Slice a segment, zero-copy * * @param begin the start index segment * @param end the end index segment * @return the segment [beg

\brief get the van */

Take a buffer of ``size'' from the pool. If there is not enough remaining space in existing memory regions, allocate and register a new memory region.

Return the buffer pointed by ``addr'' into the pool

\brief Returns true if this node is a server node. */

\brief Returns true if this node is a worker node */

\brief Returns the rank of this node in its group * * Each worker will have a unique rank within [0, NumWorkers()). So are * servers. This function

* \brief Pulls the values associated with the keys from the server nodes * * This function pulls the values of the keys specified in \a keys fro

* \brief Register a callback to the system which is called after Finalize() * * The following codes are equal * \code {cpp} * RegisterExitCallback

* \brief update the heartbeat record map * \param node_id the \ref Node id * \param t the last received heartbeat time */

Print summary of certain result map.

\brief Returns true if this node is a worker node */

\brief Returns the number of worker nodes */

* \brief Pushes and Pulls a list of key-value pairs to and from the server * nodes. * * This function pushes the values of the keys specified

get the mpirun command for setting the envornment support both openmpi and mpich2

\brief Returns true if this node is a scheduler node. */

Process a file.

\brief Returns the verbose level. */

* \brief accept a received message from \ref Van. threadsafe * \param recved the received the message */

* \brief add an incomming message * \brief return true if msg has been added before or a ACK message */

* \brief add an outgoining message * */

* \brief return the IP address and Interface the first interface which is not * loopback * * only support IPv4 */

* \brief return an available port on local machine * * only support IPv4 * \return 0 on failure */

* \brief return the IP address for given interface eth0, eth1, ... */

* \brief get next available timestamp. thread safe */

* \brief whether it is ready for sending. thread safe */

\brief Returns true if this node is a scheduler node. */

* \brief push an value into the end. threadsafe. * \param new_value the value */

* \brief Register a callback to the system which is called after Finalize() * * The following codes are equal * \code {cpp} * RegisterExit

* \brief convert from a server rank into a node id * \param rank the server rank */