![]() ![]() |
![]() |
File: [Pegasus] / pegasus / src / Pegasus / ProviderManager2 / CMPIR / ip.c
(download)
Revision: 1.1, Wed Jun 16 11:45:56 2004 UTC (20 years ago) by schuur Branch: MAIN PEP#: 130 TITLE: Remote CMPI support DESCRIPTION: Base code for Remote CMPI |
//%2003//////////////////////////////////////////////////////////////////////// // // Copyright (c) 2000, 2001, 2002 BMC Software, Hewlett-Packard Development // Company, L. P., IBM Corp., The Open Group, Tivoli Systems. // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L. P.; // IBM Corp.; EMC 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 // deal in the Software without restriction, including without limitation the // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or // sell copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN // ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. // //============================================================================== // // Author: Frank Scheffler // // Modified By: Adrian Schuur (schuur@de.ibm.com) // //%///////////////////////////////////////////////////////////////////////////// /*! \file ip.c \brief General TCP/IP routines. \author Frank Scheffler */ #include <stdio.h> #include <stdlib.h> #include <error.h> #include <errno.h> #include <string.h> #include <sys/types.h> #include <sys/socket.h> #include <netinet/in.h> #include <netdb.h> #include <unistd.h> #include <Pegasus/ProviderManager2/CMPI/CMPI_Version.h> #include <Pegasus/Provider/CMPI/cmpimacs.h> #include <Pegasus/Provider/CMPI/cmpidt.h> #include <Pegasus/Provider/CMPI/cmpift.h> #include "ip.h" #include "tcpcomm.h" struct linger __linger = { 1, 15 }; extern CMPIBrokerExtFT *CMPI_BrokerExt_Ftab; /****************************************************************************/ int open_connection ( const char * address, int port ) { int sockfd; struct sockaddr_in sin; struct hostent * server_host_name; if ( ( server_host_name = gethostbyname ( address ) ) == NULL ) { error_at_line ( 0, 0, __FILE__, __LINE__, hstrerror ( h_errno ) ); return -1; } sin.sin_family = AF_INET; sin.sin_port = htons ( port ); sin.sin_addr.s_addr = ( (struct in_addr *) ( server_host_name->h_addr ) )->s_addr; if ( ( sockfd = socket ( PF_INET, SOCK_STREAM, IPPROTO_TCP ) ) == -1 ) { error_at_line ( 0, errno, __FILE__, __LINE__, "failed to create socket" ); return -1; } setsockopt ( sockfd, SOL_SOCKET, SO_LINGER, &__linger, sizeof ( struct linger ) ); if ( connect ( sockfd, (struct sockaddr *) &sin, sizeof ( sin ) ) == -1 ) { error_at_line ( 0, errno, __FILE__, __LINE__, "could not connect to %s:%d", address, port ); return -1; } return sockfd; } void accept_connections ( int port, void (* __connection_handler) ( int ), int multithreaded ) { CMPI_THREAD_TYPE t; int in_socket, listen_socket = socket ( PF_INET, SOCK_STREAM, IPPROTO_TCP ); struct sockaddr_in sin; int sin_len = sizeof ( sin ); int ru = 1; setsockopt ( listen_socket, SOL_SOCKET, SO_REUSEADDR, (char *) &ru, sizeof ( ru ) ); bzero ( &sin, sin_len ); sin.sin_family = AF_INET; sin.sin_addr.s_addr = INADDR_ANY; sin.sin_port = htons ( port ); if ( bind ( listen_socket, (struct sockaddr *) &sin, sin_len ) || listen ( listen_socket, 0 ) ) { error ( -1, errno, "cannot listen on port %d", port ); } while ( ( in_socket = accept ( listen_socket, (struct sockaddr *) &sin, &sin_len ) ) != -1 ) { setsockopt ( in_socket, SOL_SOCKET, SO_LINGER, &__linger, sizeof ( struct linger ) ); if ( multithreaded ) { t=CMPI_BrokerExt_Ftab->newThread( (void *(*)(void *))__connection_handler, (void *) in_socket,1); } else __connection_handler ( in_socket ); } } void get_peer_address ( int socket, char * buf ) { #define UC(b) ( ( (int) b ) & 0xFF ) struct sockaddr_in sin; socklen_t sinlen = sizeof ( sin ); char * p = (char *) &sin.sin_addr; getpeername ( socket, (struct sockaddr *) &sin, &sinlen ); sprintf ( buf, "%d.%d.%d.%d", UC(p[0]), UC(p[1]), UC(p[2]), UC(p[3]) ); } /****************************************************************************/ /*** Local Variables: ***/ /*** mode: C ***/ /*** c-basic-offset: 8 ***/ /*** End: ***/
No CVS admin address has been configured |
Powered by ViewCVS 0.9.2 |