24
|
1 #include <stdio.h>
|
|
2 #include <stdlib.h>
|
|
3 #include <string.h>
|
|
4 #include <sys/socket.h>
|
|
5 #include <unistd.h>
|
|
6 #include <signal.h>
|
|
7
|
28
|
8 #include "utils.h"
|
|
9 #include "socket.h"
|
|
10 #include "screen.h"
|
24
|
11
|
|
12 /* Desc: create socket connection
|
|
13 *
|
|
14 * In : servername, port
|
|
15 * Out : socket (or -1 on error)
|
|
16 *
|
|
17 * Note: -
|
|
18 */
|
|
19 int sk_conn(struct sockaddr *name)
|
|
20 {
|
|
21 int sock;
|
|
22
|
|
23 if ((sock = socket(PF_INET, SOCK_STREAM, 0)) < 0) {
|
|
24 perror("socket (socket.c:23)");
|
|
25 return -1;
|
|
26 }
|
|
27
|
|
28 if (connect(sock, (struct sockaddr *) name, sizeof(struct sockaddr)) < 0) {
|
|
29 perror("connect (socket.c:29)");
|
|
30 return -1;
|
|
31 }
|
|
32
|
|
33 return sock;
|
|
34 }
|
|
35
|
|
36
|
|
37 /* Desc: send data through socket
|
|
38 *
|
|
39 * In : socket, buffer to send
|
|
40 * Out : 0 = fail, 1 = pass
|
|
41 *
|
|
42 * Note: -
|
|
43 */
|
|
44 int sk_send(int sock, char *buffer)
|
|
45 {
|
|
46 //ut_WriteLog("Sending:%s\n", buffer);
|
|
47 if ((send(sock, buffer, strlen(buffer), 0)) == -1)
|
|
48 return 0;
|
|
49 else
|
|
50 return 1;
|
|
51 }
|
|
52
|
|
53 /* Desc: receive data through socket
|
|
54 *
|
|
55 * In : socket
|
|
56 * Out : received buffer
|
|
57 *
|
|
58 * Note: it is up to the caller to free the returned string
|
|
59 */
|
|
60 char *sk_recv(int sock)
|
|
61 {
|
|
62 int i = 1;
|
|
63 int tambuffer = 128;
|
|
64 char mtag[16]; // For tag name
|
|
65
|
26
|
66 char *buffer = calloc(1, tambuffer);
|
|
67 char *retval = calloc(1, tambuffer + 1);
|
24
|
68
|
|
69 while (1) {
|
|
70 char *p1;
|
|
71 int n = recv(sock, buffer, tambuffer, 0);
|
|
72 if (n == -1) {
|
|
73 // Error
|
|
74 free(buffer);
|
|
75 retval[0] = 0;
|
|
76 return retval;
|
|
77 }
|
|
78
|
|
79 if (i == 1) {
|
|
80 char *p2;
|
26
|
81 strncpy(retval, buffer, tambuffer);
|
24
|
82 p1 = retval+1;
|
|
83 p2 = mtag;
|
|
84 while (('a' <= *p1) && (*p1 <= 'z') && (p2-mtag < 14))
|
|
85 *p2++ = *p1++;
|
|
86 *p2++ = '>'; *p2++ = 0;
|
|
87 //fprintf(stderr, "TAG=\"%s\"\n", mtag);
|
|
88 } else {
|
26
|
89 char *old_retval = retval;
|
24
|
90 scr_LogPrint("Realloc %d [%d]", i-1, n);
|
|
91 if (!n)
|
|
92 break;
|
|
93 retval = realloc(retval, (tambuffer * i) + 1);
|
26
|
94 if (!retval) {
|
|
95 scr_LogPrint("Memory allocation failure!!");
|
|
96 ut_WriteLog("Memory allocation failure in sk_recv()\n", retval);
|
|
97 free(buffer);
|
|
98 return old_retval;
|
|
99 }
|
|
100 strncat(retval, buffer, tambuffer);
|
24
|
101 }
|
|
102 i++;
|
|
103 p1 = retval + strlen(retval) - strlen(mtag);
|
|
104 //fprintf(stderr, "buffer:[%s]\n", buffer);
|
|
105 //fprintf(stderr, "End RET=[%s]\n", p1);
|
|
106 if (!strcmp(p1, mtag))
|
|
107 break;
|
|
108 for (p1 = retval; *p1 && (*p1 != '>'); p1++);
|
|
109 if ((*p1 == '>') && (*(p1-1) == '/'))
|
|
110 break;
|
|
111 memset(buffer, 0, tambuffer);
|
|
112 }
|
|
113 free(buffer);
|
|
114 ut_WriteLog("Received:%s\n", retval);
|
|
115 return retval;
|
|
116 }
|