pegasus/src/Pegasus/Common/HTTPAcceptor.cpp - diff

Return to HTTPAcceptor.cpp CVS log

Up to [Pegasus] / pegasus / src / Pegasus / Common

Diff for /pegasus/src/Pegasus/Common/HTTPAcceptor.cpp between version 1.49.2.1 and 1.88.6.1

version 1.49.2.1, 2004/07/26 18:09:08

version 1.88.6.1, 2006/11/03 05:04:20

Line 1

//%2003////////////////////////////////////////////////////////////////////////

//%2006////////////////////////////////////////////////////////////////////////

// Company, L. P., IBM Corp., The Open Group, Tivoli Systems.

// Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.

// IBM Corp.; EMC Corporation, The Open Group.

// IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.

// EMC Corporation; VERITAS Software Corporation; The Open Group.

// EMC Corporation; Symantec Corporation; The Open Group.

// Permission is hereby granted, free of charge, to any person obtaining a copy

// of this software and associated documentation files (the "Software"), to

Line 23

Line 29

//==============================================================================

// Author: Mike Brasher (mbrasher@bmc.com)

// Modified By:

// Jenny Yu, Hewlett-Packard Company (jenny_yu@hp.com)

// Nag Boranna, Hewlett-Packard Company (nagaraja_boranna@hp.com)

// Dave Rosckes (rosckes@us.ibm.com)

// Denise Eckstein (denise.eckstein@hp.com)

//%/////////////////////////////////////////////////////////////////////////////

#include "Config.h"

#include "Constants.h"

#include <iostream>

#include "Socket.h"

#ifdef PEGASUS_PLATFORM_WIN32_IX86_MSVC

#include <windows.h>

#else

# include <cctype>

# include <cstdlib>

# include <errno.h>

# include <fcntl.h>

# include <netdb.h>

# include <netinet/in.h>

# include <arpa/inet.h>

# include <sys/socket.h>

# ifdef PEGASUS_LOCAL_DOMAIN_SOCKET

# include <unistd.h>

# include <sys/un.h>

# endif

#endif

#include "Network.h"

#include "Socket.h"

#include "TLS.h"

#include "HTTPAcceptor.h"

Line 63

Line 44

#include <Pegasus/Common/MessageLoader.h> //l10n

#ifdef PEGASUS_PLATFORM_OS400_ISERIES_IBM

#include "OS400ConvertChar.h"

#include "EBCDIC_OS400.h"

#endif

PEGASUS_USING_STD;

PEGASUS_NAMESPACE_BEGIN

static int MAX_CONNECTION_QUEUE_LENGTH = -1;

////////////////////////////////////////////////////////////////////////////////

Line 86

Line 68

{

if (local)

{

#ifdef PEGASUS_LOCAL_DOMAIN_SOCKET

#ifndef PEGASUS_OS_TYPE_WINDOWS

#ifndef PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET

address = reinterpret_cast<struct sockaddr*>(new struct sockaddr_un);

address_size = sizeof(struct sockaddr_un);

#else

PEGASUS_ASSERT(false);

#endif

}

else

{

Line 99

Line 84

address_size = sizeof(struct sockaddr_in);

}

~HTTPAcceptorRep()

{

delete address;

}

struct sockaddr* address;

#if defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)

SocketLength address_size;

size_t address_size;

#elif defined(PEGASUS_PLATFORM_AIX_RS_IBMCXX) || defined(PEGASUS_PLATFORM_LINUX_GENERIC_GNU) || (defined(PEGASUS_PLATFORM_SOLARIS_SPARC_CC) && !defined(SUNOS_5_6))

socklen_t address_size;

#else

int address_size;

#endif

Mutex _connection_mut;

Sint32 socket;

SocketHandle socket;

// Added for NamedPipe implementation for windows

#if defined PEGASUS_OS_TYPE_WINDOWS && !defined(PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET)

NamedPipeServer* namedPipeServer;

#endif

Array<HTTPConnection*> connections;

};

