Merge branch '0.9.2'

Author: robotconscience

libs/ofxLibwebsockets/include/ofxLibwebsockets/Client.h

@@ -65,7 +65,7 @@ namespace ofxLibwebsockets {
         }
 
         // send any binary data
-        void sendBinary( ofBuffer buffer );
+        void sendBinary( ofBuffer & buffer );
         void sendBinary( unsigned char * data, int size );
         void sendBinary( char * data, int size );
 
@@ -76,7 +76,6 @@ namespace ofxLibwebsockets {
             ofAddListener( clientProtocol.oncloseEvent, app, &T::onClose);
             ofAddListener( clientProtocol.onidleEvent, app, &T::onIdle);
             ofAddListener( clientProtocol.onmessageEvent, app, &T::onMessage);
-            ofAddListener( clientProtocol.onbroadcastEvent, app, &T::onBroadcast);
         }
 
         // get pointer to libwebsockets connection wrapper

libs/ofxLibwebsockets/include/ofxLibwebsockets/Connection.h

@@ -47,7 +47,7 @@ namespace ofxLibwebsockets {
             sendBinary( (char *) image.getPixels().getData(), size );
         }
 
-        void sendBinary( ofBuffer buffer );
+        void sendBinary( ofBuffer & buffer );
         void sendBinary( unsigned char * data, unsigned int size );
         void sendBinary( char * data, unsigned int size );
 

libs/ofxLibwebsockets/include/ofxLibwebsockets/Events.h

@@ -35,5 +35,4 @@ namespace ofxLibwebsockets {
  ofEvent<ofxLibwebsockets::Event> onClose;
  ofEvent<ofxLibwebsockets::Event> onIdle;
  ofEvent<ofxLibwebsockets::Event> onMessage;
- ofEvent<ofxLibwebsockets::Event> onBroadcast;
  };*/

libs/ofxLibwebsockets/include/ofxLibwebsockets/Protocol.h

