tcp: Connection no longer setup default callbacks, but check if there is before calling

Author: AndreasAakesson

api/net/tcp/connection.hpp

@@ -665,19 +665,19 @@ class Connection : public std::enable_shared_from_this<Connection> {
     Invoke/signal the diffrent TCP events.
   */
   void signal_connect()
-  { on_connect_(shared_from_this()); }
+  { if(on_connect_) on_connect_(shared_from_this()); }
 
   void signal_disconnect(Disconnect::Reason&& reason)
   { on_disconnect_(shared_from_this(), Disconnect{reason}); }
 
   void signal_error(TCPException error)
-  { on_error_(std::forward<TCPException>(error)); }
+  { if(on_error_) on_error_(std::forward<TCPException>(error)); }
 
   void signal_packet_dropped(const Packet& packet, const std::string& reason)
-  { on_packet_dropped_(packet, reason); }
+  { if(on_packet_dropped_) on_packet_dropped_(packet, reason); }
 
   void signal_rtx_timeout()
-  { on_rtx_timeout_(rtx_attempt_+1, rttm.RTO); }
+  { if(on_rtx_timeout_) on_rtx_timeout_(rtx_attempt_+1, rttm.RTO); }
 
   /*
     Drop a packet. Used for debug/callback.

src/net/tcp/connection.cpp

@@ -41,13 +41,13 @@ Connection::Connection(TCP& host, port_t local_port, Socket remote) :
   cb(),
   read_request(),
   writeq(),
+  on_disconnect_({this, &Connection::default_on_disconnect}),
   bytes_rx_(0), bytes_tx_(0),
   queued_(false),
   rtx_timer({this, &Connection::rtx_timeout}),
   timewait_timer({this, &Connection::timewait_timeout})
 {
   setup_congestion_control();
-  setup_default_callbacks();
   debug("<Connection> %s created\n", to_string().c_str());
 }
 
@@ -816,7 +816,7 @@ void Connection::signal_close() {
   debug("<Connection::signal_close> It's time to delete this connection. \n");
 
   // call user callback
-  on_close_();
+  if(on_close_) on_close_();
 
   // clean up all copies, delegates and timers
   clean_up();
@@ -833,7 +833,7 @@ void Connection::clean_up() {
   auto shared = shared_from_this();
   // clean up all other copies
   // either in TCP::listeners_ (open) or Listener::syn_queue_ (half-open)
-  _on_cleanup_(shared);
+  if(_on_cleanup_) _on_cleanup_(shared);
 
   on_connect_.reset();
   on_disconnect_.reset(),