rtime.c File Reference

#include <wintirpc.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <sys/types.h>
#include <stdio.h>

Include dependency graph for rtime.c:

Go to the source code of this file.

Macros
#define	NYEARS   (unsigned long)(1970 - 1900)
#define	TOFFSET   (unsigned long)(60*60*24*(365*NYEARS + (NYEARS/4)))

Functions
int	_rpc_dtablesize (void)
static void	do_close (SOCKET)
int	rtime (struct sockaddr_in *addrp, struct timeval *timep, struct timeval *timeout)
static void	do_close (int s)

Macro Definition Documentation

NYEARS

#define NYEARS   (unsigned long)(1970 - 1900)

Definition at line 59 of file rtime.c.

TOFFSET

#define TOFFSET   (unsigned long)(60*60*24*(365*NYEARS + (NYEARS/4)))

Definition at line 60 of file rtime.c.

Function Documentation

_rpc_dtablesize()

int _rpc_dtablesize

(

void

)

Definition at line 48 of file rpc_dtablesize.c.

{
#ifdef _WIN32
    return FD_SETSIZE;
#else
    static int size;

    if (size == 0) {
        size = getdtablesize();
        if (size > FD_SETSIZE)
            size = FD_SETSIZE;
    }
    return (size);
#endif
}

Referenced by rtime().

do_close() [1/2]

static void do_close ( SOCKET  )

static

Referenced by messages< char >::close(), messages< wchar_t >::close(), and rtime().

do_close() [2/2]

static void do_close ( int  s )

static

Definition at line 150 of file rtime.c.

{
    int save;

    save = errno;
    (void)closesocket(s);
    errno = save;
}

rtime()

int rtime	(	struct sockaddr_in *	addrp,
		struct timeval *	timep,
		struct timeval *	timeout
	)

Definition at line 69 of file rtime.c.

{
    SOCKET s;
    fd_set readfds;
    int res;
    unsigned long thetime;
    struct sockaddr_in from;
    int fromlen;
    int type;
    struct servent *serv;

    if (timeout == NULL) {
        type = SOCK_STREAM;
    } else {
        type = SOCK_DGRAM;
    }
    s = socket(AF_INET, type, 0);
    if (s == INVALID_SOCKET) {
        return(-1);
    }
    addrp->sin_family = AF_INET;

    /* TCP and UDP port are the same in this case */
    if ((serv = getservbyname("time", "tcp")) == NULL) {
        return(-1);
    }

    addrp->sin_port = serv->s_port;

    if (type == SOCK_DGRAM) {
        res = sendto(s, (char *)&thetime, sizeof(thetime), 0, 
                 (struct sockaddr *)addrp, sizeof(*addrp));
        if (res == SOCKET_ERROR) {
            do_close(s);
            return(-1); 
        }
        do {
            FD_ZERO(&readfds);
            FD_SET(s, &readfds);
            res = select(_rpc_dtablesize(), &readfds,
                     (fd_set *)NULL, (fd_set *)NULL, timeout);
        } while (res == SOCKET_ERROR && WSAGetLastError() == WSAEINTR);
        if (res == 0 || res == SOCKET_ERROR) {
            if (res == 0) {
                errno = WSAETIMEDOUT;
            }
            do_close(s);
            return(-1); 
        }
        fromlen = sizeof(from);
        res = recvfrom(s, (char *)&thetime, sizeof(thetime), 0, 
                   (struct sockaddr *)&from, &fromlen);
        do_close(s);
        if (res == SOCKET_ERROR) {
            return(-1); 
        }
    } else {
        if (connect(s, (struct sockaddr *)addrp, sizeof(*addrp)) == SOCKET_ERROR) {
            do_close(s);
            return(-1);
        }
        res = recv(s, (char *)&thetime, sizeof(thetime), 0);
        do_close(s);
        if (res == SOCKET_ERROR) {
            return(-1);
        }
    }
    if (res != sizeof(thetime)) {
        errno = EIO;
        return(-1); 
    }
    thetime = ntohl(thetime);
    timep->tv_sec = thetime - TOFFSET;
    timep->tv_usec = 0;
    return(0);
}