summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authormalosek <malosek@fastmq.com>2009-09-11 11:21:40 +0200
committermalosek <malosek@fastmq.com>2009-09-11 11:21:40 +0200
commita91b44977201e4b3891c70da0472a332f60a39fc (patch)
tree6674e98d74a16becfd8c8998b28e0d4930676eff /src
parent88695aaee607e6f4db1f4fd052e2596653fb18b2 (diff)
Revert "link libzmq with glib when congifured --with-pgm"
This reverts commit 88695aaee607e6f4db1f4fd052e2596653fb18b2.
Diffstat (limited to 'src')
-rw-r--r--src/Makefile.am6
-rw-r--r--src/config.hpp4
-rw-r--r--src/options.cpp4
-rw-r--r--src/options.hpp6
-rw-r--r--src/socket_base.cpp74
5 files changed, 15 insertions, 79 deletions
diff --git a/src/Makefile.am b/src/Makefile.am
index f4f338e..68b34fa 100644
--- a/src/Makefile.am
+++ b/src/Makefile.am
@@ -62,8 +62,6 @@ libzmq_la_SOURCES = $(pgm_sources) \
object.hpp \
options.hpp \
owned.hpp \
- pgm_sender.hpp \
- pgm_socket.hpp \
pipe.hpp \
platform.hpp \
poll.hpp \
@@ -103,8 +101,6 @@ libzmq_la_SOURCES = $(pgm_sources) \
object.cpp \
options.cpp \
owned.cpp \
- pgm_sender.cpp \
- pgm_socket.cpp \
pipe.cpp \
poll.cpp \
select.cpp \
@@ -126,7 +122,7 @@ libzmq_la_SOURCES = $(pgm_sources) \
zmq_listener.cpp \
zmq_listener_init.cpp
-libzmq_la_LDFLAGS = -version-info @LTVER@ @LIBZMQ_EXTRA_LDFLAFS@
+libzmq_la_LDFLAGS = -version-info @LTVER@
if BUILD_PGM
libzmq_la_CXXFLAGS = -I$(top_srcdir)/foreign/openpgm/@pgm_basename@/openpgm/pgm/include/ -Wall @LIBZMQ_EXTRA_CXXFLAGS@
diff --git a/src/config.hpp b/src/config.hpp
index 43a4513..17e67b9 100644
--- a/src/config.hpp
+++ b/src/config.hpp
@@ -70,10 +70,8 @@ namespace zmq
// Maximal number of non-accepted connections that can be held by
// TCP listener object.
- tcp_connection_backlog = 10,
+ tcp_connection_backlog = 10
- // Maximum transport data unit size for PGM (TPDU).
- pgm_max_tpdu = 1500
};
}
diff --git a/src/options.cpp b/src/options.cpp
index 804cb4f..cd07c44 100644
--- a/src/options.cpp
+++ b/src/options.cpp
@@ -24,8 +24,6 @@ zmq::options_t::options_t () :
lwm (0),
swap (0),
mask (0),
- affinity (0),
- rate (0),
- recovery_ivl (0)
+ affinity (0)
{
}
diff --git a/src/options.hpp b/src/options.hpp
index 9f4a264..faf21b8 100644
--- a/src/options.hpp
+++ b/src/options.hpp
@@ -37,12 +37,6 @@ namespace zmq
uint64_t mask;
uint64_t affinity;
std::string identity;
-
- // Maximum tranfer rate [kb/s].
- uint32_t rate;
-
- // Reliability time interval [s].
- uint32_t recovery_ivl;
};
}
diff --git a/src/socket_base.cpp b/src/socket_base.cpp
index 2384d80..a26c280 100644
--- a/src/socket_base.cpp
+++ b/src/socket_base.cpp
@@ -17,8 +17,6 @@
along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
-#include <iostream>
-
#include <string>
#include <algorithm>
@@ -37,7 +35,6 @@
#include "uuid.hpp"
#include "pipe.hpp"
#include "err.hpp"
-#include "platform.hpp"
zmq::socket_base_t::socket_base_t (app_thread_t *parent_) :
object_t (parent_),
@@ -148,22 +145,6 @@ int zmq::socket_base_t::setsockopt (int option_, const void *optval_,
errno = ENOTSUP;
return -1;
- case ZMQ_RATE:
- if (optvallen_ != sizeof (uint32_t)) {
- errno = EINVAL;
- return -1;
- }
- options.rate = *((int32_t*) optval_);
- return 0;
-
- case ZMQ_RECOVERY_IVL:
- if (optvallen_ != sizeof (uint32_t)) {
- errno = EINVAL;
- return -1;
- }
- options.recovery_ivl = *((int32_t*) optval_);
- return 0;
-
default:
errno = EINVAL;
return -1;
@@ -189,21 +170,6 @@ int zmq::socket_base_t::connect (const char *addr_)
std::string session_name ("#");
session_name += uuid_t ().to_string ();
- // Parse addr_ string.
- std::string addr_type;
- std::string addr_args;
-
- std::string addr (addr_);
- std::string::size_type pos = addr.find ("://");
-
- if (pos == std::string::npos) {
- errno = EINVAL;
- return -1;
- }
-
- addr_type = addr.substr (0, pos);
- addr_args = addr.substr (pos + 3);
-
// Create the session.
io_thread_t *io_thread = choose_io_thread (options.affinity);
session_t *session = new session_t (io_thread, this, session_name.c_str (),
@@ -232,36 +198,20 @@ int zmq::socket_base_t::connect (const char *addr_)
send_plug (session);
send_own (this, session);
- if (addr_type == "tcp") {
-
- // Create the connecter object. Supply it with the session name so that
- // it can bind the new connection to the session once it is established.
- zmq_connecter_t *connecter = new zmq_connecter_t (
- choose_io_thread (options.affinity), this, options,
- session_name.c_str ());
- int rc = connecter->set_address (addr_args.c_str ());
- if (rc != 0) {
- delete connecter;
- return -1;
- }
- send_plug (connecter);
- send_own (this, connecter);
-
- return 0;
- }
-
-#if defined ZMQ_HAVE_OPENPGM
- if (addr_type == "pgm") {
-
- zmq_assert (false);
-
- return 0;
+ // Create the connecter object. Supply it with the session name so that
+ // it can bind the new connection to the session once it is established.
+ zmq_connecter_t *connecter = new zmq_connecter_t (
+ choose_io_thread (options.affinity), this, options,
+ session_name.c_str ());
+ int rc = connecter->set_address (addr_);
+ if (rc != 0) {
+ delete connecter;
+ return -1;
}
-#endif
+ send_plug (connecter);
+ send_own (this, connecter);
- // Unknown address type.
- errno = ENOTSUP;
- return -1;
+ return 0;
}
int zmq::socket_base_t::send (::zmq_msg_t *msg_, int flags_)