Classes/NetWork/NetWorkTools.cpp

#include "NetWorkTools.h"
#include "../System/System.h"
#include "../System/SystemDefine.h"
#include "../String/String.h"
#include "../NetWork/MutexHandler.h"

//sigaction SIGPIPE SIG_IGN

NetWorkTools::NetWorkTools(){}
NetWorkTools::~NetWorkTools(){}


int NetWorkTools::sendData(int socket, char *buffer, int size)
{
        int forward=0;
        int packetSize=1024;

        while ( size != 0 )
        {
                size-=packetSize;

                if ( size < 0 )
                {
                                        packetSize+=size;
                    size=0;
                }
//MSG_DONTWAIT
//MSG_NOSIGNAL
                int nTemp = send(socket, buffer+forward, packetSize, MSG_NOSIGNAL);

                if (nTemp > 0)
                {
                        forward+=nTemp;
                }
                else if (nTemp == SOCKET_ERROR)
                {
                        return 0;
                }
                else
                {
                    // Client closed connection before we could reply to
                    // all the data it sent, so bomb out early.
//                      System::println("Peer unexpectedly dropped connection!");
                        return 2;
                }
        }

        return 1;
}

/*
int NetWorkTools::sendData(int socket, char *buffer, int size)
{


        int forward=0;

        String kalle="socketIn ";
        System::println(kalle + socket + "start socket send");

        pthread_mutex_t mut=MutexHandler::getMutex();
*/      
/*
        char *tempBuffer=(char*)malloc(size);

        for ( int i=0; i<size ; i++ )
        {
                tempBuffer[i]=buffer[i];
        }

        System::println("extraBuffer");
*/
        //=-1;
//      int packetSize=1;

//      while (size!=0)
//      {

//              if ( (forward+packetSize) > 0 && forward >= 0 && (forward+packetSize) <= tempSize )
//              {
/*                      System::println(forward);
                        System::println(packetSize);
                        System::println(tempSize);
*/                      


/*
                        int     nTemp = write(socket, buffer+forward, 1);


                        String arne="nTemp  : ";

                        System::println(arne + nTemp);
*/

//    pthread_mutex_lock(&mut);

/*      
        int error = 1;
        for ( int i=0; i<size ; i++ )
        {
                error = write(socket, &buffer[i], 1);
                if(error != 1) 
                {
                        System::println("abryt");
                        break;
                }
                else 
                {
                        System::println("ntemp");
                }
        }
*/
//    pthread_mutex_lock(&mut);
        

//                      String kalle="socketIn ";
//                      System::println(kalle + socket + "start socket send");

//      System::println(nTemp);

//                      pthread_mutex_unlock(&mut);
/*              }
                else
                {
                        String kalle="socketIn2 ";
                        System::println(kalle + socket);

                        return 1;
                }


*/
/*              if (nTemp==0)
                {
//                              String kalle2="socketIn ";
//                              System::println(kalle2 + socket + "end socket send");
                                System::println(3);

                                break;
//                              return 1;

                }
*/
/*              if (nTemp > 0) 
                {
                        forward+=1;
                        size-=1;
                }
                
                if (nTemp == -1) 
                {
//                      String kalle="socketIn4 ";
//                      System::println(kalle + socket);
                        System::println(2);
                        return;
//                      return 0;
                }

                if(nTemp != 1) {
                        System::println("avbryta loppen");
                        return ;
                }
*/
/*              
                if (nTemp == 0 )
                {
                    // Client closed connection before we could reply to
                    // all the data it sent, so bomb out early.
//                      System::println("Peer unexpectedly dropped connection!");

                        String kalle="socketIn5 ";
                        System::println(kalle + socket);

                        return 2;
                }

        }
*/
/*      System::println(1);

//      String kalle2="socketIn ";
//      System::println(kalle2 + socket + "end socket send");

        return 1;
}
*/

char *NetWorkTools::recieveHttpData(int socket)
{
        char *inBuffer=(char*)malloc(4097*sizeof(char));
        char *pointer=(char*)inBuffer;
        int nReadBytes=-1;
    int numberOf=0;
        bool statement=true;
        int howManyBytes=0;

        String kalle="RecieveStart ";
        System::println(kalle + socket);

        while (statement) 
        {
        nReadBytes = recv(socket, pointer, 4096, MSG_NOSIGNAL);

                howManyBytes+=nReadBytes;

                if (nReadBytes > 0 && howManyBytes < 4096) 
                {
                        for ( int i=0; i<nReadBytes ; i++ )
                        {
                                if( pointer[0] == 13 || pointer[0] == 10 )
                                {
                                        numberOf++;
                                
                                        if ( numberOf == 3 )
                                        {
                                                statement=false;
                                                i=nReadBytes;
                                                pointer[0]=0;
                                        }
                                }
                                else
                                {
                                        numberOf=0;
                                }
                        
                                pointer++;
                        }
                }
                else if (nReadBytes == SOCKET_ERROR) 
                {
                        String kalle="socketRec1 ";
                        System::println(kalle + socket);
                        free(inBuffer);
                        return 0;
                }               
                else
                {
                        String kalle="socketRec2 ";
                        System::println(kalle + socket);
                        free(inBuffer);
                        return 0;
                }
        }

        String kalle2="RecieveEnd ";
        System::println(kalle2 + socket);
        System::println(howManyBytes);

    return inBuffer;
}


