#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(), DSLeaseIpAddress(), and DSRenewIpAddressLease().

◆ 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(), DSLeaseIpAddress(), DSReleaseIpAddressLease(), DSRenewIpAddressLease(), DSStaticRefreshParams(), and IsReconnectHackNeeded().

◆ 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(), DSLeaseIpAddress(), DSRenewIpAddressLease(), 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);
         }
     }
 }