freeswitch/libs/xmlrpc-c/lib/abyss/src/conn.c

/*******************************************************************************
**
** conn.c
**
** This file is part of the ABYSS Web server project.
**
** Copyright (C) 2000 by Moez Mahfoudh <mmoez@bigfoot.com>.
** All rights reserved.
**
** Redistribution and use in source and binary forms, with or without
** modification, are permitted provided that the following conditions
** are met:
** 1. Redistributions of source code must retain the above copyright
**    notice, this list of conditions and the following disclaimer.
** 2. Redistributions in binary form must reproduce the above copyright
**    notice, this list of conditions and the following disclaimer in the
**    documentation and/or other materials provided with the distribution.
** 3. The name of the author may not be used to endorse or promote products
**    derived from this software without specific prior written permission.
** 
** THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
** ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
** IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
** ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
** FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
** DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
** OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
** HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
** LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
** OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
** SUCH DAMAGE.
**
*******************************************************************************/

#include <time.h>
#include <string.h>
#include <stdlib.h>
#include <stdio.h>
#include <ctype.h>

#include "xmlrpc-c/abyss.h"

/*********************************************************************
** Conn
*********************************************************************/

TConn *ConnAlloc()
{
    return (TConn *)malloc(sizeof(TConn));
}

void ConnFree(TConn *c)
{
    free(c);
}

static uint32_t
THREAD_ENTRYTYPE ConnJob(TConn *c) {
    c->connected=TRUE;
    (c->job)(c);
    c->connected=FALSE;
    ThreadExit( &c->thread, 0 );
    return 0;
}

abyss_bool ConnCreate2(TConn *             const connectionP, 
                       TServer *           const serverP,
                       TSocket             const connectedSocket,
                       TIPAddr             const peerIpAddr,
                       void            ( *       func)(TConn *),
                       enum abyss_foreback const foregroundBackground)
{
    abyss_bool retval;
    
    connectionP->server     = serverP;
    connectionP->socket     = connectedSocket;
    connectionP->peerip     = peerIpAddr;
    connectionP->buffersize = 0;
    connectionP->bufferpos  = 0;
    connectionP->connected  = TRUE;
    connectionP->job        = func;
    connectionP->inbytes    = 0;
    connectionP->outbytes   = 0;
    connectionP->trace      = getenv("ABYSS_TRACE_CONN");
    
    switch (foregroundBackground)
    {
    case ABYSS_FOREGROUND:
        connectionP->hasOwnThread = FALSE;
        retval = TRUE;
        break;
    case ABYSS_BACKGROUND:
        connectionP->hasOwnThread = TRUE;
        retval = ThreadCreate(&connectionP->thread,
                              (TThreadProc)ConnJob, 
                              connectionP);
        break;
    }
    return retval;
}

abyss_bool ConnCreate(TConn *c, TSocket *s, void (*func)(TConn *))
{
    return ConnCreate2(c, c->server, *s, c->peerip, func, ABYSS_BACKGROUND);
}

abyss_bool ConnProcess(TConn *c)
{
    abyss_bool retval;

    if (c->hasOwnThread) {
        /* There's a background thread to handle this connection.  Set
           it running.
        */
        retval = ThreadRun(&(c->thread));
    } else {
        /* No background thread.  We just handle it here while Caller waits. */
        (c->job)(c);
        c->connected=FALSE;
        retval = TRUE;
    }
    return retval;
}

void ConnClose(TConn *c)
{
    if (c->hasOwnThread)
        ThreadClose(&c->thread);
}

abyss_bool ConnKill(TConn *c)
{
    c->connected=FALSE;
    return ThreadKill(&(c->thread));
}

void ConnReadInit(TConn *c)
{
    if (c->buffersize>c->bufferpos)
    {
        c->buffersize-=c->bufferpos;
        memmove(c->buffer,c->buffer+c->bufferpos,c->buffersize);
        c->bufferpos=0;
    }
    else
        c->buffersize=c->bufferpos=0;

    c->inbytes=c->outbytes=0;
}



