Merge pull request #837 from arsenm/master

Fix cmake build and warnings
This commit is contained in:
Pieter Hintjens 2014-01-19 00:08:05 -08:00
commit cedca84196
12 changed files with 16 additions and 21 deletions

View File

@ -653,9 +653,6 @@ if(NOT WIN32)
if(NOT CMAKE_SYSTEM_NAME MATCHES "Linux") if(NOT CMAKE_SYSTEM_NAME MATCHES "Linux")
set_tests_properties(test_abstract_ipc PROPERTIES WILL_FAIL true) set_tests_properties(test_abstract_ipc PROPERTIES WILL_FAIL true)
endif() endif()
if(NOT ZMQ_HAVE_SO_PEERCRED AND NOT ZMQ_HAVE_LOCAL_PEERCRED)
set_tests_properties(test_zap_ipc_creds PROPERTIES WILL_FAIL true)
endif()
endif() endif()
#----------------------------------------------------------------------------- #-----------------------------------------------------------------------------

View File

@ -133,8 +133,8 @@ int zmq::mechanism_t::parse_metadata (const unsigned char *ptr_,
return 0; return 0;
} }
int zmq::mechanism_t::property (const std::string name_, int zmq::mechanism_t::property (const std::string /* name_ */,
const void *value_, size_t length_) const void * /* value_ */, size_t /* length_ */)
{ {
// Default implementation does not check // Default implementation does not check
// property values and returns 0 to signal success. // property values and returns 0 to signal success.

View File

@ -46,9 +46,9 @@ namespace zmq
// Process the handshake command received from the peer. // Process the handshake command received from the peer.
virtual int process_handshake_command (msg_t *msg_) = 0; virtual int process_handshake_command (msg_t *msg_) = 0;
virtual int encode (msg_t *msg_) { return 0; } virtual int encode (msg_t *) { return 0; }
virtual int decode (msg_t *msg_) { return 0; } virtual int decode (msg_t *) { return 0; }
// Notifies mechanism about availability of ZAP message. // Notifies mechanism about availability of ZAP message.
virtual int zap_msg_available () { return 0; } virtual int zap_msg_available () { return 0; }

View File

@ -166,9 +166,6 @@ int zmq::stream_t::xsend (msg_t *msg_)
int zmq::stream_t::xsetsockopt (int option_, const void *optval_, int zmq::stream_t::xsetsockopt (int option_, const void *optval_,
size_t optvallen_) size_t optvallen_)
{ {
bool is_int = (optvallen_ == sizeof (int));
int value = is_int? *((int *) optval_): 0;
switch (option_) { switch (option_) {
case ZMQ_NEXT_IDENTITY: case ZMQ_NEXT_IDENTITY:
if(optval_ && optvallen_) { if(optval_ && optvallen_) {
@ -268,7 +265,7 @@ void zmq::stream_t::identify_peer (pipe_t *pipe_)
next_identity.length()); next_identity.length());
next_identity.clear(); next_identity.clear();
} }
else { else {
put_uint32 (buffer + 1, next_peer_id++); put_uint32 (buffer + 1, next_peer_id++);
blob_t identity = blob_t (buffer, sizeof buffer); blob_t identity = blob_t (buffer, sizeof buffer);
memcpy (options.identity, identity.data (), identity.size ()); memcpy (options.identity, identity.data (), identity.size ());

View File

@ -182,7 +182,7 @@ void zmq::stream_engine_t::plug (io_thread_t *io_thread_,
// application so that it knows a peer has connected. // application so that it knows a peer has connected.
msg_t connector; msg_t connector;
connector.init(); connector.init();
int rc = (this->*write_msg) (&connector); (this->*write_msg) (&connector);
connector.close(); connector.close();
session->flush (); session->flush ();
} }

View File

@ -70,7 +70,7 @@ namespace zmq
#endif #endif
// There are no incomplete items for conflate ypipe // There are no incomplete items for conflate ypipe
inline bool unwrite (T *value_) inline bool unwrite (T *)
{ {
return false; return false;
} }

View File

@ -188,12 +188,13 @@ int zmq_curve_keypair (char *z85_public_key, char *z85_secret_key)
// Is there a sensible errno to set here? // Is there a sensible errno to set here?
if (rc) if (rc)
return rc; return rc;
zmq_z85_encode (z85_public_key, public_key, 32); zmq_z85_encode (z85_public_key, public_key, 32);
zmq_z85_encode (z85_secret_key, secret_key, 32); zmq_z85_encode (z85_secret_key, secret_key, 32);
return 0; return 0;
#else // requires libsodium #else // requires libsodium
(void) z85_public_key, (void) z85_secret_key;
errno = ENOTSUP; errno = ENOTSUP;
return -1; return -1;
#endif #endif

View File

@ -19,7 +19,7 @@
#include "testutil.hpp" #include "testutil.hpp"
int main (int argc, char *argv []) int main (int, char *[])
{ {
const char *bind_to = "tcp://127.0.0.1:5555"; const char *bind_to = "tcp://127.0.0.1:5555";

View File

@ -28,7 +28,7 @@ memcpy(zmq_msg_data(&msg), data, size + 1);
int publicationsReceived = 0; int publicationsReceived = 0;
bool isSubscribed = false; bool isSubscribed = false;
int main(int argc, char** argv) { int main(int, char**) {
setup_test_environment(); setup_test_environment();
void* context = zmq_ctx_new(); void* context = zmq_ctx_new();
void* pubSocket; void* pubSocket;

View File

@ -202,7 +202,7 @@ int test_inproc_connect_and_close_first (int send_hwm, int recv_hwm)
return send_count; return send_count;
} }
int test_inproc_bind_and_close_first (int send_hwm, int recv_hwm) int test_inproc_bind_and_close_first (int send_hwm, int /* recv_hwm */)
{ {
void *ctx = zmq_ctx_new (); void *ctx = zmq_ctx_new ();
assert (ctx); assert (ctx);

View File

@ -36,10 +36,10 @@ typedef struct {
// 8-byte size is set to 1 for backwards compatibility // 8-byte size is set to 1 for backwards compatibility
static zmtp_greeting_t greeting static zmtp_greeting_t greeting
= { { 0xFF, 0, 0, 0, 0, 0, 0, 0, 1, 0x7F }, { 3, 0 }, { 'N', 'U', 'L', 'L'} }; = { { 0xFF, 0, 0, 0, 0, 0, 0, 0, 1, 0x7F }, { 3, 0 }, { 'N', 'U', 'L', 'L'}, 0, { 0 } };
static void static void
test_stream_to_dealer (void) test_stream_to_dealer (void)
{ {
int rc; int rc;

View File

@ -52,7 +52,7 @@ bool get_identity (void* socket, char* data, size_t* size)
return rc == 0; return rc == 0;
} }
int main(int argc, char** argv) int main(int, char**)
{ {
setup_test_environment(); setup_test_environment();