sockets.h

Go to the documentation of this file.

/**********************************************************************
 *
 * Verball Model Storage Library, Common Information Model Library 
 * for integration of Intelligent Services.
 * Copyright (C) 2005 Nikita Vinokurov, Orgway LLC.
 *
 * 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; 
 * version 2.1 of the License.
 *
 * 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 Street, Fifth Floor, 
 * Boston, MA  02110-1301  USA
 *
 * $Id: sockets.h,v 1.10 2006/09/18 21:38:30 sbreg Exp $
 **********************************************************************/

#ifndef _ols_sockets_header_
#define _ols_sockets_header_


#ifdef _WIN32
#include <Winsock2.h>
#else
#include <sys/select.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/time.h>
#include <sys/types.h>
#include <netdb.h>
#endif //_WIN32


#define MAX_PENDING_CONNECTIONS     44
#define MAX_EMPTY_READINGS          4


/*
 * Typedefs
 *
 */
#ifdef _WIN32
typedef SOCKET                  hsocket;
typedef struct sockaddr_in      hsockaddr;
typedef unsigned short          hport;
typedef struct in_addr          hip;

typedef struct _sockets_env {
    WSADATA wsaData;
} sockets_env;

#else //i.e. LINUX
typedef int                 hsocket;
typedef struct sockaddr_in          hsockaddr;
typedef unsigned short          hport;
typedef struct in_addr          hip;

typedef struct _sockets_env {
} sockets_env;
#endif //_WIN32


typedef struct _four_bytes {
    unsigned char b1;
    unsigned char b2;
    unsigned char b3;
    unsigned char b4;
} four_bytes;

typedef union {
    hip         ip_num;
    four_bytes  ip_bytes;
} ip_to_bytes;


/*
 * Defenitions
 *
 */


/*
 * Data structures
 *
 */
extern sockets_env sockets_os_enviroment;



#ifdef __cplusplus
extern "C"
{
#endif/* __cplusplus */


/*
 * Functions
 *
 */


int init_socket_subsystem();

int cleanup_socket_subsystem();

int common_send(hsocket sk,
        const char *buf,
        unsigned int buflen,
        unsigned int *sent);

int common_recv(hsocket sk,
        char *buf,
        unsigned int buflen,
        unsigned int *received);


int nonblocking_send(hsocket sk,
                    unsigned int ms_to_wait,
                    const char *buf,
                    unsigned int buflen,
                    unsigned int *sent);




int nonblocking_recv(hsocket sk,
                     unsigned int ms_to_wait,
                     char *buf,
                     unsigned int buflen,
                     unsigned int *received);




int nonblocking_accept(hsocket server_socket,
                       unsigned int ms_to_wait,
                       hsocket *new_socket,
                       hsockaddr *peer_address);



int ip_to_str(hip ip, char *buffer);



//int str_to_ip(const char *buffer, hip *pip);

int _str_to_ip(const char *buffer, hip *pip);



int create_listening_socket(hsocket *phsocket, struct in_addr server_address, hport server_port);


int connect_socket(hsocket sock, const hsockaddr *paddr);



void close_socket(hsocket sock);





/* Internal functions 
 *********************
 */


int send_socket(hsocket sock, const char *buff, unsigned int len);

int receive_socket(hsocket sock, char *recvbuff, unsigned int bufflen);

hsocket accept_socket(hsocket server_socket, hsockaddr *peer_address);

/* new_tcp_socket
 * Creates new socket
 * Returns -1 on error, otherwise - new socket
 */
hsocket new_tcp_socket();

int listen_socket(hsocket sock);
int bind_socket(hsocket sock, struct in_addr ip, hport port);


#ifdef __cplusplus
}
#endif/* __cplusplus */


#endif //_ols_sockets_header_

---