Final Code 12/19/2015
Diff: TCPSocketConnection.cpp
- Revision:
- 0:b49935f48132
diff -r 000000000000 -r b49935f48132 TCPSocketConnection.cpp --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/TCPSocketConnection.cpp Sat Dec 19 21:57:34 2015 +0000 @@ -0,0 +1,95 @@ +/* + TCPSocketConnection.cpp + 2014 Copyright (c) Seeed Technology Inc. All right reserved. + + Author:lawliet zou(lawliet.zou@gmail.com) + 2014-2-24 + + This library is free software; you can redistribute it and/or + modify it under the terms of the GNU Lesser General Public + License as published by the Free Software Foundation; either + version 2.1 of the License, or (at your option) any later version. + + This library is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + Lesser General Public License for more details. + + You should have received a copy of the GNU Lesser General Public + License along with this library; if not, write to the Free Software + Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA +*/ + +#include "TCPSocketConnection.h" + +TCPSocketConnection::TCPSocketConnection() +{ +} + +int TCPSocketConnection::connect(const char* host, const int port) +{ + printf(">%s<",host); + if (_sock_fd < 0) { + _sock_fd = gprs->new_socket(); + if (_sock_fd < 0) { + return -1; + } + } + + if (!gprs->connect(_sock_fd, TCP, host, port)) { + return false; + } + return true; +} + +bool TCPSocketConnection::is_connected(void) +{ + return gprs->is_connected(_sock_fd); +} + +int TCPSocketConnection::send(char* data, int length) +{ + printf("Current Socket is %d \r\n", _sock_fd); + int size = gprs->wait_writeable(_sock_fd, length); + if (size < 0) { + return -1; + } + if (size > length) { + size = length; + } + return gprs->send(_sock_fd, data, size); +} + +int TCPSocketConnection::send_all(char* data, int length) +{ + return send(data,length); +} +void TCPSocketConnection::setSocket(int currentSocket) +{ + _sock_fd = currentSocket; +} +int TCPSocketConnection::receive(char* data, int length) +{ +#if 0 + if (size < 0) { + return -1; + } + if(size == 0) { + size = gprs->wait_readable(_sock_fd, DEFAULT_TIMEOUT); + } + + if(size > length) { + size = size - length; + } else { + length = size; + size = -1; + } +#endif + int size = gprs->wait_readable(_sock_fd, DEFAULT_TIMEOUT); + return gprs->recv(_sock_fd, data, size>length?length:size); +} + +int TCPSocketConnection::receive_all(char* data, int length) +{ + return receive(data,length); +}