Update mechanism API so we can check for ERROR status

src/curve_client.cpp

@@ -206,9 +206,9 @@ int zmq::curve_client_t::decode (msg_t *msg_)
     return rc;
 }
 
-bool zmq::curve_client_t::is_handshake_complete () const
+zmq::mechanism_t::status_t zmq::curve_client_t::status () const
 {
-    return state == connected;
+    return state == connected? mechanism_t::ready: mechanism_t::handshaking;
 }
 
 int zmq::curve_client_t::produce_hello (msg_t *msg_)

src/curve_client.hpp

@@ -59,7 +59,7 @@ namespace zmq
         virtual int process_handshake_command (msg_t *msg_);
         virtual int encode (msg_t *msg_);
         virtual int decode (msg_t *msg_);
-        virtual bool is_handshake_complete () const;
+        virtual status_t status () const;
 
     private:
 

src/curve_server.cpp

@@ -237,9 +237,9 @@ int zmq::curve_server_t::zap_msg_available ()
     return rc;
 }
 
-bool zmq::curve_server_t::is_handshake_complete () const
+zmq::mechanism_t::status_t zmq::curve_server_t::status () const
 {
-    return state == connected;
+    return state == connected? mechanism_t::ready: mechanism_t::handshaking;
 }
 
 int zmq::curve_server_t::process_hello (msg_t *msg_)

src/curve_server.hpp

@@ -64,7 +64,7 @@ namespace zmq
         virtual int encode (msg_t *msg_);
         virtual int decode (msg_t *msg_);
         virtual int zap_msg_available ();
-        virtual bool is_handshake_complete () const;
+        virtual status_t status () const;
 
     private:
 

src/mechanism.hpp

@@ -37,6 +37,12 @@ namespace zmq
     {
     public:
 
+        enum status_t {
+            handshaking,
+            ready,
+            error
+        };
+
         mechanism_t (const options_t &options_);
 
         virtual ~mechanism_t ();
@@ -54,8 +60,8 @@ namespace zmq
         //  Notifies mechanism about availability of ZAP message.
         virtual int zap_msg_available () { return 0; }
 
-        //  True iff the handshake stage is complete?
+        //  Returns the status of this mechanism.
-        virtual bool is_handshake_complete () const = 0;
+        virtual status_t status () const = 0;
 
         void set_peer_identity (const void *id_ptr, size_t id_size);
 

src/null_mechanism.cpp

@@ -152,9 +152,12 @@ int zmq::null_mechanism_t::zap_msg_available ()
     return rc;
 }
 
-bool zmq::null_mechanism_t::is_handshake_complete () const
+zmq::mechanism_t::status_t zmq::null_mechanism_t::status () const
 {
-    return ready_command_received && ready_command_sent;
+    if (ready_command_received && ready_command_sent)
+        return mechanism_t::ready;
+    else
+        return mechanism_t::handshaking;
 }
 
 void zmq::null_mechanism_t::send_zap_request ()

src/null_mechanism.hpp

@@ -42,7 +42,7 @@ namespace zmq
         virtual int next_handshake_command (msg_t *msg_);
         virtual int process_handshake_command (msg_t *msg_);
         virtual int zap_msg_available ();
-        virtual bool is_handshake_complete () const;
+        virtual status_t status () const;
 
     private:
 

src/plain_mechanism.cpp

@@ -118,9 +118,9 @@ int zmq::plain_mechanism_t::process_handshake_command (msg_t *msg_)
     return rc;
 }
 
-bool zmq::plain_mechanism_t::is_handshake_complete () const
+zmq::mechanism_t::status_t zmq::plain_mechanism_t::status () const
 {
-    return state == ready;
+    return state == ready? mechanism_t::ready: mechanism_t::handshaking;
 }
 
 int zmq::plain_mechanism_t::zap_msg_available ()

src/plain_mechanism.hpp

@@ -42,7 +42,7 @@ namespace zmq
         virtual int next_handshake_command (msg_t *msg_);
         virtual int process_handshake_command (msg_t *msg_);
         virtual int zap_msg_available ();
-        virtual bool is_handshake_complete () const;
+        virtual status_t status () const;
 
     private:
 

src/stream_engine.cpp

@@ -670,17 +670,21 @@ int zmq::stream_engine_t::next_handshake_command (msg_t *msg_)
 {
     zmq_assert (mechanism != NULL);
 
-    const int rc = mechanism->next_handshake_command (msg_);
+    if (mechanism->status () == mechanism_t::ready) {
-    if (rc == 0) {
+        mechanism_ready ();
-        msg_->set_flags (msg_t::command);
+        return pull_and_encode (msg_);
-        if (mechanism->is_handshake_complete ())
+    }
-            mechanism_ready ();
+    else
+    if (mechanism->status () == mechanism_t::error) {
+        errno = EPROTO;
+        return -1;
+    }
+    else {
+        const int rc = mechanism->next_handshake_command (msg_);
+        if (rc == 0)
+            msg_->set_flags (msg_t::command);
+        return rc;
     }
-    //  TODO:
-    //  if (errno == EPROTO || errno == EACCES)
-    //      return ERROR command to client
-
-    return rc;
 }
 
 int zmq::stream_engine_t::process_handshake_command (msg_t *msg_)
@@ -688,14 +692,16 @@ int zmq::stream_engine_t::process_handshake_command (msg_t *msg_)
     zmq_assert (mechanism != NULL);
     const int rc = mechanism->process_handshake_command (msg_);
     if (rc == 0) {
-        if (mechanism->is_handshake_complete ())
+        if (mechanism->status () == mechanism_t::ready)
             mechanism_ready ();
+        else
+        if (mechanism->status () == mechanism_t::error) {
+            errno = EPROTO;
+            return -1;
+        }
         if (output_stopped)
             restart_output ();
     }
-    //  TODO:
-    //  if (errno == EPROTO || errno == EACCES)
-    //      return ERROR command to client
 
     return rc;
 }