#include <rosdhcp.h>
#include <reactos/debug.h>

Include dependency graph for dispatch.c:

Macros
#define	NDEBUG

Functions
void	dispatch (HANDLE hStopEvent)

void	got_one (struct protocol *l)

void	add_timeout (time_t when, void(where)(void ), void *what)

void	cancel_timeout (void(where)(void ), void *what)

void	add_protocol (char name, int fd, void(handler)(struct protocol ), void local)

void	remove_protocol (struct protocol *proto)

struct protocol *	find_protocol_by_adapter (struct interface_info *info)

int	interface_link_status (char *ifname)

Variables
SOCKET	DhcpSocket

HANDLE	hAdapterStateChangedEvent

struct protocol *	protocols = NULL

struct timeout *	timeouts = NULL

static struct timeout *	free_timeouts = NULL

void(*	bootp_packet_handler )(struct interface_info , struct dhcp_packet , int, unsigned int, struct iaddr, struct hardware *)

Macro Definition Documentation

◆ NDEBUG

#define NDEBUG

Definition at line 44 of file dispatch.c.

Function Documentation

◆ add_protocol()

void add_protocol	(	char *	name,
		int	fd,
		void()(struct protocol )	handler,
		void *	local
	)

Definition at line 342 of file dispatch.c.

{
    struct protocol *p;
 
    p = malloc(sizeof(*p));
    if (!p)
        error("can't allocate protocol struct for %s", name);
 
    p->fd = fd;
    p->handler = handler;
    p->local = local;
    p->next = protocols;
    protocols = p;
}

Referenced by AdapterDiscoveryThread(), and Server_AcquireParameters().

◆ add_timeout()

void add_timeout	(	time_t	when,
		void()(void )	where,
		void *	what
	)

Definition at line 253 of file dispatch.c.

{
    struct timeout *t, *q;
 
    DH_DbgPrint(MID_TRACE,("Adding timeout %x %p %x\n", when, where, what));
    /* See if this timeout supersedes an existing timeout. */
    t = NULL;
    for (q = timeouts; q; q = q->next) {
        if (q->func == where && q->what == what) {
            if (t)
                t->next = q->next;
            else
                timeouts = q->next;
            break;
        }
        t = q;
    }
 
    /* If we didn't supersede a timeout, allocate a timeout
       structure now. */
    if (!q) {
        if (free_timeouts) {
            q = free_timeouts;
            free_timeouts = q->next;
            q->func = where;
            q->what = what;
        } else {
            q = malloc(sizeof(struct timeout));
            if (!q) {
                error("Can't allocate timeout structure!");
                return;
            }
            q->func = where;
            q->what = what;
        }
    }
 
    q->when = when;
 
    /* Now sort this timeout into the timeout list. */
 
    /* Beginning of list? */
    if (!timeouts || timeouts->when > q->when) {
        q->next = timeouts;
        timeouts = q;
        return;
    }
 
    /* Middle of list? */
    for (t = timeouts; t->next; t = t->next) {
        if (t->next->when > q->when) {
            q->next = t->next;
            t->next = q;
            return;
        }
    }
 
    /* End of list. */
    t->next = q;
    q->next = NULL;
}

Referenced by bind_lease(), dhcpoffer(), send_discover(), and send_request().

◆ cancel_timeout()

void cancel_timeout	(	void()(void )	where,
		void *	what
	)

Definition at line 316 of file dispatch.c.

{
    struct timeout *t, *q;
 
    /* Look for this timeout on the list, and unlink it if we find it. */
    t = NULL;
    for (q = timeouts; q; q = q->next) {
        if (q->func == where && q->what == what) {
            if (t)
                t->next = q->next;
            else
                timeouts = q->next;
            break;
        }
        t = q;
    }
 
    /* If we found the timeout, put it on the free list. */
    if (q) {
        q->next = free_timeouts;
        free_timeouts = q;
    }
}

Referenced by dhcpack(), dhcpnak(), dhcpoffer(), send_request(), and state_selecting().

◆ dispatch()

