Lines Matching defs:sockfd
165 close_socket(int *sockfd)
167 if (*sockfd == INVALID_SOCKET)
170 close(*sockfd);
171 *sockfd = INVALID_SOCKET;
176 send_data(int sockfd, char *data, unsigned int len)
188 if (sockfd == INVALID_SOCKET)
191 FD_SET(sockfd, &WriteFDs);
195 if (select(sockfd+1, NULL, &WriteFDs, &ExceptFDs, &tv) > 0) {
196 if (!FD_ISSET(sockfd, &WriteFDs)) {
202 nret = send(sockfd, &(data[totalsent]), len, 0);
219 add_length_and_send_data(int sockfd, char *data, unsigned int len)
235 ret = send_data(sockfd, sdata, totlen);
244 recv_data(int sockfd, unsigned char *read_buf, uint32 size)
252 FD_SET(sockfd, &ReadFDs);
253 FD_SET(sockfd, &ExceptFDs);
258 if (select(sockfd+1, &ReadFDs, NULL, &ExceptFDs, &tv) > 0) {
259 if (!FD_ISSET(sockfd, &ReadFDs)) {
264 nbytes = read(sockfd, &(read_buf[totalread]), size);
284 on_receive(int sockfd, unsigned char **data)
290 sz = recv_data(sockfd, szbuff, VIS_LEN_FIELD_SZ);
309 sz = recv_data(sockfd, read_buf, (size-VIS_LEN_FIELD_SZ));
327 int res, valopt, sockfd;
335 sockfd = INVALID_SOCKET;
338 if ((sockfd = socket(PF_INET, SOCK_STREAM, 0)) == -1) {
349 if ((arg = fcntl(sockfd, F_GETFL, NULL)) < 0 ||
350 fcntl(sockfd, F_SETFL, arg | O_NONBLOCK) < 0) {
358 res = connect(sockfd, (struct sockaddr*)&server_addr, sizeof(server_addr));
365 FD_SET(sockfd, &readfds);
366 if (select(sockfd+1, NULL, &readfds, NULL, &tv) > 0) {
368 getsockopt(sockfd, SOL_SOCKET, SO_ERROR, (void*)(&valopt), &lon);
384 return sockfd;
387 close_socket(&sockfd);
395 int sockfd = INVALID_SOCKET;
398 sockfd = connect_to_server(VISUALIZATION_SERVER_PORT, VISUALIZATION_SERVER_ADDRESS);
399 if (sockfd != INVALID_SOCKET) {
400 ret = add_length_and_send_data(sockfd, xmldata, strlen(xmldata));
403 ret = on_receive(sockfd, &vis_rdata);
415 close_socket(&sockfd);