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 |
|