void dispatch ( HANDLE hStopEvent )

Definition at line 70 of file dispatch.c.

{
    int count, to_msec;
    struct protocol *l;
    time_t howlong, cur_time;
    HANDLE Events[3];
    int EventCount = 2;
 
    Events[0] = hAdapterStateChangedEvent;
    Events[1] = hStopEvent;
    Events[2] = WSA_INVALID_EVENT;
 
    ApiLock();
 
    do {
        /*
         * Call any expired timeouts, and then if there's still
         * a timeout registered, time out the select call then.
         */
        time(&cur_time);
 
        if (timeouts)
        {
            struct timeout *t;
 
            if (timeouts->when <= cur_time) {
                t = timeouts;
                timeouts = timeouts->next;
                (*(t->func))(t->what);
                t->next = free_timeouts;
                free_timeouts = t;
                continue;
            }
 
            /*
             * Figure timeout in milliseconds, and check for
             * potential overflow, so we can cram into an
             * int for poll, while not polling with a
             * negative timeout and blocking indefinitely.
             */
            howlong = timeouts->when - cur_time;
            if (howlong > INT_MAX / 1000)
                howlong = INT_MAX / 1000;
            to_msec = howlong * 1000;
        }
        else
        {
            to_msec = INFINITE;
        }
 
        if (Events[2] == WSA_INVALID_EVENT && DhcpSocket != INVALID_SOCKET)
        {
            Events[2] = WSACreateEvent();
            if (Events[2] != WSA_INVALID_EVENT)
            {
                count = WSAEventSelect(DhcpSocket, Events[2], FD_READ | FD_CLOSE);
                if (count != NO_ERROR)
                {
                    WSACloseEvent(Events[2]);
                    Events[2] = WSA_INVALID_EVENT;
                }
                else
                {
                    EventCount = 3;
                }
            }
        }
        else if (Events[2] != WSA_INVALID_EVENT && DhcpSocket == INVALID_SOCKET)
        {
            WSACloseEvent(Events[2]);
            Events[2] = WSA_INVALID_EVENT;
 
            EventCount = 2;
        }
 
        ApiUnlock();
        count = WaitForMultipleObjects(EventCount,
                                       Events,
                                       FALSE,
                                       to_msec);
        ApiLock();
        if (count == WAIT_OBJECT_0)
        {
            /* Adapter state change */
            continue;
        }
        else if (count == WAIT_OBJECT_0 + 1)
        {
            /* Stop event signalled */
            DPRINT("Dispatch thread stop event!\n");
            break;
        }
        else if (count == WAIT_OBJECT_0 + 2)
        {
            /* Packet received */
 
            /* WSA events are manual reset events */
            WSAResetEvent(Events[2]);
        }
        else
        {
            /* Timeout */
            continue;
        }
 
        for (l = protocols; l; l = l->next) {
            struct interface_info *ip;
            ip = l->local;
            if (ip && (l->handler != got_one ||
                        !ip->dead)) {
                DH_DbgPrint(MID_TRACE,("Handling %x\n", l));
                (*(l->handler))(l);
            }
        }
    } while (1);
 
    WSACloseEvent(Events[2]);
 
    ApiUnlock();
 
    DPRINT("Dispatch thread stopped!\n");
}

Referenced by create_database(), create_list(), create_view(), CxxHandleV8Frame(), database_invoke(), ICreateTypeInfo2_fnSetTypeFlags(), init_test_dispatch(), InstallerImpl_OpenDatabase(), InstallerImpl_OpenPackage(), InstallerImpl_Products(), InstallerImpl_RelatedProducts(), InstallerImpl_SummaryInformation(), main(), run_script(), ServiceMain(), session_invoke(), svc_create(), svc_reg(), svc_tp_create(), test_CreateTypeLib(), test_IConnectionPoint(), test_IWinHttpRequest_Invoke(), test_ParseDisplayName(), test_recinfo(), test_VarCat(), and test_VarUI1FromDisp().

◆ find_protocol_by_adapter()