@@ -33,8 +33,6 @@ namespace ofxLibwebsockets {
         virtual bool allowClient(const std::string name,
                                  const std::string ip) const;
 
-        void broadcast(const std::string& message);
-        
         unsigned int idx;
         unsigned int rx_buffer_size;
 
@@ -49,7 +47,6 @@ namespace ofxLibwebsockets {
         virtual void onerror    (Event& args);
         virtual void onidle     (Event& args);
         virtual void onmessage  (Event& args);
-        virtual void onbroadcast(Event& args);
 
         // internal events: called by Reactor
         ofEvent<Event> onconnectEvent;
@@ -58,7 +55,6 @@ namespace ofxLibwebsockets {
         ofEvent<Event> onerrorEvent;
         ofEvent<Event> onidleEvent;
         ofEvent<Event> onmessageEvent;
-        ofEvent<Event> onbroadcastEvent;
 
         bool defaultAllowPolicy;
         std::map<std::string, bool> allowRules;
@@ -74,7 +70,6 @@ namespace ofxLibwebsockets {
         void _onerror     (Event& args);
         void _onidle      (Event& args);
         void _onmessage   (Event& args);
-        void _onbroadcast (Event& args);
 
         bool _allowClient(const std::string name,
                           const std::string ip) const;

libs/ofxLibwebsockets/include/ofxLibwebsockets/Server.h

@@ -59,11 +59,7 @@ namespace ofxLibwebsockets {
         // close the server
         void close();
 
-        // broadcast a message to all connections
-        void broadcast( string message );
-        
-        // send to all connections 
-        // (sends normal message instead of broadcast)
+        // send to all connections
         void send( string message );
 
         // send anything that has pixels to all connections
@@ -81,7 +77,7 @@ namespace ofxLibwebsockets {
         }
 
         // send any binary data to all connections
-        void sendBinary( ofBuffer buffer );
+        void sendBinary( ofBuffer & buffer );
         void sendBinary( unsigned char * data, int size );
         void sendBinary( char * data, int size );
 
@@ -95,7 +91,6 @@ namespace ofxLibwebsockets {
             ofAddListener( serverProtocol.oncloseEvent, app, &T::onClose);
             ofAddListener( serverProtocol.onidleEvent, app, &T::onIdle);
             ofAddListener( serverProtocol.onmessageEvent, app, &T::onMessage);
-            ofAddListener( serverProtocol.onbroadcastEvent, app, &T::onBroadcast);
         }
 
         template<class T>
@@ -105,7 +100,6 @@ namespace ofxLibwebsockets {
             ofRemoveListener( serverProtocol.oncloseEvent, app, &T::onClose);
             ofRemoveListener( serverProtocol.onidleEvent, app, &T::onIdle);
             ofRemoveListener( serverProtocol.onmessageEvent, app, &T::onMessage);
-            ofRemoveListener( serverProtocol.onbroadcastEvent, app, &T::onBroadcast);
         }
 
         //getters

libs/ofxLibwebsockets/src/Client.cpp

@@ -226,7 +226,7 @@ namespace ofxLibwebsockets {
     }
 
     //--------------------------------------------------------------
-    void Client::sendBinary( ofBuffer buffer ){
+    void Client::sendBinary( ofBuffer & buffer ){
         if ( connection != NULL){
             connection->sendBinary(buffer);
         }

libs/ofxLibwebsockets/src/Connection.cpp

@@ -82,7 +82,7 @@ namespace ofxLibwebsockets {
     }
 
     //--------------------------------------------------------------
-    void Connection::sendBinary( ofBuffer buffer ){
+    void Connection::sendBinary( ofBuffer & buffer ){
         sendBinary(buffer.getData(), buffer.size());
     }
 

libs/ofxLibwebsockets/src/Protocol.cpp

@@ -20,7 +20,6 @@ namespace ofxLibwebsockets {
         ofAddListener(oncloseEvent,        this, &Protocol::_onclose);
         ofAddListener(onidleEvent,         this, &Protocol::_onidle);
         ofAddListener(onmessageEvent,      this, &Protocol::_onmessage);
-        ofAddListener(onbroadcastEvent,    this, &Protocol::_onbroadcast);
         ofAddListener(onerrorEvent,         this, &Protocol::_onerror);
         rx_buffer_size = OFX_LWS_MAX_BUFFER;
         idle = false;
@@ -33,7 +32,6 @@ namespace ofxLibwebsockets {
         ofRemoveListener(oncloseEvent,     this, &Protocol::_onclose);
         ofRemoveListener(onidleEvent,      this, &Protocol::_onidle);
         ofRemoveListener(onmessageEvent,   this, &Protocol::_onmessage);
-        ofRemoveListener(onbroadcastEvent, this, &Protocol::_onbroadcast);
         ofRemoveListener(onerrorEvent,         this, &Protocol::_onerror);
         rx_buffer_size = OFX_LWS_MAX_BUFFER;
         idle = false;
@@ -94,24 +92,4 @@ namespace ofxLibwebsockets {
     }
 
     void Protocol::onmessage(Event&args){}
-
-    //--------------------------------------------------------------
-    void Protocol::_onbroadcast(Event& args){ onbroadcast(args); }
-
-    void Protocol::onbroadcast(Event&args){ args.conn.send(args.message); }
-
-    //--------------------------------------------------------------
-    void Protocol::broadcast(const std::string& message){
-        std::string buf(LWS_SEND_BUFFER_PRE_PADDING+message.size()+LWS_SEND_BUFFER_POST_PADDING, 0);
-        unsigned char *p = (unsigned char*)&buf[LWS_SEND_BUFFER_PRE_PADDING];
-        
-        if (reactor != NULL)
-        {
-            memcpy(p, message.c_str(), message.size());
-            //int n = libwebsockets_broadcast(&reactor->lws_protocols[idx], p, message.size());
-            int n = libwebsocket_callback_on_writable_all_protocol(&reactor->lws_protocols[idx]);
-            if (n < 0)
-                fprintf(stderr, "ERROR writing to socket");
-        }
-    }
 }

libs/ofxLibwebsockets/src/Server.cpp

@@ -149,14 +149,6 @@ namespace ofxLibwebsockets {
         }
 		libwebsocket_context_destroy(context);
 	}
-
-    //--------------------------------------------------------------
-    void Server::broadcast( string message ){
-        // loop through all protocols and broadcast!
-        for (int i=0; i<protocols.size(); i++){
-            protocols[i].second->broadcast( message );
-        }
-    }
 
     //--------------------------------------------------------------
     void Server::send( string message ){
@@ -168,7 +160,7 @@ namespace ofxLibwebsockets {
     }
 
     //--------------------------------------------------------------
-    void Server::sendBinary( ofBuffer buffer ){
+    void Server::sendBinary( ofBuffer & buffer ){
         sendBinary(buffer.getData(), buffer.size());
     }