1	#include "NetWorkTools.h"
2	#include "../System/System.h"
3	#include "../System/SystemDefine.h"
4	#include "../String/String.h"
5	#include "../NetWork/MutexHandler.h"
6
7	//sigaction SIGPIPE SIG_IGN
8
9	NetWorkTools::NetWorkTools(){}
10	NetWorkTools::~NetWorkTools(){}
11
12
13	int NetWorkTools::sendData(int socket, char *buffer, int size)
14	{
15	int forward=0;
16	int packetSize=1024;
17
18	while ( size != 0 )
19	{
20	size-=packetSize;
21
22	if ( size < 0 )
23	{
24	packetSize+=size;
25	size=0;
26	}
27	//MSG_DONTWAIT
28	//MSG_NOSIGNAL
29	int nTemp = send(socket, buffer+forward, packetSize, MSG_NOSIGNAL);
30
31	if (nTemp > 0)
32	{
33	forward+=nTemp;
34	}
35	else if (nTemp == SOCKET_ERROR)
36	{
37	return 0;
38	}
39	else
40	{
41	// Client closed connection before we could reply to
42	// all the data it sent, so bomb out early.
43	// System::println("Peer unexpectedly dropped connection!");
44	return 2;
45	}
46	}
47
48	return 1;
49	}
50
51	/*
52	int NetWorkTools::sendData(int socket, char *buffer, int size)
53	{
54
55
56	int forward=0;
57
58	String kalle="socketIn ";
59	System::println(kalle + socket + "start socket send");
60
61	pthread_mutex_t mut=MutexHandler::getMutex();
62	*/
63	/*
64	char tempBuffer=(char)malloc(size);
65
66	for ( int i=0; i<size ; i++ )
67	{
68	tempBuffer[i]=buffer[i];
69	}
70
71	System::println("extraBuffer");
72	*/
73	//=-1;
74	// int packetSize=1;
75
76	// while (size!=0)
77	// {
78
79	// if ( (forward+packetSize) > 0 && forward >= 0 && (forward+packetSize) <= tempSize )
80	// {
81	/* System::println(forward);
82	System::println(packetSize);
83	System::println(tempSize);
84	*/
85
86
87	/*
88	int nTemp = write(socket, buffer+forward, 1);
89
90
91	String arne="nTemp : ";
92
93	System::println(arne + nTemp);
94	*/
95
96	// pthread_mutex_lock(&mut);
97
98	/*
99	int error = 1;
100	for ( int i=0; i<size ; i++ )
101	{
102	error = write(socket, &buffer[i], 1);
103	if(error != 1)
104	{
105	System::println("abryt");
106	break;
107	}
108	else
109	{
110	System::println("ntemp");
111	}
112	}
113	*/
114	// pthread_mutex_lock(&mut);
115
116
117	// String kalle="socketIn ";
118	// System::println(kalle + socket + "start socket send");
119
120	// System::println(nTemp);
121
122	// pthread_mutex_unlock(&mut);
123	/* }
124	else
125	{
126	String kalle="socketIn2 ";
127	System::println(kalle + socket);
128
129	return 1;
130	}
131
132
133	*/
134	/* if (nTemp==0)
135	{
136	// String kalle2="socketIn ";
137	// System::println(kalle2 + socket + "end socket send");
138	System::println(3);
139
140	break;
141	// return 1;
142
143	}
144	*/
145	/* if (nTemp > 0)
146	{
147	forward+=1;
148	size-=1;
149	}
150
151	if (nTemp == -1)
152	{
153	// String kalle="socketIn4 ";
154	// System::println(kalle + socket);
155	System::println(2);
156	return;
157	// return 0;
158	}
159
160	if(nTemp != 1) {
161	System::println("avbryta loppen");
162	return ;
163	}
164	*/
165	/*
166	if (nTemp == 0 )
167	{
168	// Client closed connection before we could reply to
169	// all the data it sent, so bomb out early.
170	// System::println("Peer unexpectedly dropped connection!");
171
172	String kalle="socketIn5 ";
173	System::println(kalle + socket);
174
175	return 2;
176	}
177
178	}
179	*/
180	/* System::println(1);
181
182	// String kalle2="socketIn ";
183	// System::println(kalle2 + socket + "end socket send");
184
185	return 1;
186	}
187	*/
188
189	char *NetWorkTools::recieveHttpData(int socket)
190	{
191	char inBuffer=(char)malloc(4097*sizeof(char));
192	char pointer=(char)inBuffer;
193	int nReadBytes=-1;
194	int numberOf=0;
195	bool statement=true;
196	int howManyBytes=0;
197
198	String kalle="RecieveStart ";
199	System::println(kalle + socket);
200
201	while (statement)
202	{
203	nReadBytes = recv(socket, pointer, 4096, MSG_NOSIGNAL);
204
205	howManyBytes+=nReadBytes;
206
207	if (nReadBytes > 0 && howManyBytes < 4096)
208	{
209	for ( int i=0; i<nReadBytes ; i++ )
210	{
211	if( pointer[0] == 13 \|\| pointer[0] == 10 )
212	{
213	numberOf++;
214
215	if ( numberOf == 3 )
216	{
217	statement=false;
218	i=nReadBytes;
219	pointer[0]=0;
220	}
221	}
222	else
223	{
224	numberOf=0;
225	}
226
227	pointer++;
228	}
229	}
230	else if (nReadBytes == SOCKET_ERROR)
231	{
232	String kalle="socketRec1 ";
233	System::println(kalle + socket);
234	free(inBuffer);
235	return 0;
236	}
237	else
238	{
239	String kalle="socketRec2 ";
240	System::println(kalle + socket);
241	free(inBuffer);
242	return 0;
243	}
244	}
245
246	String kalle2="RecieveEnd ";
247	System::println(kalle2 + socket);
248	System::println(howManyBytes);
249
250	return inBuffer;
251	}
252
253