344 |
|
while(1) { |
345 |
|
if(f != NULL) { |
346 |
|
char buffer[512]; |
347 |
+ |
int st; |
348 |
|
fread(buffer, size < 512 ? size : 512, 1, f); |
349 |
< |
if(tw_write(ssl, sock, buffer, size < 512 ? size : 512) < 0) return; |
349 |
> |
if((st = tw_write(ssl, sock, buffer, size < 512 ? size : 512)) <= 0) break; |
350 |
|
} else { |
351 |
< |
if(tw_write(ssl, sock, (unsigned char*)doc + incr, size < 512 ? size : 512) < 0) return; |
351 |
> |
if(tw_write(ssl, sock, (unsigned char*)doc + incr, size < 512 ? size : 512) <= 0) break; |
352 |
|
} |
353 |
|
incr += 512; |
354 |
|
if(size <= 512) break; |
1023 |
|
struct timeval tv; |
1024 |
|
#endif |
1025 |
|
#if defined(__MINGW32__) || defined(__HAIKU__) || defined(_MSC_VER) || defined(__BORLANDC__) || (defined(__WATCOMC__) && !defined(__NETWARE__) && !defined(__DOS__)) |
1026 |
< |
struct thread_entry threads[2048]; |
1026 |
> |
struct thread_entry threads[128]; |
1027 |
|
for(i = 0; i < sizeof(threads) / sizeof(threads[0]); i++) { |
1028 |
|
threads[i].used = false; |
1029 |
|
} |