struct protocol * find_protocol_by_adapter ( struct interface_info * info )

Definition at line 412 of file dispatch.c.

{
    struct protocol *p;
 
    for( p = protocols; p; p = p->next ) {
        if( p->local == (void *)info ) return p;
    }
 
    return NULL;
}

Referenced by AdapterDiscoveryThread(), IsReconnectHackNeeded(), Server_AcquireParameters(), Server_ReleaseParameters(), and Server_StaticRefreshParams().

◆ got_one()

void got_one ( struct protocol * l )

Definition at line 194 of file dispatch.c.

{
    struct sockaddr_in from;
    struct hardware hfrom;
    struct iaddr ifrom;
    ssize_t result;
    union {
        /*
         * Packet input buffer.  Must be as large as largest
         * possible MTU.
         */
        unsigned char packbuf[4095];
        struct dhcp_packet packet;
    } u;
    struct interface_info *ip = l->local;
    PDHCP_ADAPTER adapter;
 
    if ((result = receive_packet(ip, u.packbuf, sizeof(u), &from,
                                 &hfrom)) == -1) {
        warning("receive_packet failed on %s: %d", ip->name,
                WSAGetLastError());
        ip->errors++;
        if (ip->errors > 20) {
            /* our interface has gone away. */
            warning("Interface %s no longer appears valid.",
                    ip->name);
            ip->dead = 1;
            closesocket(l->fd);
            remove_protocol(l);
            adapter = AdapterFindInfo(ip);
            if (adapter) {
                RemoveEntryList(&adapter->ListEntry);
                free(adapter);
            }
        }
        return;
    }
    if (result == 0)
        return;
 
    if (bootp_packet_handler) {
        ifrom.len = 4;
        memcpy(ifrom.iabuf, &from.sin_addr, ifrom.len);
 
        
        adapter = AdapterFindByHardwareAddress(u.packet.chaddr,
                                               u.packet.hlen);
 
        if (!adapter) {
            warning("Discarding packet with a non-matching target physical address\n");
            return;
        }
 
        (*bootp_packet_handler)(&adapter->DhclientInfo, &u.packet, result,
                                from.sin_port, ifrom, &hfrom);
    }
}

Referenced by AdapterDiscoveryThread(), dispatch(), Server_AcquireParameters(), and slurpstring().

◆ interface_link_status()

int interface_link_status ( char * ifname )

Definition at line 424 of file dispatch.c.

{
    return (1);
}

◆ remove_protocol()

void remove_protocol ( struct protocol * proto )

Definition at line 359 of file dispatch.c.

{
    struct protocol *p, *next, *prev;
    struct interface_info *ip = proto->local;
    struct timeout *t, *q, *u;
    
    t = NULL;
    q = timeouts;
    while (q != NULL)
    {
        /* Remove all timeouts for this protocol */
        if (q->what == ip)
        {
            /* Unlink the timeout from previous */
            if (t)
                t->next = q->next;
            else
                timeouts = q->next;
                        
            /* Advance to the next timeout */
            u = q->next;
            
            /* Add it to the free list */
            q->next = free_timeouts;
            free_timeouts = q;
        }
        else
        {
            /* Advance to the next timeout */
            u = q->next;
            
            /* Update the previous pointer */
            t = q;
        }
        
        /* Advance */
        q = u;
    }
 
    prev = NULL;
    for (p = protocols; p; p = next) {
        next = p->next;
        if (p == proto) {
            if (prev)
                prev->next = p->next;
            else
                protocols = p->next;
            free(p);
        }
    }
}

Referenced by AdapterDiscoveryThread(), got_one(), Server_AcquireParameters(), Server_ReleaseParameters(), and Server_StaticRefreshParams().

Variable Documentation

◆ bootp_packet_handler

void(* bootp_packet_handler) (struct interface_info , struct dhcp_packet , int, unsigned int, struct iaddr, struct hardware *)	(	struct interface_info *	,
		struct dhcp_packet *	,
		int	,
		unsigned int	,
		struct iaddr	,
		struct hardware *
	)