Open Source Projects Europe

#endif

#endif

#define MILLIS(OLD, NEW) ( (long)(((NEW).tv_sec - (OLD).tv_sec) * 1000 + \

#define MILLIS(OLD, NEW) ( (long)(((NEW).tv_sec - (OLD).tv_sec) * 1000 + \

                  ((NEW).tv_usec - (OLD).tv_usec) / 1000))

                  ((NEW).tv_usec - (OLD).tv_usec) / 1000))

// Simplified interface to 'select()'. Only use one fd, for either

// Simplified interface to 'select()'. Only use one fd, for either

// reading or writing. This is only used when not using the

// reading or writing. This is only used when not using the

// selectloop() style of network i/o.

// selectloop() style of network i/o.

// Note that timeo == 0 does NOT mean wait forever but no wait at all.

// Note that timeo == 0 does NOT mean wait forever but no wait at all.

int Netcon::select1(int fd, int timeo, int write)

int Netcon::select1(int fd, int timeo, int write)

    periodicmillis = ms;

    periodicmillis = ms;

    if (periodicmillis > 0)

    if (periodicmillis > 0)

    gettimeofday(&lasthdlcall, 0);

    gettimeofday(&lasthdlcall, 0);

}

}

// to call the periodic routine.

void periodictimeout(struct timeval *tv)

{

{

    // If periodic not set, the select call times out and we loop

    // If periodic not set, the select call times out and we loop

    // after a very long time (we'd need to pass NULL to select for an

    // after a very long time (we'd need to pass NULL to select for an

    // infinite wait, and I'm too lazy to handle it)

    // infinite wait, and I'm too lazy to handle it)

    if (periodicmillis <= 0) {

    if (periodicmillis <= 0) {

    tv->tv_usec = (millis % 1000) * 1000;

    tv->tv_usec = (millis % 1000) * 1000;

}

}

// Check if it's time to call the handler. selectloop will return to

// Check if it's time to call the handler. selectloop will return to

// caller if it or we return 0

// caller if it or we return 0

int maybecallperiodic()

{

{

    if (periodicmillis <= 0)

    if (periodicmillis <= 0)

    return 1;

    return 1;

    struct timeval mtv;

    struct timeval mtv;

    gettimeofday(&mtv, 0);

    gettimeofday(&mtv, 0);

    }

    }

}

}

void Netcon::closeconn() 

void Netcon::closeconn() 

{

{

    if (m_fd >= 0) {

    close(m_fd);

    close(m_fd);

}

}

char *Netcon::sterror()

char *Netcon::sterror()

{

{

    return strerror(errno);

    return strerror(errno);

}

}

// Receive at most cnt bytes (maybe less)

// Receive at most cnt bytes (maybe less)

int NetconData::receive(char *buf, int cnt, int timeo)

int NetconData::receive(char *buf, int cnt, int timeo)

{

{

    LOGDEB2(("NetconData::receive: cnt %d timeo %d m_buf 0x%x m_bufbytes %d\n",

         cnt, timeo, m_buf, m_bufbytes));

         cnt, timeo, m_buf, m_bufbytes));

    if (m_fd < 0) {

    if (m_fd < 0) {

    LOGERR(("NetconData::receive: connection not opened\n"));

    LOGERR(("NetconData::receive: connection not opened\n"));

    return -1;

    return -1;

    }

    }

    // Get whatever might have been left in the buffer by a previous 

    // Get whatever might have been left in the buffer by a previous 

    // getline, except if we're called to fill the buffer of course

    // getline, except if we're called to fill the buffer of course

    if (m_buf && m_bufbytes > 0 && (buf < m_buf || buf > m_buf + m_bufsize)) {

    if (m_buf && m_bufbytes > 0 && (buf < m_buf || buf > m_buf + m_bufsize)) {

    memcpy(buf, m_bufbase, frombuf);

    m_bufbytes -= frombuf;

    m_bufbase += frombuf;

    cnt -= frombuf;

    if (cnt <= 0)

    if (cnt <= 0)

        return frombuf;

    }

    }

    if (timeo > 0) {

    if (timeo > 0) {

    int ret = select1(m_fd, timeo);

    int ret = select1(m_fd, timeo);

    if (ret == 0) {

    if (ret == 0) {

        LOGDEB2(("NetconData::receive timed out\n"));

        LOGDEB2(("NetconData::receive timed out\n"));

        LOGSYSERR("NetconData::receive", "select", "");

        LOGSYSERR("NetconData::receive", "select", "");

        return -1;

        return -1;

    }

    }

    }

    }

    m_didtimo = 0;

    m_didtimo = 0;

    if ((cnt = read(m_fd, buf, cnt)) < 0) {

    char fdcbuf[10];sprintf(fdcbuf, "%d", m_fd);

    char fdcbuf[10];sprintf(fdcbuf, "%d", m_fd);

    LOGSYSERR("NetconData::receive", "read", fdcbuf);

    LOGSYSERR("NetconData::receive", "read", fdcbuf);

    return -1;

    return -1;

    }

    }

    LOGDEB2(("NetconData::receive: normal return, cnt %d\n", cnt));

    LOGDEB2(("NetconData::receive: normal return, cnt %d\n", cnt));

}

}

// Receive exactly cnt bytes (except for timeout)

// Receive exactly cnt bytes (except for timeout)

int NetconData::doreceive(char *buf, int cnt, int timeo)

int NetconData::doreceive(char *buf, int cnt, int timeo)

{

{

    int maxtransf = MIN(m_bufbytes, cnt-1);

    int maxtransf = MIN(m_bufbytes, cnt-1);

    int nn = maxtransf;

    int nn = maxtransf;

    LOGDEB2(("Before loop, bufbytes %d, maxtransf %d, nn: %d\n", 

    LOGDEB2(("Before loop, bufbytes %d, maxtransf %d, nn: %d\n", 

         m_bufbytes, maxtransf, nn));

         m_bufbytes, maxtransf, nn));

    for (nn = maxtransf; nn > 0;) {

    for (nn = maxtransf; nn > 0;) {

        // This is not pretty but we want nn to be decremented for

        // Better ways welcome!

        nn--;

        nn--;

        if ((*cp++ = *m_bufbase++) == '\n')

        if ((*cp++ = *m_bufbase++) == '\n')

        break;

        break;

    }

    }

    // Update counts

    // Update counts

int NetconCli::setconn(int fd)

int NetconCli::setconn(int fd)

{

{

    LOGDEB2(("Netconcli::setconn: fd %d\n", fd));

    LOGDEB2(("Netconcli::setconn: fd %d\n", fd));

    closeconn();

    closeconn();

    m_fd = fd;

    m_fd = fd;

    setpeer("");

    setpeer("");

    return 0;

    return 0;

}

}