Fixed issue with Buffer size in recv, fixed atomic include in threads, added an initializer to Parse in main.cpp

Author: dfurneau

Makefile

@@ -6,7 +6,7 @@
 #    By: dfurneau <dfurneau@student.42abudhabi.ae>  +#+  +:+       +#+         #
 #                                                 +#+#+#+#+#+   +#+            #
 #    Created: 2023/03/07 07:25:25 by dfurneau          #+#    #+#              #
-#    Updated: 2023/04/14 01:22:44 by dfurneau         ###   ########.fr        #
+#    Updated: 2023/04/15 00:52:29 by dfurneau         ###   ########.fr        #
 #                                                                              #
 # **************************************************************************** #
 
@@ -20,7 +20,7 @@ SSRCS		=	./src/main.cpp \
 SOBJS		=	${SSRCS:.cpp=.o}
 CXX			=	g++
 
-CXXFLAGS	=	-Wall -Wextra -Werror -std=c++2a
+CXXFLAGS	=	-Wall -Wextra -Werror -std=c++2a -Ofast
 
 LIBS		=	-pthread
 

includes/client-tester.hpp

@@ -6,13 +6,14 @@
 /*   By: dfurneau <dfurneau@student.42abudhabi.ae>  +#+  +:+       +#+        */
 /*                                                +#+#+#+#+#+   +#+           */
 /*   Created: 2023/03/14 10:12:49 by dfurneau          #+#    #+#             */
-/*   Updated: 2023/04/14 00:28:28 by dfurneau         ###   ########.fr       */
+/*   Updated: 2023/04/15 00:40:11 by dfurneau         ###   ########.fr       */
 /*                                                                            */
 /* ************************************************************************** */
 
 #ifndef CLIENT_TESTER_HPP
 # define CLIENT_TESTER_HPP
 
+# define BUFFSIZE 4095
 # include "parse.hpp"
 
 # include <cstring>

includes/thread.hpp

@@ -6,7 +6,7 @@
 /*   By: dfurneau <dfurneau@student.42abudhabi.ae>  +#+  +:+       +#+        */
 /*                                                +#+#+#+#+#+   +#+           */
 /*   Created: 2023/04/12 02:57:16 by dfurneau          #+#    #+#             */
-/*   Updated: 2023/04/14 00:24:52 by dfurneau         ###   ########.fr       */
+/*   Updated: 2023/04/15 00:47:12 by dfurneau         ###   ########.fr       */
 /*                                                                            */
 /* ************************************************************************** */
 
@@ -17,7 +17,10 @@
 # include "parse.hpp"
 
 # include <mutex>
+# include <atomic>
 # include <thread>
+# include <string>
+# include <iostream>
 # include <csignal>
 
 inline std::mutex mtx;

src/client-tester.cpp

@@ -6,7 +6,7 @@
 /*   By: dfurneau <dfurneau@student.42abudhabi.ae>  +#+  +:+       +#+        */
 /*                                                +#+#+#+#+#+   +#+           */
 /*   Created: 2023/03/14 10:12:40 by dfurneau          #+#    #+#             */
-/*   Updated: 2023/04/14 00:27:17 by dfurneau         ###   ########.fr       */
+/*   Updated: 2023/04/15 00:40:01 by dfurneau         ###   ########.fr       */
 /*                                                                            */
 /* ************************************************************************** */
 
@@ -157,10 +157,13 @@ void clientTester::ircconnect( void ) {
             std::this_thread::sleep_for( std::chrono::milliseconds( 1 ) );
     }
 
-    char buffer[1024];
+    char buffer[BUFFSIZE];
     ssize_t byteRec;
 
-    while ( ( byteRec = recv( m_fd, &buffer, std::strlen( buffer ), 0 ) ) <= 0) ;
+    while ( ( byteRec = recv( m_fd, &buffer, BUFFSIZE, 0 ) ) <= 0) {
+        if ( byteRec > 0 )
+            std::cout << buffer << std::endl;
+    }
 
     for ( std::vector<std::string>::const_iterator it = m_data->m_afterConnect.begin(); it != m_data->m_afterConnect.end(); ++it ) {
         ircsend( replaceBuffer( *it ) );

src/main.cpp

@@ -6,7 +6,7 @@
 /*   By: dfurneau <dfurneau@student.42abudhabi.ae>  +#+  +:+       +#+        */
 /*                                                +#+#+#+#+#+   +#+           */
 /*   Created: 2023/03/14 10:12:40 by dfurneau          #+#    #+#             */
-/*   Updated: 2023/04/14 00:39:19 by dfurneau         ###   ########.fr       */
+/*   Updated: 2023/04/15 00:51:59 by dfurneau         ###   ########.fr       */
 /*                                                                            */
 /* ************************************************************************** */
 
@@ -82,14 +82,15 @@ int main( int ac, char** av ) {
     if ( threadCount <= 0 || !isValidIp( ipAddress ) || ( port <= 0 || port >= 65535 ) )
         return usage( av[0] );
 
-    Parse* p;
+    Parse* p = nullptr;
     try {
         p = new Parse( "./conf/replace.conf", "./conf/connect.conf", "./conf/after-connect.conf", "./conf/disconnect.conf", "./conf/loop.conf" );
         p->init( );
     }
     catch ( std::runtime_error& ex ) {
         std::cout << "Conf files missing from ./conf directory" << std::endl;
-        delete p;
+        if ( p )
+            delete p;
         return EXIT_FAILURE;
     }