X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Fpipe.cpp;h=309f51b0496aa406572ffdda5c66c3668dcf417c;hb=b54a57c7af29c89371aa65dc766adac9ed61f58c;hp=4b3dde1d3e6ab9001c719764479074e7c65126db;hpb=1cf9a9d0bc8a553f67994f845d2ee2ea4223879c;p=metaproxy-moved-to-github.git diff --git a/src/pipe.cpp b/src/pipe.cpp index 4b3dde1..309f51b 100644 --- a/src/pipe.cpp +++ b/src/pipe.cpp @@ -1,8 +1,21 @@ -/* $Id: pipe.cpp,v 1.11 2007-02-26 13:19:23 adam Exp $ - Copyright (c) 2005-2007, Index Data. +/* This file is part of Metaproxy. + Copyright (C) Index Data + +Metaproxy 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, or (at your option) any later +version. + +Metaproxy 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 General Public License +for more details. + +You should have received a copy of the GNU General Public License +along with this program; if not, write to the Free Software +Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA +*/ - See the LICENSE file for details - */ #include "config.hpp" #if HAVE_UNISTD_H @@ -34,6 +47,7 @@ #include #include +#include #include @@ -109,7 +123,7 @@ Pipe::Pipe(int port_to_use) : m_p(new Rep) throw Pipe::Error("could not create socket"); #ifndef WIN32 unsigned long one = 1; - if (setsockopt(m_p->m_socket, SOL_SOCKET, SO_REUSEADDR, (char*) + if (setsockopt(m_p->m_socket, SOL_SOCKET, SO_REUSEADDR, (char*) &one, sizeof(one)) < 0) throw Pipe::Error("setsockopt error"); #endif @@ -119,10 +133,10 @@ Pipe::Pipe(int port_to_use) : m_p(new Rep) add.sin_port = htons(port_to_use); add.sin_addr.s_addr = INADDR_ANY; struct sockaddr *addr = ( struct sockaddr *) &add; - + if (bind(m_p->m_socket, addr, sizeof(struct sockaddr_in))) throw Pipe::Error("could not bind on socket"); - + if (listen(m_p->m_socket, 3) < 0) throw Pipe::Error("could not listen on socket"); @@ -133,11 +147,11 @@ Pipe::Pipe(int port_to_use) : m_p(new Rep) memcpy(&add.sin_addr.s_addr, &tmpadd, sizeof(struct in_addr)); else throw Pipe::Error("inet_addr failed"); - + m_p->m_fd[1] = socket(AF_INET, SOCK_STREAM, 0); if (m_p->m_fd[1] < 0) throw Pipe::Error("could not create socket"); - + m_p->nonblock(m_p->m_fd[1]); if (connect(m_p->m_fd[1], addr, sizeof(*addr)) < 0) @@ -209,8 +223,8 @@ int &Pipe::write_fd() const /* * Local variables: * c-basic-offset: 4 + * c-file-style: "Stroustrup" * indent-tabs-mode: nil - * c-file-style: "stroustrup" * End: * vim: shiftwidth=4 tabstop=8 expandtab */