static void
traceSocketRead(const char * const label,
                const char * const buffer,
                unsigned int const size) {

    unsigned int nonPrintableCount;
    unsigned int i;
    
    nonPrintableCount = 0;  /* Initial value */
    
    for (i = 0; i < size; ++i) {
        if (!isprint(buffer[i]) && buffer[i] != '\n' && buffer[i] != '\r')
            ++nonPrintableCount;
    }
    if (nonPrintableCount > 0)
        fprintf(stderr, "%s contains %u nonprintable characters.\n", 
                label, nonPrintableCount);
    
    fprintf(stderr, "%s:\n", label);
    fprintf(stderr, "%.*s\n", (int)size, buffer);
}



abyss_bool
ConnRead(TConn *  const c,
         uint32_t const timeout) {

    while (SocketWait(&(c->socket),TRUE,FALSE,timeout*1000) == 1) {
        uint32_t x;
        uint32_t y;
        
        x = SocketAvailableReadBytes(&c->socket);

        /* Avoid lost connections */
        if (x <= 0)
            break;
        
        /* Avoid Buffer overflow and lost Connections */
        if (x + c->buffersize >= BUFFER_SIZE)
            x = BUFFER_SIZE-c->buffersize - 1;
        
        y = SocketRead(&c->socket, c->buffer + c->buffersize, x);
        if (y > 0) {
            if (c->trace)
                traceSocketRead("READ FROM SOCKET:",
                                c->buffer + c->buffersize, y);

            c->inbytes += y;
            c->buffersize += y;
            c->buffer[c->buffersize] = '\0';
            return TRUE;
        }
        break;
    }
    return FALSE;
}


            
abyss_bool ConnWrite(TConn *c,void *buffer,uint32_t size)
{
    char *buf = buffer;
    int rc, off = 0;

    while (TRUE) {
        /* try sending data */
        if ((rc = SocketWrite(&(c->socket),&buf[off],size - off)) <= 0)
            return FALSE;

        /* increase count */
        off += rc;

        /* check we're not finished writing */
        if (off >= size)
            break;
    }

    c->outbytes+=size;
    return TRUE;
}

abyss_bool ConnWriteFromFile(TConn *c,TFile *file,uint64_t start,uint64_t end,
            void *buffer,uint32_t buffersize,uint32_t rate)
{
    uint64_t y,bytesread=0;
    uint32_t waittime;

    if (rate>0)
    {
        if (buffersize>rate)
            buffersize=rate;

        waittime=(1000*buffersize)/rate;
    }
    else
        waittime=0;

    if (!FileSeek(file,start,SEEK_SET))
        return FALSE;

    while (bytesread<=end-start)
    {
        y=(end-start+1)-bytesread;

        if (y>buffersize)
            y=buffersize;

        y=FileRead(file,buffer,y);
        bytesread+=y;

        if (y>0)
            ConnWrite(c,buffer,y);
        else
            break;

        if (waittime)
            ThreadWait(waittime);
    };

    return (bytesread>end-start);
}

abyss_bool ConnReadLine(TConn *c,char **z,uint32_t timeout)
{
    char *p,*t;
    abyss_bool first=TRUE;
    uint32_t to,start;

    p=*z=c->buffer+c->bufferpos;
    start=clock();

    for (;;)
    {
        to=(clock()-start)/CLOCKS_PER_SEC;
        if (to>timeout)
            break;

        if (first)
        {
            if (c->bufferpos>=c->buffersize)
                if (!ConnRead(c,timeout-to))
                    break;

            first=FALSE;
        }
        else
        {
            if (!ConnRead(c,timeout-to))
                break;
        };

        t=strchr(p,LF);
        if (t)
        {
            if ((*p!=LF) && (*p!=CR))
            {
                if (!*(t+1))
                    continue;

                p=t;

                if ((*(p+1)==' ') || (*(p+1)=='\t'))
                {
                    if (p>*z)
                        if (*(p-1)==CR)
                            *(p-1)=' ';

                    *(p++)=' ';
                    continue;
                };
            } else {
                /* emk - 04 Jan 2001 - Bug fix to leave buffer
                ** pointing at start of body after reading blank
                ** line following header. */
                p=t;
            }

            c->bufferpos+=p+1-*z;

            if (p>*z)
                if (*(p-1)==CR)
                    p--;

            *p='\0';
            return TRUE;
        }
    };

    return FALSE;
}