1 /***************************************************************************
2 * Copyright (C) 2007 by Prabakaran Thirumalai *
3 * praba_tuty@yahoo.com *
5 * This program is free software; you can redistribute it and/or modify *
6 * it under the terms of the GNU General Public License as published by *
7 * the Free Software Foundation; either version 2 of the License, or *
8 * (at your option) any later version. *
10 * This program is distributed in the hope that it will be useful, *
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of *
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
13 * GNU General Public License for more details. *
15 * You should have received a copy of the GNU General Public License *
16 * along with this program; if not, write to the *
17 * Free Software Foundation, Inc., *
18 * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. *
19 ***************************************************************************/
22 #include <SqlNetworkHandler.h>
24 DbRetVal
TCPServer::start()
29 printError(ErrBadArg
, "Set the port first before starting\n");
32 struct sockaddr_in my_addr
;
33 if ((sockfd
= socket(AF_INET
, SOCK_STREAM
, 0)) == -1) {
34 printError(ErrOS
, "Unable to create socket\n");
37 my_addr
.sin_family
= AF_INET
;
38 my_addr
.sin_port
= htons(port
);
39 my_addr
.sin_addr
.s_addr
= INADDR_ANY
;
40 memset(&(my_addr
.sin_zero
), '\0', 8);
41 if (bind(sockfd
, (struct sockaddr
*)&my_addr
,
42 sizeof(struct sockaddr
)) == -1) {
45 if (listen(sockfd
, 10) == -1) {
51 DbRetVal
TCPServer::stop()
57 DbRetVal
TCPServer::handleClient()
59 printf("PRABA::handling client \n");
61 socklen_t addressLen
= sizeof(struct sockaddr
);
62 clientfd
= accept(sockfd
, (struct sockaddr
*) &clientAddress
, &addressLen
);
71 int ret
= os::send(clientfd
, &response
, 4, 0);
74 printError(ErrOS
, "Unable to communicate to peer\n");
77 printf("sent connect ack packet to client\n");
79 struct timeval timeout
;
80 SqlNetworkHandler handler
;
84 FD_SET(clientfd
, &fdset
);
87 int ret
= os::select(clientfd
+1, &fdset
, 0, 0, &timeout
);
89 printf("something in fd\n");
90 int numbytes
= os::recv(clientfd
,&header
,sizeof(PacketHeader
),0);
93 printError(ErrOS
, "Error reading from socket\n");
96 printf("HEADER says packet type is %d\n", header
.packetType
);
97 if (header
.packetType
== NW_PKT_DISCONNECT
) exit(0);
98 char *buffer
= (char*) malloc(header
.packetLength
);
99 numbytes
= os::recv(clientfd
,buffer
,header
.packetLength
,0);
102 printError(ErrOS
, "Error reading from socket\n");
106 int response
= handler
.process(header
, buffer
);
107 numbytes
= os::send(clientfd
, &response
, 4, 0);
110 printError(ErrOS
, "Error writing to socket\n");
113 } else printf("Nothing in fd %d\n", ret
);
116 printError(ErrOS
, "Unable to fork new process");