1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
|
/*
+----------------------------------------------------------------------+
| Xdebug |
+----------------------------------------------------------------------+
| Copyright (c) 2002, 2003, 2004, 2005, 2006, 2007 Derick Rethans |
+----------------------------------------------------------------------+
| This source file is subject to version 1.0 of the Xdebug license, |
| that is bundled with this package in the file LICENSE, and is |
| available at through the world-wide-web at |
| http://xdebug.derickrethans.nl/license.php |
| If you did not receive a copy of the Xdebug license and are unable |
| to obtain it through the world-wide-web, please send a note to |
| xdebug@derickrethans.nl so we can mail you a copy immediately. |
+----------------------------------------------------------------------+
| Authors: Derick Rethans <derick@xdebug.org> |
+----------------------------------------------------------------------+
*/
#include <stdlib.h>
#include <string.h>
#ifndef WIN32
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#else
#include <winsock2.h>
#include <io.h>
#endif
#include "usefulstuff.h"
#define READ_BUFFER_SIZE 128
char* fd_read_line_delim(int socket, fd_buf *context, int type, unsigned char delim, int *length)
{
int size = 0, newl = 0, nbufsize = 0;
char *tmp;
char *tmp_buf = NULL;
char *ptr;
char buffer[READ_BUFFER_SIZE + 1];
if (!context->buffer) {
context->buffer = calloc(1,1);
context->buffer_size = 0;
}
while ((ptr = memchr(context->buffer, delim, context->buffer_size)) == NULL) {
ptr = context->buffer + context->buffer_size;
if (type == FD_RL_FILE) {
newl = read(socket, buffer, READ_BUFFER_SIZE);
} else {
newl = recv(socket, buffer, READ_BUFFER_SIZE, 0);
}
if (newl > 0) {
context->buffer = realloc(context->buffer, context->buffer_size + newl + 1);
memcpy(context->buffer + context->buffer_size, buffer, newl);
context->buffer_size += newl;
context->buffer[context->buffer_size] = '\0';
} else {
return NULL;
}
}
ptr = memchr(context->buffer, delim, context->buffer_size);
size = ptr - context->buffer;
/* Copy that line into tmp */
tmp = malloc(size + 1);
tmp[size] = '\0';
memcpy(tmp, context->buffer, size);
/* Rewrite existing buffer */
if ((nbufsize = context->buffer_size - size - 1) > 0) {
tmp_buf = malloc(nbufsize + 1);
memcpy(tmp_buf, ptr + 1, nbufsize);
tmp_buf[nbufsize] = 0;
}
free(context->buffer);
context->buffer = tmp_buf;
context->buffer_size = context->buffer_size - (size + 1);
/* Return normal line */
if (length) {
*length = size;
}
return tmp;
}
|
