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 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154
|
//////////////////////////////////////////////////////////////////////////////
//////////////////////////////////////////////////////////////////////////////
//
// copyright : (C) 2014 Eran Ifrah
// file name : clSocketServer.cpp
//
// -------------------------------------------------------------------------
// A
// _____ _ _ _ _
// / __ \ | | | | (_) |
// | / \/ ___ __| | ___| | _| |_ ___
// | | / _ \ / _ |/ _ \ | | | __/ _ )
// | \__/\ (_) | (_| | __/ |___| | || __/
// \____/\___/ \__,_|\___\_____/_|\__\___|
//
// F i l e
//
// This program is free software; you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation; either version 2 of the License, or
// (at your option) any later version.
//
//////////////////////////////////////////////////////////////////////////////
//////////////////////////////////////////////////////////////////////////////
#include "clConnectionString.h"
#include "clSocketServer.h"
#ifndef _WIN32
#include <arpa/inet.h>
#include <netinet/in.h>
#include <stdio.h>
#include <sys/socket.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <sys/un.h>
#include <unistd.h>
#endif
clSocketServer::clSocketServer() {}
clSocketServer::~clSocketServer() { DestroySocket(); }
int clSocketServer::CreateServer(const std::string& pipePath)
{
#ifndef __WXMSW__
unlink(pipePath.c_str());
// Create a socket
if((m_socket = ::socket(AF_UNIX, SOCK_STREAM, 0)) == INVALID_SOCKET) {
throw clSocketException("Could not create socket: " + error());
}
// must set reuse-address
int optval;
// set SO_REUSEADDR on a socket to true (1):
optval = 1;
::setsockopt(m_socket, SOL_SOCKET, SO_REUSEADDR, (const char*)&optval, sizeof(optval));
// Prepare the sockaddr_in structure
struct sockaddr_un server;
server.sun_family = AF_UNIX;
strcpy(server.sun_path, pipePath.c_str());
// Bind
if(::bind(m_socket, (struct sockaddr*)&server, sizeof(server)) == -1) {
throw clSocketException("CreateServer: bind operation failed: " + error());
}
char mode[] = "0777";
int newMode = ::strtol(mode, 0, 8);
::chmod(pipePath.c_str(), newMode);
// define the accept queue size
::listen(m_socket, 10);
return 0;
#else
int port = ::atoi(pipePath.c_str());
return CreateServer("127.0.0.1", port);
#endif
}
int clSocketServer::CreateServer(const std::string& address, int port)
{
// Create a socket
if((m_socket = ::socket(AF_INET, SOCK_STREAM, 0)) == INVALID_SOCKET) {
throw clSocketException("Could not create socket: " + error());
}
// must set reuse-address
int optval;
// set SO_REUSEADDR on a socket to true (1):
optval = 1;
::setsockopt(m_socket, SOL_SOCKET, SO_REUSEADDR, (const char*)&optval, sizeof(optval));
// Prepare the sockaddr_in structure
struct sockaddr_in server;
server.sin_family = AF_INET;
#ifdef __WXMSW__
server.sin_addr.s_addr = inet_addr(address.c_str());
#else
inet_pton(AF_INET, address.c_str(), &server.sin_addr);
#endif
server.sin_port = htons(port);
// Bind
if(::bind(m_socket, (struct sockaddr*)&server, sizeof(server)) != 0) {
throw clSocketException("CreateServer: bind() error: " + error());
}
if(port == 0) {
struct sockaddr_in socket_name;
#ifdef __WXMSW__
int name_len = sizeof(socket_name);
#else
socklen_t name_len = sizeof(socket_name);
#endif
if(::getsockname(m_socket, (struct sockaddr*)&socket_name, &name_len) != 0) {
throw clSocketException("CreateServer: getsockname() error: " + error());
}
port = ntohs(socket_name.sin_port);
}
// define the accept queue size
if(::listen(m_socket, 10) != 0) { throw clSocketException("CreateServer: listen() error: " + error()); }
// return the bound port number
return port;
}
int clSocketServer::Start(const wxString& connectionString)
{
clConnectionString cs(connectionString);
if(!cs.IsOK()) { throw clSocketException("Invalid connection string provided"); }
if(cs.GetProtocol() == clConnectionString::kTcp) {
return CreateServer(cs.GetHost().mb_str(wxConvUTF8).data(), cs.GetPort());
} else {
return CreateServer(cs.GetPath().mb_str(wxConvUTF8).data());
}
}
clSocketBase::Ptr_t clSocketServer::WaitForNewConnection(long timeout)
{
return clSocketBase::Ptr_t(WaitForNewConnectionRaw(timeout));
}
clSocketBase* clSocketServer::WaitForNewConnectionRaw(long timeout)
{
if(SelectRead(timeout) == kTimeout) { return NULL; }
int fd = ::accept(m_socket, 0, 0);
if(fd < 0) { throw clSocketException("accept error: " + error()); }
return new clSocketBase(fd);
}
|