check_dhcp.c 28 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061
  1. /******************************************************************************
  2. *
  3. * CHECK_DHCP.C
  4. *
  5. * Program: DHCP plugin for Nagios
  6. * License: GPL
  7. * Copyright (c) 2001-2004 Ethan Galstad (nagios@nagios.org)
  8. *
  9. * License Information:
  10. *
  11. * This program is free software; you can redistribute it and/or modify
  12. * it under the terms of the GNU General Public License as published by
  13. * the Free Software Foundation; either version 2 of the License, or
  14. * (at your option) any later version.
  15. *
  16. * This program is distributed in the hope that it will be useful,
  17. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  18. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  19. * GNU General Public License for more details.
  20. *
  21. * You should have received a copy of the GNU General Public License
  22. * along with this program; if not, write to the Free Software
  23. * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  24. *
  25. *****************************************************************************/
  26. #include "common.h"
  27. #include "netutils.h"
  28. #include "utils.h"
  29. #include <stdio.h>
  30. #include <stdlib.h>
  31. #include <string.h>
  32. #include <errno.h>
  33. #include <unistd.h>
  34. #include <sys/time.h>
  35. #include <sys/ioctl.h>
  36. #include <fcntl.h>
  37. #include <getopt.h>
  38. #include <sys/socket.h>
  39. #include <sys/types.h>
  40. #include <netdb.h>
  41. #include <netinet/in.h>
  42. #include <net/if.h>
  43. #include <arpa/inet.h>
  44. #if defined( __linux__ )
  45. #include <linux/if_ether.h>
  46. #include <features.h>
  47. #else
  48. #include <netinet/if_ether.h>
  49. #include <sys/sysctl.h>
  50. #include <net/if_dl.h>
  51. #endif
  52. const char *progname = "check_dhcp";
  53. /*#define DEBUG*/
  54. #define HAVE_GETOPT_H
  55. /**** Common definitions ****/
  56. #define STATE_OK 0
  57. #define STATE_WARNING 1
  58. #define STATE_CRITICAL 2
  59. #define STATE_UNKNOWN -1
  60. #define OK 0
  61. #define ERROR -1
  62. #define FALSE 0
  63. #define TRUE 1
  64. /**** DHCP definitions ****/
  65. #define MAX_DHCP_CHADDR_LENGTH 16
  66. #define MAX_DHCP_SNAME_LENGTH 64
  67. #define MAX_DHCP_FILE_LENGTH 128
  68. #define MAX_DHCP_OPTIONS_LENGTH 312
  69. typedef struct dhcp_packet_struct{
  70. u_int8_t op; /* packet type */
  71. u_int8_t htype; /* type of hardware address for this machine (Ethernet, etc) */
  72. u_int8_t hlen; /* length of hardware address (of this machine) */
  73. u_int8_t hops; /* hops */
  74. u_int32_t xid; /* random transaction id number - chosen by this machine */
  75. u_int16_t secs; /* seconds used in timing */
  76. u_int16_t flags; /* flags */
  77. struct in_addr ciaddr; /* IP address of this machine (if we already have one) */
  78. struct in_addr yiaddr; /* IP address of this machine (offered by the DHCP server) */
  79. struct in_addr siaddr; /* IP address of DHCP server */
  80. struct in_addr giaddr; /* IP address of DHCP relay */
  81. unsigned char chaddr [MAX_DHCP_CHADDR_LENGTH]; /* hardware address of this machine */
  82. char sname [MAX_DHCP_SNAME_LENGTH]; /* name of DHCP server */
  83. char file [MAX_DHCP_FILE_LENGTH]; /* boot file name (used for diskless booting?) */
  84. char options[MAX_DHCP_OPTIONS_LENGTH]; /* options */
  85. }dhcp_packet;
  86. typedef struct dhcp_offer_struct{
  87. struct in_addr server_address; /* address of DHCP server that sent this offer */
  88. struct in_addr offered_address; /* the IP address that was offered to us */
  89. u_int32_t lease_time; /* lease time in seconds */
  90. u_int32_t renewal_time; /* renewal time in seconds */
  91. u_int32_t rebinding_time; /* rebinding time in seconds */
  92. struct dhcp_offer_struct *next;
  93. }dhcp_offer;
  94. typedef struct requested_server_struct{
  95. struct in_addr server_address;
  96. struct requested_server_struct *next;
  97. }requested_server;
  98. #define BOOTREQUEST 1
  99. #define BOOTREPLY 2
  100. #define DHCPDISCOVER 1
  101. #define DHCPOFFER 2
  102. #define DHCPREQUEST 3
  103. #define DHCPDECLINE 4
  104. #define DHCPACK 5
  105. #define DHCPNACK 6
  106. #define DHCPRELEASE 7
  107. #define DHCP_OPTION_MESSAGE_TYPE 53
  108. #define DHCP_OPTION_HOST_NAME 12
  109. #define DHCP_OPTION_BROADCAST_ADDRESS 28
  110. #define DHCP_OPTION_REQUESTED_ADDRESS 50
  111. #define DHCP_OPTION_LEASE_TIME 51
  112. #define DHCP_OPTION_RENEWAL_TIME 58
  113. #define DHCP_OPTION_REBINDING_TIME 59
  114. #define DHCP_INFINITE_TIME 0xFFFFFFFF
  115. #define DHCP_BROADCAST_FLAG 32768
  116. #define DHCP_SERVER_PORT 67
  117. #define DHCP_CLIENT_PORT 68
  118. #define ETHERNET_HARDWARE_ADDRESS 1 /* used in htype field of dhcp packet */
  119. #define ETHERNET_HARDWARE_ADDRESS_LENGTH 6 /* length of Ethernet hardware addresses */
  120. unsigned char client_hardware_address[MAX_DHCP_CHADDR_LENGTH]="";
  121. char network_interface_name[8]="eth0";
  122. u_int32_t packet_xid=0;
  123. u_int32_t dhcp_lease_time=0;
  124. u_int32_t dhcp_renewal_time=0;
  125. u_int32_t dhcp_rebinding_time=0;
  126. int dhcpoffer_timeout=2;
  127. dhcp_offer *dhcp_offer_list=NULL;
  128. requested_server *requested_server_list=NULL;
  129. int valid_responses=0; /* number of valid DHCPOFFERs we received */
  130. int requested_servers=0;
  131. int requested_responses=0;
  132. int request_specific_address=FALSE;
  133. int received_requested_address=FALSE;
  134. struct in_addr requested_address;
  135. int process_arguments(int, char **);
  136. int call_getopt(int, char **);
  137. int validate_arguments(void);
  138. void print_usage(void);
  139. void print_help(void);
  140. int get_hardware_address(int,char *);
  141. int send_dhcp_discover(int);
  142. int get_dhcp_offer(int);
  143. int get_results(void);
  144. int add_dhcp_offer(struct in_addr,dhcp_packet *);
  145. int free_dhcp_offer_list(void);
  146. int free_requested_server_list(void);
  147. int create_dhcp_socket(void);
  148. int close_dhcp_socket(int);
  149. int send_dhcp_packet(void *,int,int,struct sockaddr_in *);
  150. int receive_dhcp_packet(void *,int,int,int,struct sockaddr_in *);
  151. int main(int argc, char **argv){
  152. int dhcp_socket;
  153. int result;
  154. if(process_arguments(argc,argv)!=OK){
  155. /*usage("Invalid command arguments supplied\n");*/
  156. printf("Invalid command arguments supplied\n");
  157. exit(STATE_UNKNOWN);
  158. }
  159. /* create socket for DHCP communications */
  160. dhcp_socket=create_dhcp_socket();
  161. /* get hardware address of client machine */
  162. get_hardware_address(dhcp_socket,network_interface_name);
  163. /* send DHCPDISCOVER packet */
  164. send_dhcp_discover(dhcp_socket);
  165. /* wait for a DHCPOFFER packet */
  166. get_dhcp_offer(dhcp_socket);
  167. /* close socket we created */
  168. close_dhcp_socket(dhcp_socket);
  169. /* determine state/plugin output to return */
  170. result=get_results();
  171. /* free allocated memory */
  172. free_dhcp_offer_list();
  173. free_requested_server_list();
  174. return result;
  175. }
  176. /* determines hardware address on client machine */
  177. int get_hardware_address(int sock,char *interface_name){
  178. #if defined(__linux__)
  179. struct ifreq ifr;
  180. strncpy((char *)&ifr.ifr_name,interface_name,sizeof(ifr.ifr_name));
  181. /* try and grab hardware address of requested interface */
  182. if(ioctl(sock,SIOCGIFHWADDR,&ifr)<0){
  183. printf("Error: Could not get hardware address of interface '%s'\n",interface_name);
  184. exit(STATE_UNKNOWN);
  185. }
  186. memcpy(&client_hardware_address[0],&ifr.ifr_hwaddr.sa_data,6);
  187. #else
  188. /* Code from getmac.c posted at http://lists.freebsd.org/pipermail/freebsd-hackers/2004-June/007415.html
  189. * by Alecs King based on Unix Network programming Ch 17
  190. */
  191. int mib[6], len;
  192. char *buf;
  193. unsigned char *ptr;
  194. struct if_msghdr *ifm;
  195. struct sockaddr_dl *sdl;
  196. mib[0] = CTL_NET;
  197. mib[1] = AF_ROUTE;
  198. mib[2] = 0;
  199. mib[3] = AF_LINK;
  200. mib[4] = NET_RT_IFLIST;
  201. if ((mib[5] = if_nametoindex(interface_name)) == 0) {
  202. perror("if_nametoindex error");
  203. exit(2);
  204. }
  205. if (sysctl(mib, 6, NULL, &len, NULL, 0) < 0) {
  206. perror("sysctl 1 error");
  207. exit(3);
  208. }
  209. if ((buf = malloc(len)) == NULL) {
  210. perror("malloc error");
  211. exit(4);
  212. }
  213. if (sysctl(mib, 6, buf, &len, NULL, 0) < 0) {
  214. perror("sysctl 2 error");
  215. exit(5);
  216. }
  217. ifm = (struct if_msghdr *)buf;
  218. sdl = (struct sockaddr_dl *)(ifm + 1);
  219. ptr = (unsigned char *)LLADDR(sdl);
  220. memcpy(&client_hardware_address[0], ptr, 6) ;
  221. #endif
  222. #ifdef DEBUG
  223. printf("Hardware address: %02x:%02x:%02x:",client_hardware_address[0],client_hardware_address[1],client_hardware_address[2]);
  224. printf("%02x:",client_hardware_address[3]);
  225. printf("%02x:%02x\n",client_hardware_address[4],client_hardware_address[5]);
  226. printf("\n");
  227. #endif
  228. return OK;
  229. }
  230. /* sends a DHCPDISCOVER broadcast message in an attempt to find DHCP servers */
  231. int send_dhcp_discover(int sock){
  232. dhcp_packet discover_packet;
  233. struct sockaddr_in sockaddr_broadcast;
  234. /* clear the packet data structure */
  235. bzero(&discover_packet,sizeof(discover_packet));
  236. /* boot request flag (backward compatible with BOOTP servers) */
  237. discover_packet.op=BOOTREQUEST;
  238. /* hardware address type */
  239. discover_packet.htype=ETHERNET_HARDWARE_ADDRESS;
  240. /* length of our hardware address */
  241. discover_packet.hlen=ETHERNET_HARDWARE_ADDRESS_LENGTH;
  242. discover_packet.hops=0;
  243. /* transaction id is supposed to be random */
  244. srand(time(NULL));
  245. packet_xid=random();
  246. discover_packet.xid=htonl(packet_xid);
  247. /**** WHAT THE HECK IS UP WITH THIS?!? IF I DON'T MAKE THIS CALL, ONLY ONE SERVER RESPONSE IS PROCESSED!!!! ****/
  248. /* downright bizzarre... */
  249. ntohl(discover_packet.xid);
  250. /*discover_packet.secs=htons(65535);*/
  251. discover_packet.secs=0xFF;
  252. /* tell server it should broadcast its response */
  253. discover_packet.flags=htons(DHCP_BROADCAST_FLAG);
  254. /* our hardware address */
  255. memcpy(discover_packet.chaddr,client_hardware_address,ETHERNET_HARDWARE_ADDRESS_LENGTH);
  256. /* first four bytes of options field is magic cookie (as per RFC 2132) */
  257. discover_packet.options[0]='\x63';
  258. discover_packet.options[1]='\x82';
  259. discover_packet.options[2]='\x53';
  260. discover_packet.options[3]='\x63';
  261. /* DHCP message type is embedded in options field */
  262. discover_packet.options[4]=DHCP_OPTION_MESSAGE_TYPE; /* DHCP message type option identifier */
  263. discover_packet.options[5]='\x01'; /* DHCP message option length in bytes */
  264. discover_packet.options[6]=DHCPDISCOVER;
  265. /* the IP address we're requesting */
  266. if(request_specific_address==TRUE){
  267. discover_packet.options[7]=DHCP_OPTION_REQUESTED_ADDRESS;
  268. discover_packet.options[8]='\x04';
  269. memcpy(&discover_packet.options[9],&requested_address,sizeof(requested_address));
  270. }
  271. /* send the DHCPDISCOVER packet to broadcast address */
  272. sockaddr_broadcast.sin_family=AF_INET;
  273. sockaddr_broadcast.sin_port=htons(DHCP_SERVER_PORT);
  274. sockaddr_broadcast.sin_addr.s_addr=INADDR_BROADCAST;
  275. bzero(&sockaddr_broadcast.sin_zero,sizeof(sockaddr_broadcast.sin_zero));
  276. #ifdef DEBUG
  277. printf("DHCPDISCOVER to %s port %d\n",inet_ntoa(sockaddr_broadcast.sin_addr),ntohs(sockaddr_broadcast.sin_port));
  278. printf("DHCPDISCOVER XID: %lu (0x%X)\n",ntohl(discover_packet.xid),ntohl(discover_packet.xid));
  279. printf("DHCDISCOVER ciaddr: %s\n",inet_ntoa(discover_packet.ciaddr));
  280. printf("DHCDISCOVER yiaddr: %s\n",inet_ntoa(discover_packet.yiaddr));
  281. printf("DHCDISCOVER siaddr: %s\n",inet_ntoa(discover_packet.siaddr));
  282. printf("DHCDISCOVER giaddr: %s\n",inet_ntoa(discover_packet.giaddr));
  283. #endif
  284. /* send the DHCPDISCOVER packet out */
  285. send_dhcp_packet(&discover_packet,sizeof(discover_packet),sock,&sockaddr_broadcast);
  286. #ifdef DEBUG
  287. printf("\n\n");
  288. #endif
  289. return OK;
  290. }
  291. /* waits for a DHCPOFFER message from one or more DHCP servers */
  292. int get_dhcp_offer(int sock){
  293. dhcp_packet offer_packet;
  294. struct sockaddr_in source;
  295. int result=OK;
  296. int timeout=1;
  297. int responses=0;
  298. int x;
  299. time_t start_time;
  300. time_t current_time;
  301. time(&start_time);
  302. /* receive as many responses as we can */
  303. for(responses=0,valid_responses=0;;){
  304. time(&current_time);
  305. if((current_time-start_time)>=dhcpoffer_timeout)
  306. break;
  307. #ifdef DEBUG
  308. printf("\n\n");
  309. #endif
  310. bzero(&source,sizeof(source));
  311. bzero(&offer_packet,sizeof(offer_packet));
  312. result=OK;
  313. result=receive_dhcp_packet(&offer_packet,sizeof(offer_packet),sock,dhcpoffer_timeout,&source);
  314. if(result!=OK){
  315. #ifdef DEBUG
  316. printf("Result=ERROR\n");
  317. #endif
  318. continue;
  319. }
  320. else{
  321. #ifdef DEBUG
  322. printf("Result=OK\n");
  323. #endif
  324. responses++;
  325. }
  326. #ifdef DEBUG
  327. printf("DHCPOFFER from IP address %s\n",inet_ntoa(source.sin_addr));
  328. printf("DHCPOFFER XID: %lu (0x%X)\n",ntohl(offer_packet.xid),ntohl(offer_packet.xid));
  329. #endif
  330. /* check packet xid to see if its the same as the one we used in the discover packet */
  331. if(ntohl(offer_packet.xid)!=packet_xid){
  332. #ifdef DEBUG
  333. printf("DHCPOFFER XID (%lu) did not match DHCPDISCOVER XID (%lu) - ignoring packet\n",ntohl(offer_packet.xid),packet_xid);
  334. #endif
  335. continue;
  336. }
  337. /* check hardware address */
  338. result=OK;
  339. #ifdef DEBUG
  340. printf("DHCPOFFER chaddr: ");
  341. #endif
  342. for(x=0;x<ETHERNET_HARDWARE_ADDRESS_LENGTH;x++){
  343. #ifdef DEBUG
  344. printf("%02X",(unsigned char)offer_packet.chaddr[x]);
  345. #endif
  346. if(offer_packet.chaddr[x]!=client_hardware_address[x]){
  347. result=ERROR;
  348. }
  349. }
  350. #ifdef DEBUG
  351. printf("\n");
  352. #endif
  353. if(result==ERROR){
  354. #ifdef DEBUG
  355. printf("DHCPOFFER hardware address did not match our own - ignoring packet\n");
  356. #endif
  357. continue;
  358. }
  359. #ifdef DEBUG
  360. printf("DHCPOFFER ciaddr: %s\n",inet_ntoa(offer_packet.ciaddr));
  361. printf("DHCPOFFER yiaddr: %s\n",inet_ntoa(offer_packet.yiaddr));
  362. printf("DHCPOFFER siaddr: %s\n",inet_ntoa(offer_packet.siaddr));
  363. printf("DHCPOFFER giaddr: %s\n",inet_ntoa(offer_packet.giaddr));
  364. #endif
  365. add_dhcp_offer(source.sin_addr,&offer_packet);
  366. valid_responses++;
  367. }
  368. #ifdef DEBUG
  369. printf("Total responses seen on the wire: %d\n",responses);
  370. printf("Valid responses for this machine: %d\n",valid_responses);
  371. #endif
  372. return OK;
  373. }
  374. /* sends a DHCP packet */
  375. int send_dhcp_packet(void *buffer, int buffer_size, int sock, struct sockaddr_in *dest){
  376. struct sockaddr_in myname;
  377. int result;
  378. result=sendto(sock,(char *)buffer,buffer_size,0,(struct sockaddr *)dest,sizeof(*dest));
  379. #ifdef DEBUG
  380. printf("send_dhcp_packet result: %d\n",result);
  381. #endif
  382. if(result<0)
  383. return ERROR;
  384. return OK;
  385. }
  386. /* receives a DHCP packet */
  387. int receive_dhcp_packet(void *buffer, int buffer_size, int sock, int timeout, struct sockaddr_in *address){
  388. struct timeval tv;
  389. fd_set readfds;
  390. int recv_result;
  391. socklen_t address_size;
  392. struct sockaddr_in source_address;
  393. /* wait for data to arrive (up time timeout) */
  394. tv.tv_sec=timeout;
  395. tv.tv_usec=0;
  396. FD_ZERO(&readfds);
  397. FD_SET(sock,&readfds);
  398. select(sock+1,&readfds,NULL,NULL,&tv);
  399. /* make sure some data has arrived */
  400. if(!FD_ISSET(sock,&readfds)){
  401. #ifdef DEBUG
  402. printf("No (more) data received\n");
  403. #endif
  404. return ERROR;
  405. }
  406. else{
  407. /* why do we need to peek first? i don't know, its a hack. without it, the source address of the first packet received was
  408. not being interpreted correctly. sigh... */
  409. bzero(&source_address,sizeof(source_address));
  410. address_size=sizeof(source_address);
  411. recv_result=recvfrom(sock,(char *)buffer,buffer_size,MSG_PEEK,(struct sockaddr *)&source_address,&address_size);
  412. #ifdef DEBUG
  413. printf("recv_result_1: %d\n",recv_result);
  414. #endif
  415. recv_result=recvfrom(sock,(char *)buffer,buffer_size,0,(struct sockaddr *)&source_address,&address_size);
  416. #ifdef DEBUG
  417. printf("recv_result_2: %d\n",recv_result);
  418. #endif
  419. if(recv_result==-1){
  420. #ifdef DEBUG
  421. printf("recvfrom() failed, ");
  422. printf("errno: (%d) -> %s\n",errno,strerror(errno));
  423. #endif
  424. return ERROR;
  425. }
  426. else{
  427. #ifdef DEBUG
  428. printf("receive_dhcp_packet() result: %d\n",recv_result);
  429. printf("receive_dhcp_packet() source: %s\n",inet_ntoa(source_address.sin_addr));
  430. #endif
  431. memcpy(address,&source_address,sizeof(source_address));
  432. return OK;
  433. }
  434. }
  435. return OK;
  436. }
  437. /* creates a socket for DHCP communication */
  438. int create_dhcp_socket(void){
  439. struct sockaddr_in myname;
  440. struct ifreq interface;
  441. int sock;
  442. int flag=1;
  443. /* Set up the address we're going to bind to. */
  444. bzero(&myname,sizeof(myname));
  445. myname.sin_family=AF_INET;
  446. myname.sin_port=htons(DHCP_CLIENT_PORT);
  447. myname.sin_addr.s_addr=INADDR_ANY; /* listen on any address */
  448. bzero(&myname.sin_zero,sizeof(myname.sin_zero));
  449. /* create a socket for DHCP communications */
  450. sock=socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP);
  451. if(sock<0){
  452. printf("Error: Could not create socket!\n");
  453. exit(STATE_UNKNOWN);
  454. }
  455. #ifdef DEBUG
  456. printf("DHCP socket: %d\n",sock);
  457. #endif
  458. /* set the reuse address flag so we don't get errors when restarting */
  459. flag=1;
  460. if(setsockopt(sock,SOL_SOCKET,SO_REUSEADDR,(char *)&flag,sizeof(flag))<0){
  461. printf("Error: Could not set reuse address option on DHCP socket!\n");
  462. exit(STATE_UNKNOWN);
  463. }
  464. /* set the broadcast option - we need this to listen to DHCP broadcast messages */
  465. if(setsockopt(sock,SOL_SOCKET,SO_BROADCAST,(char *)&flag,sizeof flag)<0){
  466. printf("Error: Could not set broadcast option on DHCP socket!\n");
  467. exit(STATE_UNKNOWN);
  468. }
  469. /* bind socket to interface */
  470. #if defined(__linux__)
  471. strncpy(interface.ifr_ifrn.ifrn_name,network_interface_name,IFNAMSIZ);
  472. if(setsockopt(sock,SOL_SOCKET,SO_BINDTODEVICE,(char *)&interface,sizeof(interface))<0){
  473. printf("Error: Could not bind socket to interface %s. Check your privileges...\n",network_interface_name);
  474. exit(STATE_UNKNOWN);
  475. }
  476. #else
  477. strncpy(interface.ifr_name,network_interface_name,IFNAMSIZ);
  478. #endif
  479. /* bind the socket */
  480. if(bind(sock,(struct sockaddr *)&myname,sizeof(myname))<0){
  481. printf("Error: Could not bind to DHCP socket (port %d)! Check your privileges...\n",DHCP_CLIENT_PORT);
  482. exit(STATE_UNKNOWN);
  483. }
  484. return sock;
  485. }
  486. /* closes DHCP socket */
  487. int close_dhcp_socket(int sock){
  488. close(sock);
  489. return OK;
  490. }
  491. /* adds a requested server address to list in memory */
  492. int add_requested_server(struct in_addr server_address){
  493. requested_server *new_server;
  494. new_server=(requested_server *)malloc(sizeof(requested_server));
  495. if(new_server==NULL)
  496. return ERROR;
  497. new_server->server_address=server_address;
  498. new_server->next=requested_server_list;
  499. requested_server_list=new_server;
  500. requested_servers++;
  501. #ifdef DEBUG
  502. printf("Requested server address: %s\n",inet_ntoa(new_server->server_address));
  503. #endif
  504. return OK;
  505. }
  506. /* adds a DHCP OFFER to list in memory */
  507. int add_dhcp_offer(struct in_addr source,dhcp_packet *offer_packet){
  508. dhcp_offer *new_offer;
  509. int x;
  510. int y;
  511. unsigned option_type;
  512. unsigned option_length;
  513. if(offer_packet==NULL)
  514. return ERROR;
  515. /* process all DHCP options present in the packet */
  516. for(x=4;x<MAX_DHCP_OPTIONS_LENGTH;){
  517. /* end of options (0 is really just a pad, but bail out anyway) */
  518. if((int)offer_packet->options[x]==-1 || (int)offer_packet->options[x]==0)
  519. break;
  520. /* get option type */
  521. option_type=offer_packet->options[x++];
  522. /* get option length */
  523. option_length=offer_packet->options[x++];
  524. #ifdef DEBUG
  525. printf("Option: %d (0x%02X)\n",option_type,option_length);
  526. #endif
  527. /* get option data */
  528. if(option_type==DHCP_OPTION_LEASE_TIME)
  529. dhcp_lease_time=ntohl(*((u_int32_t *)&offer_packet->options[x]));
  530. if(option_type==DHCP_OPTION_RENEWAL_TIME)
  531. dhcp_renewal_time=ntohl(*((u_int32_t *)&offer_packet->options[x]));
  532. if(option_type==DHCP_OPTION_REBINDING_TIME)
  533. dhcp_rebinding_time=ntohl(*((u_int32_t *)&offer_packet->options[x]));
  534. /* skip option data we're ignoring */
  535. else
  536. for(y=0;y<option_length;y++,x++);
  537. }
  538. #ifdef DEBUG
  539. if(dhcp_lease_time==DHCP_INFINITE_TIME)
  540. printf("Lease Time: Infinite\n");
  541. else
  542. printf("Lease Time: %lu seconds\n",(unsigned long)dhcp_lease_time);
  543. if(dhcp_renewal_time==DHCP_INFINITE_TIME)
  544. printf("Renewal Time: Infinite\n");
  545. else
  546. printf("Renewal Time: %lu seconds\n",(unsigned long)dhcp_renewal_time);
  547. if(dhcp_rebinding_time==DHCP_INFINITE_TIME)
  548. printf("Rebinding Time: Infinite\n");
  549. printf("Rebinding Time: %lu seconds\n",(unsigned long)dhcp_rebinding_time);
  550. #endif
  551. new_offer=(dhcp_offer *)malloc(sizeof(dhcp_offer));
  552. if(new_offer==NULL)
  553. return ERROR;
  554. new_offer->server_address=source;
  555. new_offer->offered_address=offer_packet->yiaddr;
  556. new_offer->lease_time=dhcp_lease_time;
  557. new_offer->renewal_time=dhcp_renewal_time;
  558. new_offer->rebinding_time=dhcp_rebinding_time;
  559. #ifdef DEBUG
  560. printf("Added offer from server @ %s",inet_ntoa(new_offer->server_address));
  561. printf(" of IP address %s\n",inet_ntoa(new_offer->offered_address));
  562. #endif
  563. /* add new offer to head of list */
  564. new_offer->next=dhcp_offer_list;
  565. dhcp_offer_list=new_offer;
  566. return OK;
  567. }
  568. /* frees memory allocated to DHCP OFFER list */
  569. int free_dhcp_offer_list(void){
  570. dhcp_offer *this_offer;
  571. dhcp_offer *next_offer;
  572. for(this_offer=dhcp_offer_list;this_offer!=NULL;this_offer=next_offer){
  573. next_offer=this_offer->next;
  574. free(this_offer);
  575. }
  576. return OK;
  577. }
  578. /* frees memory allocated to requested server list */
  579. int free_requested_server_list(void){
  580. requested_server *this_server;
  581. requested_server *next_server;
  582. for(this_server=requested_server_list;this_server!=NULL;this_server=next_server){
  583. next_server=this_server->next;
  584. free(this_server);
  585. }
  586. return OK;
  587. }
  588. /* gets state and plugin output to return */
  589. int get_results(void){
  590. dhcp_offer *temp_offer;
  591. requested_server *temp_server;
  592. int result;
  593. u_int32_t max_lease_time=0;
  594. received_requested_address=FALSE;
  595. /* checks responses from requested servers */
  596. requested_responses=0;
  597. if(requested_servers>0){
  598. for(temp_server=requested_server_list;temp_server!=NULL;temp_server=temp_server->next){
  599. for(temp_offer=dhcp_offer_list;temp_offer!=NULL;temp_offer=temp_offer->next){
  600. /* get max lease time we were offered */
  601. if(temp_offer->lease_time>max_lease_time || temp_offer->lease_time==DHCP_INFINITE_TIME)
  602. max_lease_time=temp_offer->lease_time;
  603. /* see if we got the address we requested */
  604. if(!memcmp(&requested_address,&temp_offer->offered_address,sizeof(requested_address)))
  605. received_requested_address=TRUE;
  606. /* see if the servers we wanted a response from talked to us or not */
  607. if(!memcmp(&temp_offer->server_address,&temp_server->server_address,sizeof(temp_server->server_address))){
  608. #ifdef DEBUG
  609. printf("DHCP Server Match: Offerer=%s",inet_ntoa(temp_offer->server_address));
  610. printf(" Requested=%s\n",inet_ntoa(temp_server->server_address));
  611. #endif
  612. requested_responses++;
  613. }
  614. }
  615. }
  616. }
  617. /* else check and see if we got our requested address from any server */
  618. else{
  619. for(temp_offer=dhcp_offer_list;temp_offer!=NULL;temp_offer=temp_offer->next){
  620. /* get max lease time we were offered */
  621. if(temp_offer->lease_time>max_lease_time || temp_offer->lease_time==DHCP_INFINITE_TIME)
  622. max_lease_time=temp_offer->lease_time;
  623. /* see if we got the address we requested */
  624. if(!memcmp(&requested_address,&temp_offer->offered_address,sizeof(requested_address)))
  625. received_requested_address=TRUE;
  626. }
  627. }
  628. result=STATE_OK;
  629. if(valid_responses==0)
  630. result=STATE_CRITICAL;
  631. else if(requested_servers>0 && requested_responses==0)
  632. result=STATE_CRITICAL;
  633. else if(requested_responses<requested_servers)
  634. result=STATE_WARNING;
  635. else if(request_specific_address==TRUE && received_requested_address==FALSE)
  636. result=STATE_WARNING;
  637. printf("DHCP %s: ",(result==STATE_OK)?"ok":"problem");
  638. /* we didn't receive any DHCPOFFERs */
  639. if(dhcp_offer_list==NULL){
  640. printf("No DHCPOFFERs were received.\n");
  641. return result;
  642. }
  643. printf("Received %d DHCPOFFER(s)",valid_responses);
  644. if(requested_servers>0)
  645. printf(", %s%d of %d requested servers responded",((requested_responses<requested_servers) && requested_responses>0)?"only ":"",requested_responses,requested_servers);
  646. if(request_specific_address==TRUE)
  647. printf(", requested address (%s) was %soffered",inet_ntoa(requested_address),(received_requested_address==TRUE)?"":"not ");
  648. printf(", max lease time = ");
  649. if(max_lease_time==DHCP_INFINITE_TIME)
  650. printf("Infinity");
  651. else
  652. printf("%lu sec",(unsigned long)max_lease_time);
  653. printf(".\n");
  654. return result;
  655. }
  656. /* print usage help */
  657. void print_help(void){
  658. /*print_revision(progname,"$Revision$");*/
  659. printf("Copyright (c) 2001-2004 Ethan Galstad (nagios@nagios.org)\n\n");
  660. printf("This plugin tests the availability of DHCP servers on a network.\n\n");
  661. print_usage();
  662. printf
  663. ("\nOptions:\n"
  664. " -s, --serverip=IPADDRESS\n"
  665. " IP address of DHCP server that we must hear from\n"
  666. " -r, --requestedip=IPADDRESS\n"
  667. " IP address that should be offered by at least one DHCP server\n"
  668. " -t, --timeout=INTEGER\n"
  669. " Seconds to wait for DHCPOFFER before timeout occurs\n"
  670. " -i, --interface=STRING\n"
  671. " Interface to to use for listening (i.e. eth0)\n"
  672. " -v, --verbose\n"
  673. " Print extra information (command-line use only)\n"
  674. " -h, --help\n"
  675. " Print detailed help screen\n"
  676. " -V, --version\n"
  677. " Print version information\n\n"
  678. );
  679. /*support();*/
  680. return;
  681. }
  682. /* prints usage information */
  683. void print_usage(void){
  684. printf("Usage: %s [-s serverip] [-r requestedip] [-t timeout] [-i interface]\n",progname);
  685. printf(" %s --help\n",progname);
  686. printf(" %s --version\n",progname);
  687. return;
  688. }
  689. /* process command-line arguments */
  690. int process_arguments(int argc, char **argv){
  691. int c;
  692. if(argc<1)
  693. return ERROR;
  694. c=0;
  695. while((c+=(call_getopt(argc-c,&argv[c])))<argc){
  696. /*
  697. if(is_option(argv[c]))
  698. continue;
  699. */
  700. }
  701. return validate_arguments();
  702. }
  703. int call_getopt(int argc, char **argv){
  704. int c=0;
  705. int i=0;
  706. struct in_addr ipaddress;
  707. #ifdef HAVE_GETOPT_H
  708. int option_index = 0;
  709. static struct option long_options[] =
  710. {
  711. {"serverip", required_argument,0,'s'},
  712. {"requestedip", required_argument,0,'r'},
  713. {"timeout", required_argument,0,'t'},
  714. {"interface", required_argument,0,'i'},
  715. {"verbose", no_argument, 0,'v'},
  716. {"version", no_argument, 0,'V'},
  717. {"help", no_argument, 0,'h'},
  718. {0,0,0,0}
  719. };
  720. #endif
  721. while(1){
  722. #ifdef HAVE_GETOPT_H
  723. c=getopt_long(argc,argv,"+hVvt:s:r:t:i:",long_options,&option_index);
  724. #else
  725. c=getopt(argc,argv,"+?hVvt:s:r:t:i:");
  726. #endif
  727. i++;
  728. if(c==-1||c==EOF||c==1)
  729. break;
  730. switch(c){
  731. case 'w':
  732. case 'r':
  733. case 't':
  734. case 'i':
  735. i++;
  736. break;
  737. default:
  738. break;
  739. }
  740. switch(c){
  741. case 's': /* DHCP server address */
  742. if(inet_aton(optarg,&ipaddress))
  743. add_requested_server(ipaddress);
  744. /*
  745. else
  746. usage("Invalid server IP address\n");
  747. */
  748. break;
  749. case 'r': /* address we are requested from DHCP servers */
  750. if(inet_aton(optarg,&ipaddress)){
  751. requested_address=ipaddress;
  752. request_specific_address=TRUE;
  753. }
  754. /*
  755. else
  756. usage("Invalid requested IP address\n");
  757. */
  758. break;
  759. case 't': /* timeout */
  760. /*
  761. if(is_intnonneg(optarg))
  762. */
  763. if(atoi(optarg)>0)
  764. dhcpoffer_timeout=atoi(optarg);
  765. /*
  766. else
  767. usage("Time interval must be a nonnegative integer\n");
  768. */
  769. break;
  770. case 'i': /* interface name */
  771. strncpy(network_interface_name,optarg,sizeof(network_interface_name)-1);
  772. network_interface_name[sizeof(network_interface_name)-1]='\x0';
  773. break;
  774. case 'V': /* version */
  775. /*print_revision(progname,"$Revision$");*/
  776. exit(STATE_OK);
  777. case 'h': /* help */
  778. print_help();
  779. exit(STATE_OK);
  780. case '?': /* help */
  781. /*usage("Invalid argument\n");*/
  782. break;
  783. default:
  784. break;
  785. }
  786. }
  787. return i;
  788. }
  789. int validate_arguments(void){
  790. return OK;
  791. }