pinghandler.h

Go to the documentation of this file.

/*
** Copyright (C) 2004 Russell Leighton
**
** This program is free software; you can redistribute it and/or modify
** it under the terms of the GNU General Public License as published by
** the Free Software Foundation; either version 2 of the License, or
** (at your option) any later version.
**
** This program is distributed in the hope that it will be useful,
** but WITHOUT ANY WARRANTY; without even the implied warranty of
** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
** GNU General Public License for more details.
**
** You should have received a copy of the GNU General Public License
** along with this program; if not, write to the Free Software
** Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*/




#ifndef __AWHANDLER_PING__
#define __AWHANDLER_PING__

#include "sysnet.h"
#include "monitor.h"
#include "wire.h"

/*
Changes:

02/18/04  Russell Leighton
Ported to handler

04/16/02  Russell Leighton
Made stateful.

03/08/02  Russell Leighton
Added triptime and packets events.

12/28/01 Russell Leighton
Added 'maxretries' to handler.

*/

typedef struct {

  aw_event_sig_t
   connect,
   noconnect,
   triptime,
   packets;

  u_int32_t
   statefull;                    /* if non-zero then connect/noconnect events will be statefull,
                                    meaning you only get events on transitions from connect <-> noconnect
                                  */

} aw_pinghandler_events_t;

typedef enum {

  AW_PINGHANDLER_IDLE,               /* not doing anything */
  AW_PINGHANDLER_WAIT_READ,          /* waiting on a read() */
  AW_PINGHANDLER_DONE_READ,          /* done read */

} aw_pinghandler_state_cd_t;


typedef struct {

  aw_pinghandler_state_cd_t
   state_cd;

  aw_event_t
   *current_event;

  int32_t
   sfd;

  /* marks start of connection */
  aw_timestamp_t
   starttime;

  /* how many times have I tried */
  u_int32_t
   tries;

  /* 1 if last handler could connect, -1 if could noconnect */
  int32_t
   connect;

} aw_pinghandler_state_t;

typedef struct {

  aw_handler_t 
    handler_header;

  aw_pinghandler_state_t
   state;

  aw_pinghandler_events_t
   events;

  struct sockaddr_in
   whereto_addr;

  /* used for timeout callbacks */
  aw_address_t
   timeout_event_id;

  /* sched for timeout alarm */
  aw_alarm_sched_t
   timeout_sched;

  /* number of times to try before giving up , if 0 then try only 1 time */
  u_int32_t
   maxretries;

  byte_t
   *host;

} aw_pinghandler_t ;

aw_pinghandler_t *aw_create_pinghandler(const aw_pinghandler_events_t *events,
                                        const byte_t *hostname,
                                        aw_timestamp_t timeout,
                                        u_int32_t maxretries,
                                        int32_t (*regevent)(aw_handler_t *h, aw_address_t *eventid, u_int32_t index),
                                        int32_t (*regmaskevent)(aw_handler_t *h, aw_address_t *eventid, u_int32_t index),
                                        const aw_alarm_sched_t *sched,
                                        aw_logger_t *logger
                                        );

void aw_free_pinghandler(aw_pinghandler_t *p);

aw_handler_t *aw_wire_pinghandler(aw_wire_mkhandler_args_t *args);

#endif

Aware 0.11.1 Copyright (C) 1998-2005 Russell Leighton (russ@elegant-software.com)