////////////////////////////////////////////////////////////////////////////////

// HTTPAcceptor

Line 126

Line 114

Boolean localConnection,

Uint32 portNumber,

SSLContext * sslcontext,

Boolean exportConnection)

ReadWriteSem* sslContextObjectLock)

: Base(PEGASUS_QUEUENAME_HTTPACCEPTOR), // ATTN: Need unique names?

_monitor(monitor),

_outputMessageQueue(outputMessageQueue),

Line 135

Line 123

_localConnection(localConnection),

_portNumber(portNumber),

_sslcontext(sslcontext),

_exportConnection(exportConnection)

_sslContextObjectLock(sslContextObjectLock)

{

Socket::initializeInterface();

Line 177

Line 165

HTTPAcceptor::~HTTPAcceptor()

{

destroyConnections();

unbind();

// ATTN: Is this correct in a multi-HTTPAcceptor server?

Socket::uninitializeInterface();

Line 187

Line 176

if (! message)

return;

PEGASUS_ASSERT(_rep != 0);

switch (message->getType())

{

case SOCKET_MESSAGE:

Line 196

Line 186

// If this is a connection request:

if (socketMessage->socket == _rep->socket &&

socketMessage->events | SocketMessage::READ)

socketMessage->events & SocketMessage::READ)

{

_acceptConnection();

}

Line 210

Line 200

break;

}

// Added for NamedPipe implementation for windows

#if defined PEGASUS_OS_TYPE_WINDOWS && !defined(PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET)

case NAMEDPIPE_MESSAGE:

{

NamedPipeMessage* namedPipeMessage = (NamedPipeMessage*)message;

if (((namedPipeMessage->namedPipe.getPipe()) == ( _rep->namedPipeServer->getPipe())) &&

(namedPipeMessage->events & NamedPipeMessage::READ))

{

_acceptNamedPipeConnection();

}

else

{

// ATTN! this can't happen!

Tracer::trace(TRC_DISCARDED_DATA, Tracer::LEVEL2,

"HTTPAcceptor::handleEnqueue: Invalid NAMEDPIPE_MESSAGE received.");

}

break;

}

#endif

case CLOSE_CONNECTION_MESSAGE:

{

CloseConnectionMessage* closeConnectionMessage

= (CloseConnectionMessage*)message;

_rep->_connection_mut.lock(pegasus_thread_self());

AutoMutex autoMut(_rep->_connection_mut);

for (Uint32 i = 0, n = _rep->connections.size(); i < n; i++)

{

HTTPConnection* connection = _rep->connections[i];

Sint32 socket = connection->getSocket();

// Added for NamedPipe implementation for windows

#if defined PEGASUS_OS_TYPE_WINDOWS && !defined(PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET)

if(!connection->isNamedPipeConnection())

{

#endif

SocketHandle socket = connection->getSocket();

if (socket == closeConnectionMessage->socket)

{

Line 229

Line 246

delete connection;

break;

}

// Added for NamedPipe implementation for windows

#if defined PEGASUS_OS_TYPE_WINDOWS && !defined(PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET)

}

_rep->_connection_mut.unlock();

else

{

NamedPipe namedPipe = connection->getNamedPipe();

//NamedPipeMessage* namedPipeMessage = (NamedPipeMessage*)message;

if (namedPipe.getPipe() == closeConnectionMessage->namedPipe.getPipe())

{

_monitor->unsolicitPipeMessages(namedPipe);

_rep->connections.remove(i);

delete connection;

break;

}

#endif

}

break;

}

Line 284

Line 319

/**

_bind - creates a new server socket and bind socket to the port address.

If PEGASUS_LOCAL_DOMAIN_SOCKET is defined, the port number is ignored and

If PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET is not defined, the port number is ignored and

a domain socket is bound.

void HTTPAcceptor::_bind()

{

PEGASUS_ASSERT(_rep != 0);

// Create address:

memset(_rep->address, 0, sizeof(*_rep->address));

#if defined PEGASUS_OS_TYPE_WINDOWS

if (!_localConnection)

{

#endif

memset(_rep->address, 0, sizeof(*_rep->address));

#if defined PEGASUS_OS_TYPE_WINDOWS

}

#endif

if (_localConnection)

{

#ifdef PEGASUS_LOCAL_DOMAIN_SOCKET

// Added for NamedPipe implementation for windows

#ifndef PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET

# ifdef PEGASUS_OS_TYPE_WINDOWS

# ifdef PEGASUS_LOCALDOMAINSOCKET_DEBUG

{

AutoMutex automut(Monitor::_cout_mut);

PEGASUS_STD(cout) << "in HTTPAcceptor::_bind before calling _createNamedPipe() "

<< PEGASUS_STD(endl);

}

# endif

_createNamedPipe();

# ifdef PEGASUS_LOCALDOMAINSOCKET_DEBUG

{

AutoMutex automut(Monitor::_cout_mut);

PEGASUS_STD(cout) << "in HTTPAcceptor::_bind after calling _createNamedPipe() " << PEGASUS_STD(endl);

}

# endif

return;

# else // Other than Windows platform

reinterpret_cast<struct sockaddr_un*>(_rep->address)->sun_family =

AF_UNIX;

strcpy(reinterpret_cast<struct sockaddr_un*>(_rep->address)->sun_path,

Line 305

Line 367

AtoE(reinterpret_cast<struct sockaddr_un*>(_rep->address)->sun_path);

#endif

::unlink(reinterpret_cast<struct sockaddr_un*>(_rep->address)->sun_path);

# endif

#else

PEGASUS_ASSERT(false);

#endif

Line 323

Line 386

if (_localConnection)

{

_rep->socket = socket(AF_UNIX, SOCK_STREAM, 0);

_rep->socket = Socket::createSocket(AF_UNIX, SOCK_STREAM, 0);

}

else

{

_rep->socket = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);

_rep->socket = Socket::createSocket(PF_INET, SOCK_STREAM, IPPROTO_TCP);

}

if (_rep->socket < 0)

Line 346

Line 410

// set the close-on-exec bit for this file handle.

// any unix that forks needs this bit set.

#ifndef PEGASUS_PLATFORM_WIN32_IX86_MSVC

#if !defined PEGASUS_OS_TYPE_WINDOWS && !defined(PEGASUS_OS_VMS)

int sock_flags;

if( (sock_flags = fcntl(_rep->socket, F_GETFD, 0)) < 0)

{

Line 387

Line 451

throw BindFailedException(parms);

}

// Bind socket to port:

if (::bind(_rep->socket, _rep->address, _rep->address_size) < 0)

{

Socket::close(_rep->socket);

Line 403

Line 469

throw BindFailedException(parms);

}

// Get the actual port value used if the caller specified a port value of 0.

if ( _portNumber == 0 )

{

sockaddr_in buf;

SocketLength bufSize = sizeof(buf);

if ( getsockname(_rep->socket, reinterpret_cast<sockaddr *>(&buf), &bufSize) == 0 )

{

_portNumber = ntohs(buf.sin_port);

}

// Change permissions on Linux local domain socket to allow writes by others.

#if !defined(PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET) && defined(PEGASUS_PLATFORM_LINUX_GENERIC_GNU)

if (_localConnection)

{

if (::chmod( PEGASUS_LOCAL_DOMAIN_SOCKET_PATH,

S_IRUSR | S_IWUSR | S_IXUSR |

S_IRGRP | S_IWGRP | S_IXGRP |

S_IROTH | S_IWOTH | S_IXOTH ) < 0 )

{

Socket::close(_rep->socket);

delete _rep;

_rep = 0;

//l10n

//throw BindFailedException("Failed to bind socket");

MessageLoaderParms parms("Common.HTTPAcceptor.FAILED_BIND_SOCKET",

"Failed to bind socket");

PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,

"HTTPAcceptor::_bind: Failed to set domain socket permissions.");

throw BindFailedException(parms);

}

#endif

// Set up listening on the given socket:

//int const MAX_CONNECTION_QUEUE_LENGTH = 15;

Line 457

Line 563

// close the socket

Socket::close(_rep->socket);

// Unlink Local Domain Socket Bug# 3312

if (_localConnection)

{

#ifndef PEGASUS_OS_TYPE_WINDOWS

# ifndef PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET

PEG_TRACE_STRING(TRC_HTTP, Tracer::LEVEL2,

"HTTPAcceptor::closeConnectionSocket Unlinking local connection." );

::unlink(

reinterpret_cast<struct sockaddr_un*>(_rep->address)->sun_path);

# else

PEGASUS_ASSERT(false);

# endif

#endif

}

else

{

Line 481

Line 602

}

/**

reconnectConnectionSocket - creates a new server socket.

void HTTPAcceptor::reconnectConnectionSocket()

{

if (_rep)

{

// unregister the socket

_monitor->unsolicitSocketMessages(_rep->socket);

// close the socket

Socket::close(_rep->socket);

// Unlink Local Domain Socket Bug# 3312

if (_localConnection)

{

#ifndef PEGASUS_OS_TYPE_WINDOWS && !defined(PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET)

PEG_TRACE_STRING(TRC_HTTP, Tracer::LEVEL2,

"HTTPAcceptor::reconnectConnectionSocket Unlinking local connection." );

::unlink(

reinterpret_cast<struct sockaddr_un*>(_rep->address)->sun_path);

#else

PEGASUS_ASSERT(false);

#endif

}

// open the socket

_bind();

}

else

{

PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,

"HTTPAcceptor::reconnectConnectionSocket failure _rep is null." );

}

/**

getOutstandingRequestCount - returns the number of outstanding requests.

Uint32 HTTPAcceptor::getOutstandingRequestCount()

Uint32 HTTPAcceptor::getOutstandingRequestCount() const

{

Uint32 count = 0;

if (_rep)

_rep->_connection_mut.lock(pegasus_thread_self());

{

AutoMutex autoMut(_rep->_connection_mut);

if (_rep->connections.size() > 0)

{

HTTPConnection* connection = _rep->connections[0];

count = connection->getRequestCount();

}

_rep->_connection_mut.unlock();

}

return count;

}

/**

getPortNumber - returns the port number used for the connection

Uint32 HTTPAcceptor::getPortNumber() const

{

return _portNumber;

}

void HTTPAcceptor::setSocketWriteTimeout(Uint32 socketWriteTimeout)

{

_socketWriteTimeout = socketWriteTimeout;

}

void HTTPAcceptor::unbind()

{

if (_rep)

{

_portNumber = 0;

Socket::close(_rep->socket);

if (_localConnection)

{

#ifdef PEGASUS_LOCAL_DOMAIN_SOCKET

#ifndef PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET

# ifndef PEGASUS_OS_TYPE_WINDOWS

::unlink(

reinterpret_cast<struct sockaddr_un*>(_rep->address)->sun_path);

# endif

#else

PEGASUS_ASSERT(false);

#endif

}

#if defined PEGASUS_OS_TYPE_WINDOWS && !defined(PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET)

if (!_localConnection)

{

#endif

delete _rep;

#if defined PEGASUS_OS_TYPE_WINDOWS && !defined(PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET)

}

#endif

_rep = 0;

}

else

Line 526

Line 707

void HTTPAcceptor::destroyConnections()

{

if (_rep)

{

// For each connection created by this object:

_rep->_connection_mut.lock(pegasus_thread_self());

AutoMutex autoMut(_rep->_connection_mut);

for (Uint32 i = 0, n = _rep->connections.size(); i < n; i++)

{

HTTPConnection* connection = _rep->connections[i];

Sint32 socket = connection->getSocket();

// Added for NamedPipe implementation for windows

#if defined PEGASUS_OS_TYPE_WINDOWS && !defined(PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET)

if(!connection->isNamedPipeConnection())

{

#endif

SocketHandle socket = connection->getSocket();

// Unsolicit SocketMessages:

_monitor->unsolicitSocketMessages(socket);

// Added for NamedPipe implementation for windows

// Destroy the connection (causing it to close):

#if defined PEGASUS_OS_TYPE_WINDOWS && !defined(PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET)

while (connection->refcount.value()) { }

}

else

{

NamedPipe namedPipe = connection->getNamedPipe();

_monitor->unsolicitPipeMessages(namedPipe);

}

#endif

while (connection->refcount.get()) { }

delete connection;

}

_rep->connections.clear();

_rep->_connection_mut.unlock();

}

void HTTPAcceptor::_acceptConnection()

Line 556

Line 750

PEGASUS_ASSERT(_rep != 0);

if (!_rep)

return;

// Accept the connection (populate the address):

struct sockaddr* accept_address;

#if defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)

SocketLength address_size;

size_t address_size;

#elif defined(PEGASUS_PLATFORM_AIX_RS_IBMCXX) || defined(PEGASUS_PLATFORM_LINUX_GENERIC_GNU) || (defined(PEGASUS_OS_SOLARIS) && !defined(SUNOS_5_6))

socklen_t address_size;

#else

int address_size;

#endif

if (_localConnection)

{

#ifdef PEGASUS_LOCAL_DOMAIN_SOCKET

#ifndef PEGASUS_OS_TYPE_WINDOWS

#ifndef PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET

accept_address = reinterpret_cast<struct sockaddr*>(new struct sockaddr_un);

address_size = sizeof(struct sockaddr_un);

#else

PEGASUS_ASSERT(false);

#endif

}

else

{

Line 585

Line 772

address_size = sizeof(struct sockaddr_in);

}

Sint32 socket = accept(_rep->socket, accept_address, &address_size);

SocketHandle socket = accept(_rep->socket, accept_address, &address_size);

if (socket == PEGASUS_SOCKET_ERROR)

{

// the remote connection is invalid, destroy client address.

delete accept_address;

if (socket < 0)

// TCPIP is down reconnect this acceptor

if(getSocketError() == PEGASUS_NETWORK_TCPIP_STOPPED)

{

PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,

"Socket has an IO error. TCP/IP down. Try to reconnect." );

reconnectConnectionSocket();

return;

}

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"HTTPAcceptor - accept() failure. errno: $0"

,errno);

Line 601

Line 799

return;

}

String ipAddress;

if (_localConnection)

{

ipAddress = "localhost";

}

else

{

unsigned char* sa = reinterpret_cast<unsigned char*>(

&reinterpret_cast<struct sockaddr_in*>(

accept_address)->sin_addr.s_addr);

char ipBuffer[32];

sprintf(ipBuffer, "%u.%u.%u.%u", sa[0], sa[1], sa[2], sa[3]);

ipAddress = ipBuffer;

}

delete accept_address;

// set the close on exec flag

#ifndef PEGASUS_PLATFORM_WIN32_IX86_MSVC

#if !defined(PEGASUS_OS_TYPE_WINDOWS) && !defined(PEGASUS_OS_VMS)

int sock_flags;

if( (sock_flags = fcntl(socket, F_GETFD, 0)) < 0)

{

Line 621

Line 837

#endif

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER, 0,

"HTTPAcceptor - accept() success. Socket: $1"

"HTTPAcceptor - accept() success. Socket: $1" ,socket));

,socket);

AutoPtr<MP_Socket> mp_socket(new MP_Socket(

socket, _sslcontext, _sslContextObjectLock));

mp_socket->setSocketWriteTimeout(_socketWriteTimeout);

// Perform the SSL handshake, if applicable. Make the socket non-blocking

// for this operation so we can send it back to the Monitor's select() loop

// if it takes a while.

// Create a new conection and add it to the connection list:

mp_socket->disableBlocking();

Sint32 socketAcceptStatus = mp_socket->accept();

mp_socket->enableBlocking();

AutoPtr<MP_Socket> mp_socket(new MP_Socket(socket, _sslcontext, _exportConnection));

if (socketAcceptStatus < 0)

if (mp_socket->accept() < 0)

{

PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,

"HTTPAcceptor: SSL_accept() failed");

mp_socket->close();

return;

}

// Create a new connection and add it to the connection list:

HTTPConnection* connection = new HTTPConnection(_monitor, mp_socket,

this, static_cast<MessageQueue *>(_outputMessageQueue), _exportConnection);

ipAddress, this, static_cast<MessageQueue *>(_outputMessageQueue));

if (socketAcceptStatus == 0)

{

PEG_TRACE_STRING(TRC_HTTP, Tracer::LEVEL2,

"HTTPAcceptor: SSL_accept() pending");

connection->_acceptPending = true;

}

// Solicit events on this new connection's socket:

int index;

if (-1 == (index = _monitor->solicitSocketMessages(

socket,

connection->getSocket(),

SocketMessage::READ | SocketMessage::EXCEPTION,

connection->getQueueId(), Monitor::CONNECTION)) )

{

Line 655

Line 890

return;

}

mp_socket.release();

// Save the socket for cleanup later:

connection->_entry_index = index;

_rep->_connection_mut.lock(pegasus_thread_self());

AutoMutex autoMut(_rep->_connection_mut);

_rep->connections.append(connection);

_rep->_connection_mut.unlock();

}

// Added for NamedPipe implementation for windows

AsyncDQueue<pegasus_acceptor> pegasus_acceptor::acceptors(true, 0);

#if defined PEGASUS_OS_TYPE_WINDOWS && !defined(PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET)

void HTTPAcceptor::_createNamedPipe()

void pegasus_acceptor::close_all_acceptors(void)

{

try

{

pegasus_acceptor* temp = acceptors.remove_first();

#ifdef PEGASUS_LOCALDOMAINSOCKET_DEBUG

while(temp)

{

delete temp;

AutoMutex automut(Monitor::_cout_mut);

temp = acceptors.remove_first();

PEGASUS_STD(cout) << "Entering HTTPAcceptor::_createNamedPipe()." << PEGASUS_STD(endl);

}

#endif

catch(...)

_rep->namedPipeServer = new NamedPipeServer(PEGASUS_NAMEDPIPE_PATH);

#ifdef PEGASUS_LOCALDOMAINSOCKET_DEBUG

{

AutoMutex automut(Monitor::_cout_mut);

PEGASUS_STD(cout) << "in HTTPAcceptor::_createNamedPipe() after calling the pipe server constructor" << PEGASUS_STD(endl);

}

pegasus_acceptor::pegasus_acceptor(monitor_2* monitor,

MessageQueue* outputMessageQueue,

Boolean localConnection,

Uint32 portNumber,

SSLContext* sslcontext)

: _monitor(monitor), _outputMessageQueue(outputMessageQueue),

_localConnection(localConnection), _portNumber(portNumber),

_sslcontext(sslcontext), connections(true, 0)

{

AutoMutex automut(Monitor::_cout_mut);

Socket::initializeInterface();

cout << "Named pipe...in _createNamedPipe..." << _rep->namedPipeServer->getPipe() << endl;

try {

acceptors.insert_first(this);

}

catch(...){

}

#endif

// Register to receive Messages on Connection pipe:

pegasus_acceptor::~pegasus_acceptor(void)

if ( -1 == ( _entry_index = _monitor->solicitPipeMessages(

*_rep->namedPipeServer,

NamedPipeMessage::READ | NamedPipeMessage::EXCEPTION,

getQueueId(),

Monitor::ACCEPTOR)))

{

unbind();

::CloseHandle(_rep->namedPipeServer->getPipe());

Socket::uninitializeInterface();

delete _rep;

try {

_rep = 0;

acceptors.remove(this);

//l10n

}

MessageLoaderParms parms("Common.HTTPAcceptor.FAILED_SOLICIT_SOCKET_MESSAGES",

catch(...){

"Failed to solicit socket messaeges");

}

PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,

"HTTPAcceptor::_bind: Failed to solicit pipe messages(2).");

}

throw BindFailedException(parms);

#ifdef PEGASUS_LOCALDOMAINSOCKET_DEBUG

void pegasus_acceptor::bind()

{

AutoMutex automut(Monitor::_cout_mut); //added

PEGASUS_SOCKLEN_SIZE addr_size;

PEGASUS_STD(cout) << "in HTTPAcceptor::_createNamedPipe() _monitor->solicitSocketMessages failed"

struct sockaddr *addr;

<< PEGASUS_STD(endl);

struct sockaddr_in addr_in;

# ifdef PEGASUS_LOCAL_DOMAIN_SOCKET

struct sockaddr_un addr_un;

#endif

memset(&addr_in, 0, sizeof(addr_in));

addr_in.sin_addr.s_addr = INADDR_ANY;

addr_in.sin_family = AF_INET;

addr_in.sin_port = htons(_portNumber);

addr = (struct sockaddr*) &addr_in;

addr_size = sizeof(addr_in);

// first step: determine which kind of socket factory to initialize,

// then create the socket and bind it to an address

if(_localConnection == true){

#ifdef PEGASUS_LOCAL_DOMAIN_SOCKET

unix_socket_factory sf;

pegasus_socket temp(&sf);

_listener = temp;

memset(&addr_un, 0, sizeof(addr_un));

addr_un.sun_family = AF_UNIX;

strcpy(addr_un.sun_path, PEGASUS_LOCAL_DOMAIN_SOCKET_PATH);

#ifdef PEGASUS_PLATFORM_OS400_ISERIES_IBM

AtoE(addr_un.sun_path);

#endif

addr = (struct sockaddr*) &addr_un;

addr_size = sizeof(addr_un);

_listener.socket(AF_UNIX, SOCK_STREAM, 0);

#else

bsd_socket_factory sf;

pegasus_socket temp(&sf);

_listener = temp;

_listener.socket(AF_UNIX, SOCK_STREAM, 0);

#endif

}

else if( _sslcontext != 0 ) {

#ifdef PEGASUS_HAS_SSL

ssl_socket_factory sf;

pegasus_socket temp(&sf, _sslcontext);

#else

bsd_socket_factory sf;

pegasus_socket temp(&sf);

#endif

_listener = temp;

_listener.socket(PF_INET, SOCK_STREAM, 0);

}

else {

bsd_socket_factory sf;

pegasus_socket temp(&sf);

_listener = temp;

_listener.socket(PF_INET, SOCK_STREAM, 0);

}

#ifdef PEGASUS_LOCALDOMAINSOCKET_DEBUG

_listener.bind((struct sockaddr*)addr, addr_size);

// second step: listen on the socket

_listener.listen(5);

// third step: add this listening socket to the monitor

_monitor->tickle();

_monitor->add_entry(_listener, LISTEN, this, this);

}

/** Unbind from the given port.

void pegasus_acceptor::unbind()

{

// remove the socket from the monitor

AutoMutex automut(Monitor::_cout_mut);

_monitor->remove_entry((Sint32)_listener);

PEGASUS_STD(cout) << "Leaving HTTPAcceptor::_createNamedPipe()." << PEGASUS_STD(endl);

// close the socket

_listener.close();

}

#endif

return;

/** Close the connection socket.

void pegasus_acceptor::closeConnectionSocket()

{

unbind();

}

void HTTPAcceptor::_acceptNamedPipeConnection()

{

PEGASUS_ASSERT(_rep != 0);

/** Reopen the connection socket.

if (!_rep)

return;

void pegasus_acceptor::reopenConnectionSocket()

#ifdef PEGASUS_LOCALDOMAINSOCKET_DEBUG

{

bind();

AutoMutex automut(Monitor::_cout_mut);

cout <<"In HTTPAcceptor::_acceptNamedPipeConnection " << endl;

}

#endif

/** Returns the number of outstanding requests

NamedPipeServerEndPiont nPSEndPoint = _rep->namedPipeServer->accept();

// Register to receive Messages on Connection pipe:

Uint32 pegasus_acceptor::getOutstandingRequestCount()

#ifdef PEGASUS_LOCALDOMAINSOCKET_DEBUG

{

return _monitor->getOutstandingRequestCount();

AutoMutex automut(Monitor::_cout_mut);

cout << " In _acceptNamedPipeConnection -- after calling namedPipeServer->accept()" << endl;

}

#endif

HTTPConnection* connection = new HTTPConnection(_monitor, nPSEndPoint,

this, static_cast<MessageQueue *>(_outputMessageQueue),false);

Boolean pegasus_acceptor::operator ==(const pegasus_acceptor& pa)

// Solicit events on this new connection's socket:

int index;

#ifdef PEGASUS_LOCALDOMAINSOCKET_DEBUG

{

if(this == &pa)

AutoMutex automut(Monitor::_cout_mut);

return true;

cout << endl << connection->getNamedPipe().getName() << " has a this as a QueueID " <<

return false;

connection->getQueueId() << endl;

}

#endif

Boolean pegasus_acceptor::operator ==(void* pa)

if (-1 == (index = _monitor->solicitPipeMessages(

connection->getNamedPipe(),

NamedPipeMessage::READ | NamedPipeMessage::EXCEPTION,

connection->getQueueId(), Monitor::ACCEPTOR)) )

{

if((void*)this == pa)

// ATTN-DE-P2-2003100503::TODO::Need to enhance code to return

return true;

// an error message to Client application.

return false;

Tracer::trace(TRC_DISCARDED_DATA, Tracer::LEVEL2,

"HTTPAcceptor::_acceptPipeConnection: Attempt to allocate entry in _entries table failed.");

delete connection;

return;

}

// Save the socket for cleanup later:

pegasus_acceptor* pegasus_acceptor::find_acceptor(Boolean local, Uint32 port)

connection->_entry_index = index;

AutoMutex autoMut(_rep->_connection_mut);

_rep->connections.append(connection);

#ifdef PEGASUS_LOCALDOMAINSOCKET_DEBUG

{

pegasus_acceptor* temp = 0;

AutoMutex automut(Monitor::_cout_mut);

PEGASUS_STD(cout)

try {

<< "in HTTPAcceptor::_acceptNamedPipeConnection() at the end" << PEGASUS_STD(endl);

acceptors.try_lock(pegasus_thread_self());

temp = acceptors.next(temp);

while(temp){

if( local == true ){

if(temp->_localConnection){

acceptors.unlock();

return temp;

}

if(temp->_localConnection == local && temp->_portNumber ==port){

acceptors.unlock();

return temp;

}

temp = acceptors.next(temp);

}

acceptors.unlock();

#endif

}

catch(...){

}

return temp;

}

class m2e_rep;

void pegasus_acceptor::accept_dispatch(monitor_2_entry *entry)

{

pegasus_acceptor* myself = (pegasus_acceptor*)entry->get_accept();

HTTPConnection2* connection = new HTTPConnection2(entry->_rep->psock, myself->_outputMessageQueue);

// set the entry's dispatch parameter to point to the connection object

entry->set_dispatch ((void*)connection);

monitor_2::insert_connection(connection);

}

#endif

PEGASUS_NAMESPACE_END

Legend:

Removed from v.1.49.2.1
changed lines
	Added in v.1.88.6.1

No CVS admin address has been configured