model.h

Go to the documentation of this file.

/*
** Copyright (C) 2005 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 __AWMODEL__
#define __AWMODEL__

#include "awsqlite.h"

#include "monitor.h"

/*\@{*/


typedef struct {

  /* key into aw_user table */
  u_int32_t
   userid;

  /* read only? */
  u_int32_t
   ro;

} aw_model_userhandle_t;

#define AW_MODEL_NETMESSAGE_DEFAULT_PORT 9999

typedef enum {
  AW_MODEL_INTERFACE_HANDLER = 1,
  AW_MODEL_SERVICE_HANDLER,
} aw_model_netmon_class_t;


typedef struct aw_model_netmon_s {

  /* linked list */
  struct aw_model_netmon_s
   *next;

  /* type of handler */
  aw_model_netmon_class_t
   handler_class;

  /* id in database */
  u_int32_t
   id;

  /* ptr to handler */
  aw_wire_obj_t
   *h;

} aw_model_netmon_t;

typedef struct {

  byte_t *sql;
  
  sqlite3_stmt *compiled;

} aw_model_stmt_t ;

typedef struct {

  /* options for monitoring */
  struct {

    /* network monitoring */
    struct {

      /* info for listening for network events */
      struct {

        u_int32_t
        port;

        aw_ip_addr_t
        bind;

      } message;

    } net;

    /* alert processing */
    struct {
 
      /* time limit in minutes before an alert needs escalation (default to 30) */
      u_int32_t
       timelimit;

    } alert_escalator;

  } sysmon;

} aw_model_options_t;

typedef struct {

  aw_monitor_t 
   *mon;

  aw_model_userhandle_t 
   superuser;

  /* directory structure for persistence */
   struct { 

    const byte_t *root; 
    const byte_t *log;  
    const byte_t *rrd;  
  } dirs;

  /* monitoring */
  struct {

    /* network monitoring */
    struct {

      /* non-zero if network monitoring has been disabled */
      u_int32_t disabled; 

      /* info for listening for network events */
      struct {

        u_int32_t
        port;

        aw_ip_addr_t
        bind;

      } message;

      /* masks for all interface and service events */
      struct {

        aw_address_t
          interface_event,
          service_event,
          connect_event,
          noconnect_event,
          upservice_event,
          downservice_event,
          triptime_event;

      } event_masks;

      /* addresses for other events */
      struct {

        aw_address_t
          discover_event,
          message_event,
          mdns_event;

      } event_addr;

      /* process id of discovery process */
      int32_t 
       discovery_pid;  

      /* run network disovery on a clock */
      aw_handler_t
       discovery;

      /* takes interface events and updates model */
      aw_handler_t
       interface_event_rx;

      /* takes service events and updates model */
      aw_handlerid_t
       mdns_probeid;
      aw_handler_t
       service_event_rx;

      /* takes mdns events and updates model */
      aw_handler_t
       mdns_event_rx;

      /* takes message events and updates model */
      aw_handler_t
       message_event_rx;

      /* list of active handlers */
      aw_model_netmon_t
       *probes;

    } net;

    /* alert processing */
    struct {

      /* time limit in minutes before an alert needs escalation */
      u_int32_t
       timelimit;
 
      aw_handler_t
       poller;

    } alert_escalator;

  } sysmon;

  /* database info */
  struct {

    aw_sqlite_cinfo_t  
     cinfo;

    aw_sqlite_state_t  
     state;

    /* holds prepared statements */
    struct {
#include "model_pstmt.h"
    } stmts;

  } db;

} aw_model_t;

typedef struct {

  /* handle */
  aw_model_userhandle_t handle;

  byte_t loginid[16];
  byte_t password[33];
  byte_t lastname[16];
  byte_t firstname[16];
  byte_t notifymode[16];
  u_int32_t notify;
  u_int32_t active;
  u_int32_t deleted;

} aw_model_user_t;


typedef struct aw_model_user_listing_s {

  struct {

    /* iterator: return non-zero on data, 0 on done and -1 on error */
    int32_t (*next)(struct aw_model_user_listing_s *);

    /* private */
    struct {

      aw_model_t *model;

      u_int32_t deleted; /* if non-zero then return records marked deleted */

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

  struct {
    u_int32_t userid;
    byte_t loginid[16];
    byte_t lastname[16];
    byte_t firstname[16];
    u_int32_t active;
    u_int32_t deleted;
  } listing;

} aw_model_user_listing_t;


typedef struct {

  u_int32_t userid; 

  byte_t
    street1[51],
    street2[51],
    city[31],
    state[3],
    zip[11],
    country[16],
    homephone[16],
    workphone[16],
    fax[16],
    email[51],
    mobile[16],
    pager[16],
    notes[256];

  u_int32_t id;

} aw_model_userinfo_t;

typedef struct {

    u_int32_t groupid;
    byte_t name[26];
    byte_t desc[256];
    u_int32_t deleted;

} aw_model_group_t;

typedef struct  aw_model_group_listing_s {

  struct {

    /* iterator: return non-zero on data, 0 on done and -1 on error */
    int32_t (*next)(struct aw_model_group_listing_s *);

    /* private */
    struct {

      aw_model_t *model;

      u_int32_t deleted; /* if non-zero then return records marked deleted */

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

  aw_model_group_t
   listing;

} aw_model_group_listing_t;


typedef struct aw_model_group_slisting_s {

  struct {

    /* iterator: return non-zero on data, 0 on done and -1 on error */
    int32_t (*next)(struct aw_model_group_slisting_s *);

    /* private */
    struct {

      aw_model_stmt_t *stmt;

      aw_model_t *model;

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

  u_int32_t groupid;
  byte_t name[26];

} aw_model_group_slisting_t;

typedef struct aw_model_user_slisting_s {

  struct {

    /* iterator: return non-zero on data, 0 on done and -1 on error */
    int32_t (*next)(struct aw_model_user_slisting_s *);

    /* private */
    struct {

      aw_model_t *model;

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

  u_int32_t userid;
  byte_t loginid[16];

} aw_model_user_slisting_t;


typedef struct aw_model_user2group_s {

  struct {

    /* iterator: return non-zero on success, 0 on done and -1 on error */
    int32_t (*associate)(struct aw_model_user2group_s *, u_int32_t groupid);

    /* call this when done to commit */
    void (*commit)(struct aw_model_user2group_s *);

    /* call this when done to rollback */
    void (*rollback)(struct aw_model_user2group_s *);

    /* private */
    struct {

      aw_model_t *model;

      u_int32_t userid;

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

} aw_model_user2group_t;


typedef struct aw_model_group2user_s {

  struct {

    /* iterator: return non-zero on success, 0 on done and -1 on error */
    int32_t (*associate)(struct aw_model_group2user_s *, u_int32_t groupid);

    /* call this when done to commit */
    void (*commit)(struct aw_model_group2user_s *);

    /* call this when done to rollback */
    void (*rollback)(struct aw_model_group2user_s *);

    /* private */
    struct {

      aw_model_t *model;

      u_int32_t groupid;

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

} aw_model_group2user_t;


typedef struct {

    u_int32_t nodegrpid;
    byte_t name[26];
    byte_t desc[256];
    u_int32_t deleted;

} aw_model_nodegrp_t;

typedef struct aw_model_nodegrp_listing_s {

  struct {

    /* iterator: return non-zero on data, 0 on done and -1 on error */
    int32_t (*next)(struct aw_model_nodegrp_listing_s *);

    /* private */
    struct {

      aw_model_t *model;

      u_int32_t deleted; /* if non-zero then return records marked deleted */

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

  u_int32_t nodegrpid;
  byte_t name[65];
  u_int32_t outage;
  u_int32_t deleted;

} aw_model_nodegrp_listing_t;

typedef struct aw_model_node2nodegrp_s {

  struct {

    /* iterator: return non-zero on success, 0 on done and -1 on error */
    int32_t (*associate)(struct aw_model_node2nodegrp_s *, u_int32_t nodegrpid);

    /* call this when done to commit */
    void (*commit)(struct aw_model_node2nodegrp_s *);

    /* call this when done to rollback */
    void (*rollback)(struct aw_model_node2nodegrp_s *);

    /* private */
    struct {

      aw_model_t *model;

      u_int32_t nodeid;

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

} aw_model_node2nodegrp_t;


typedef struct aw_model_nodegrp2node_s {

  struct {

    /* iterator: return non-zero on success, 0 on done and -1 on error */
    int32_t (*associate)(struct aw_model_nodegrp2node_s *, u_int32_t nodeid);

    /* call this when done to commit */
    void (*commit)(struct aw_model_nodegrp2node_s *);

    /* call this when done to rollback */
    void (*rollback)(struct aw_model_nodegrp2node_s *);

    /* private */
    struct {

      aw_model_t *model;

      u_int32_t nodegrpid;

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

} aw_model_nodegrp2node_t;

typedef struct aw_model_node2group_s {

  struct {

    /* iterator: return non-zero on success, 0 on done and -1 on error */
    int32_t (*associate)(struct aw_model_node2group_s *, u_int32_t nodeid);

    /* call this when done to commit */
    void (*commit)(struct aw_model_node2group_s *);

    /* call this when done to rollback */
    void (*rollback)(struct aw_model_node2group_s *);

    /* private */
    struct {

      aw_model_t *model;

      u_int32_t nodeid;

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

} aw_model_node2group_t;


typedef struct {
  u_int32_t nodeid;
  byte_t name[65];
  u_int32_t outage;
  u_int32_t active;
  u_int32_t deleted;
} aw_model_node_t;

typedef struct {
  u_int32_t nodeid;
  byte_t username[65];
  byte_t nmbname[65];
  byte_t snmpname[65];
  byte_t mdnsname[65];
  byte_t ipname[65];
  byte_t desc[256];
  u_int32_t active;
  u_int32_t deleted;
} aw_model_node_detail_t;

typedef struct aw_model_node_listing_s {

  struct {

    /* iterator: return non-zero on data, 0 on done and -1 on error */
    int32_t (*next)(struct aw_model_node_listing_s *);

    /* private */
    struct {

      aw_model_t *model;

      aw_model_stmt_t *query;

      u_int32_t deleted; /* if non-zero then return records marked deleted */

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

  aw_model_node_t
   listing;

} aw_model_node_listing_t;

typedef struct aw_model_node_slisting_s {

  struct {

    /* iterator: return non-zero on data, 0 on done and -1 on error */
    int32_t (*next)(struct aw_model_node_slisting_s *);

    /* private */
    struct {

      aw_model_t *model;

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

  u_int32_t nodeid;
  byte_t name[65];

} aw_model_node_slisting_t;

typedef struct {

    u_int32_t 
      nodeid;
    byte_t
      manufacturer[65],
      vendor[65],
      modelnumber[65],
      serialnumber[65],
      circuitid[65],
      assetnumber[65],
      os[65],
      rack[65],
      slot[65],
      port[65],
      region[65],
      division[65],
      department[65],
      address1[256],
      address2[256],
      city[65],
      state[65],
      country[65],
      zip[65],
      building[65],
      floor[65],
      room[65],
      vendorphone[65],
      vendorfax[65],
      vendoremail[65],
      vendorim[65],
      vendorurl[65],
      vendorassetnumber[65],
      dateinstalled[65],
      lease[65],
      leaseexpires[65],
      supportphone[65],
      maintcontract[65],
      maintcontractexpires[65],
      comment[256];  

} aw_model_nodeasset_t;


typedef struct { 

  byte_t prettyname[131];

} aw_model_interface_name_t;

/* Calc cron size (worst case):

min = ( 10 + 50*2 )*2 - 1  + 1 = 220
hr = ( 10 + 14*2 )*2 - 1  + 1 = 76
dom = ( 9 + 22*2 )*2 - 1  + 1 = 106
mon = ( 9 + 3*2 )*2 - 1  + 1 = 30
dow = ( 7 )*2 - 1 = 13

total = 445 + 1
*/

typedef struct { 

  u_int32_t interfaceid;
  aw_model_interface_name_t name;
  u_int32_t up;
  u_int32_t outage;
  u_int32_t snmp;
  u_int32_t active;
  u_int32_t deleted;

  byte_t ip[65];
  byte_t snmp_community[65];
  u_int32_t timeout;
  u_int32_t cycle;
  byte_t handlercron[446]; 
  byte_t maintcron[446];
  u_int32_t perf;
  u_int32_t traffic;

} aw_model_interface_detail_t;

typedef struct aw_model_interface_listing_s {

  struct {

    /* iterator: return non-zero on data, 0 on done and -1 on error */
    int32_t (*next)(struct aw_model_interface_listing_s *);

    /* private */
    struct {

      aw_model_t *model;

      u_int32_t deleted; /* if non-zero then return records marked deleted */

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

  /*
  struct {
    u_int32_t interfaceid;
    aw_model_interface_name_t name;
    u_int32_t up;
    u_int32_t outage;
    u_int32_t snmp;
    u_int32_t active;
    u_int32_t deleted;
    } */

  aw_model_interface_detail_t listing;

} aw_model_interface_listing_t;

typedef struct aw_model_interface_netmon_listing_s {

  struct {

    /* iterator: return non-zero on data, 0 on done and -1 on error */
    int32_t (*next)(struct aw_model_interface_netmon_listing_s *);

    /* private */
    struct {

      aw_model_t *model;

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

  aw_model_interface_detail_t listing;

} aw_model_interface_netmon_listing_t;


typedef struct { 
  byte_t prettyname[131];
} aw_model_service_name_t;

typedef struct {

    u_int32_t serviceid;
    aw_model_service_name_t name;
    u_int32_t up;
    u_int32_t active;
    u_int32_t deleted;

    byte_t service[33];
    byte_t ip[65];
    u_int32_t port;
    byte_t proto[33];
    byte_t handler[33];
    u_int32_t timeout;
    u_int32_t cycle;
    byte_t handlercron[446];
    byte_t maintcron[446];
    u_int32_t perf;

} aw_model_service_detail_t;

typedef struct aw_model_service_listing_s {

  struct {

    /* iterator: return non-zero on data, 0 on done and -1 on error */
    int32_t (*next)(struct aw_model_service_listing_s *);

    /* private */
    struct {

      aw_model_t *model;

      u_int32_t deleted; /* if non-zero then return records marked deleted */

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

  aw_model_service_detail_t listing;

} aw_model_service_listing_t;

typedef struct aw_model_service_netmon_listing_s {

  struct {

    /* iterator: return non-zero on data, 0 on done and -1 on error */
    int32_t (*next)(struct aw_model_service_netmon_listing_s *);

    /* private */
    struct {

      aw_model_t *model;

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

  aw_model_service_detail_t listing;

} aw_model_service_netmon_listing_t;

typedef struct aw_model_service2port_listing_s {

  struct {

    /* iterator: return non-zero on data, 0 on done and -1 on error */
    int32_t (*next)(struct aw_model_service2port_listing_s *);

    /* private */
    struct {

      aw_model_t *model;

      u_int32_t deleted; /* if non-zero then return records marked deleted */

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

  struct {
    u_int32_t port;
    byte_t proto[33];
    byte_t service[33];
  } listing;

} aw_model_service2port_listing_t;

typedef struct {

  byte_t kw[65];
  byte_t val[65];
  byte_t note[129];

} aw_model_setting_t;

typedef struct aw_model_subnet_listing_s {

  struct {

    /* iterator: return non-zero on data, 0 on done and -1 on error */
    int32_t (*next)(struct aw_model_subnet_listing_s *);

    /* private */
    struct {

      aw_model_t *model;

      u_int32_t deleted; /* if non-zero then return records marked deleted */

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

  struct {
    u_int32_t subnetid;
    byte_t netmask[65];
    u_int32_t active;
    u_int32_t deleted;
  } listing;

} aw_model_subnet_listing_t;

typedef struct aw_model_event_slisting_s {

  struct {

    /* iterator: return non-zero on data, 0 on done and -1 on error */
    int32_t (*next)(struct aw_model_event_slisting_s *);

    /* private */
    struct {

      aw_model_t *model;

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

  byte_t dt[20];
  int32_t type;      // 0 => Down , 1 => Up , -1 => message
  byte_t msg[513];

} aw_model_event_slisting_t;


typedef struct aw_model_alert_slisting_s {

  struct {

    /* iterator: return non-zero on data, 0 on done and -1 on error */
    int32_t (*next)(struct aw_model_alert_slisting_s *);

    /* private */
    struct {

      aw_model_t *model;

    } state;

    /* NOTE: if we want more than 1
       of these in flight at a time, 
       then the pstmt needs to move
       here from the model */

  } iter ;

  byte_t msg[513];

} aw_model_alert_slisting_t;

/* --- core.c --- */

int32_t aw_model_execute_stmt(aw_model_t *model, aw_model_stmt_t *stmt);

void aw_model_reset_stmt(aw_model_t *model, aw_model_stmt_t *stmt);

void aw_model_finalize_stmt(aw_model_t *model, aw_model_stmt_t *stmt);

int32_t aw_model_open(const byte_t *db, aw_monitor_t *mon, const aw_model_options_t *options, aw_model_t *model);

void aw_model_close(aw_model_t *model);

/* --- discover.c --- */

int32_t aw_model_discover(aw_model_t *model, const aw_model_userhandle_t *handle);

int32_t aw_model_run_discover(aw_model_t *model, const aw_model_userhandle_t *handle);


int32_t aw_model_discover_running(aw_model_t *model, const aw_model_userhandle_t *handle);

void aw_model_schedule_discovery(aw_model_t *model, const aw_model_userhandle_t *handle, const byte_t *mode);

/* --- auth.c --- */

const aw_model_userhandle_t * aw_model_authenticate(aw_model_t *model, const byte_t *userid, 
                                                    const byte_t *password);

const aw_model_userhandle_t *aw_model_CHAP(aw_model_t *model, const byte_t *userid, 
                                           u_int32_t prefix, const byte_t *response);

/* --- user.c --- */

const aw_model_userhandle_t *aw_model_make_handle(u_int32_t userid, u_int32_t ro);

void aw_model_free_handle(const aw_model_userhandle_t *handle);

int32_t aw_model_user_create(aw_model_t *model, const aw_model_userhandle_t *handle, const byte_t *loginid);

int32_t aw_model_user_query(aw_model_t *model, const aw_model_userhandle_t *handle,
                            u_int32_t userid, aw_model_user_t *user);

int32_t aw_model_user_list(aw_model_t *model, const aw_model_userhandle_t *handle,
                           u_int32_t deleted, aw_model_user_listing_t *user_listing);

int32_t aw_model_user_update(aw_model_t *model, const aw_model_userhandle_t *handle,
                             const aw_model_user_t *updated_user);

int32_t aw_model_userinfo_query(aw_model_t *model, const aw_model_userhandle_t *handle,
                                u_int32_t userid, aw_model_userinfo_t *userinfo);

int32_t aw_model_userinfo_update(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                 const aw_model_userinfo_t *updated_userinfo);

/* --- group.c --- */

int32_t aw_model_group_create(aw_model_t *model, const aw_model_userhandle_t *handle, 
                              const byte_t *groupname);

int32_t aw_model_group_query(aw_model_t *model, const aw_model_userhandle_t *handle,
                             u_int32_t groupid, aw_model_group_t *group);

int32_t aw_model_group_list(aw_model_t *model, const aw_model_userhandle_t *handle,
                            u_int32_t deleted, aw_model_group_listing_t *group_listing);

int32_t aw_model_group_user_slist(aw_model_t *model, const aw_model_userhandle_t *handle,
                                  u_int32_t userid, aw_model_group_slisting_t *group_slisting);

int32_t aw_model_group_notuser_slist(aw_model_t *model, const aw_model_userhandle_t *handle,
                                     u_int32_t userid, aw_model_group_slisting_t *group_slisting);

int32_t aw_model_group_node_slist(aw_model_t *model, const aw_model_userhandle_t *handle,
                                  u_int32_t nodeid, aw_model_group_slisting_t *group_slisting);

int32_t aw_model_group_notnode_slist(aw_model_t *model, const aw_model_userhandle_t *handle,
                                     u_int32_t nodeid, aw_model_group_slisting_t *group_slisting);

int32_t aw_model_user_group_slist(aw_model_t *model, const aw_model_userhandle_t *handle,
                                  u_int32_t groupid, aw_model_user_slisting_t *user_slisting);

int32_t aw_model_user_notgroup_slist(aw_model_t *model, const aw_model_userhandle_t *handle,
                                     u_int32_t groupid, aw_model_user_slisting_t *user_slisting);

int32_t aw_model_group_update(aw_model_t *model, const aw_model_userhandle_t *handle, 
                              const aw_model_group_t *updated_group);

int32_t aw_model_user2groups(aw_model_t *model, const aw_model_userhandle_t *handle, 
                             u_int32_t userid, aw_model_user2group_t *user2group);


int32_t aw_model_group2users(aw_model_t *model, const aw_model_userhandle_t *handle, 
                             u_int32_t groupid, aw_model_group2user_t *group2user);

/* --- node.c --- */

int32_t aw_model_node_create(aw_model_t *model, const aw_model_userhandle_t *handle, 
                             const byte_t *name);

int32_t aw_model_node_query(aw_model_t *model, const aw_model_userhandle_t *handle, 
                            u_int32_t nodeid, aw_model_node_detail_t *nodedetail);

int32_t aw_model_node_update(aw_model_t *model, const aw_model_userhandle_t *handle, 
                             const aw_model_node_detail_t *updated_nodedetail);

int32_t aw_model_nodegrp_create(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                const byte_t *name);

int32_t aw_model_nodegrp_update(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                const aw_model_nodegrp_t *updated_nodegrp);

int32_t aw_model_nodegrp_query(aw_model_t *model, const aw_model_userhandle_t *handle, 
                               u_int32_t nodegrpid, aw_model_nodegrp_t *nodegrp);

int32_t aw_model_nodegrp_list(aw_model_t *model, const aw_model_userhandle_t *handle, 
                              u_int32_t deleted, aw_model_nodegrp_listing_t *nodegrp_listing);

int32_t aw_model_node_list(aw_model_t *model, const aw_model_userhandle_t *handle, 
                           u_int32_t deleted, aw_model_node_listing_t *node_listing);

int32_t aw_model_node_outages(aw_model_t *model, const aw_model_userhandle_t *handle, 
                              u_int32_t limit, aw_model_node_listing_t *node_listing);

int32_t aw_model_node_list_by_nodegrp(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                      u_int32_t nodegrpid,
                                      u_int32_t deleted, aw_model_node_listing_t *node_listing);

int32_t aw_model_nodegrp2nodes(aw_model_t *model, const aw_model_userhandle_t *handle, 
                               u_int32_t append, u_int32_t nodegrpid, 
                               aw_model_nodegrp2node_t *nodegrp2node);

int32_t aw_model_node_nodegrp_slist(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                    u_int32_t nodegrpid, aw_model_node_slisting_t *node_slisting);

int32_t aw_model_node_notnodegrp_slist(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                       u_int32_t nodegrpid, aw_model_node_slisting_t *node_slisting);

int32_t aw_model_nodegrp_apply_active(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                      u_int32_t nodegrpid, u_int32_t val);

int32_t aw_model_nodegrp_apply_deleted(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                       u_int32_t nodegrpid, u_int32_t val);

int32_t aw_model_node2groups(aw_model_t *model, const aw_model_userhandle_t *handle, 
                             u_int32_t nodeid, aw_model_node2group_t *node2group);


/* --- nodeasset.c --- */

int32_t aw_model_nodeasset_query(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                 u_int32_t nodeid, aw_model_nodeasset_t *nodeasset);

int32_t aw_model_nodeasset_update(aw_model_t *model, const aw_model_userhandle_t *handle,
                                  u_int32_t nodeid, const aw_model_nodeasset_t *nodeasset);

/* --- interface.c --- */

int32_t aw_model_interface_create(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                  u_int32_t nodeid, const byte_t *ip);

int32_t aw_model_interface_update(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                  const aw_model_interface_detail_t *updated_interfacedetail);

int32_t aw_model_interface_name_query(aw_model_t *model, const aw_model_userhandle_t *handle,
                                      u_int32_t interfaceid, 
                                      aw_model_interface_name_t *interface_name);

int32_t aw_model_interface_query(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                 u_int32_t interfaceid, aw_model_interface_detail_t *interfacedetail);

int32_t aw_model_interface_list_by_node(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                        u_int32_t nodeid,
                                        u_int32_t deleted, 
                                        aw_model_interface_listing_t *interface_listing);

int32_t aw_model_interface_netmon_list(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                       aw_model_interface_netmon_listing_t *interface_netmon_listing);

/* --- service.c --- */

int32_t aw_model_service_create(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                u_int32_t interfaceid, const byte_t *service);

int32_t aw_model_service_unique(aw_model_t *model, const aw_model_userhandle_t *handle, 
                               u_int32_t serviceid,  byte_t *ip, u_int32_t port, byte_t *proto);

int32_t aw_model_service_update(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                  const aw_model_service_detail_t *updated_servicedetail);

int32_t aw_model_service_name_query(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                    u_int32_t serviceid, 
                                    aw_model_service_name_t *service_name);

int32_t aw_model_service_id_query(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                  const byte_t *ip, u_int32_t port);

int32_t aw_model_service_query(aw_model_t *model, const aw_model_userhandle_t *handle, 
                               u_int32_t serviceid, aw_model_service_detail_t *servicedetail);

int32_t aw_model_service_list_by_interface(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                           u_int32_t interfaceid,
                                           u_int32_t deleted, aw_model_service_listing_t *service_listing);

int32_t aw_model_service_netmon_list(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                     aw_model_service_netmon_listing_t *service_netmon_listing);
int32_t aw_model_service2port_list(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                   aw_model_service2port_listing_t *service2port_listing);

/* --- settings.c --- */

int32_t aw_model_settings_query(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                const byte_t *kw, aw_model_setting_t *setting);

int32_t aw_model_settings_update(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                 const byte_t *kw, const byte_t *val);

/* --- subnet.c --- */

int32_t aw_model_subnet_create(aw_model_t *model, const aw_model_userhandle_t *handle, const byte_t *netmask);

int32_t aw_model_subnet_list(aw_model_t *model, const aw_model_userhandle_t *handle, 
                             u_int32_t deleted, aw_model_subnet_listing_t *subnet_listing);

int32_t aw_model_subnet_update(aw_model_t *model, const aw_model_userhandle_t *handle, 
                               u_int32_t subnetid, u_int32_t active, u_int32_t deleted);

/* --- event.c --- */

int32_t aw_model_ia_event_insert(aw_model_t *model, const aw_model_userhandle_t *handle,
                                 u_int32_t interface_id, u_int32_t up, 
                                 u_int32_t priority, aw_timestamp_t tstamp);

int32_t aw_model_sa_event_insert(aw_model_t *model, const aw_model_userhandle_t *handle,
                                 u_int32_t service_id, u_int32_t up, 
                                 const byte_t *type, u_int32_t priority,aw_timestamp_t tstamp);


int32_t aw_model_mdns_event_insert(aw_model_t *model, const aw_model_userhandle_t *handle,
                                     const byte_t *ip, u_int32_t port, const byte_t *service,
                                     const byte_t *protocol, const byte_t *name, u_int32_t up, 
                                     u_int32_t priority, aw_timestamp_t tstamp);


int32_t aw_model_nm_event_insert(aw_model_t *model, const aw_model_userhandle_t *handle,
                                 const byte_t *nodename, const byte_t *msg, 
                                 u_int32_t priority,aw_timestamp_t tstamp);

int32_t aw_model_event_today_slist(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                   u_int32_t limit,
                                   aw_model_event_slisting_t *event_slisting);

/* --- alert.c --- */

int32_t aw_model_interface_alert(aw_model_t *model, const aw_model_userhandle_t *handle,
                                 u_int32_t interface_id, u_int32_t up,aw_timestamp_t tstamp);

int32_t aw_model_service_alert(aw_model_t *model, const aw_model_userhandle_t *handle,
                               u_int32_t service_id, u_int32_t up, aw_timestamp_t tstamp);

int32_t aw_model_message_alert(aw_model_t *model, const aw_model_userhandle_t *handle,
                               const byte_t *nodename, const byte_t *msg, aw_timestamp_t tstamp);

int32_t aw_model_escalate_alert(aw_model_t *model, const aw_model_userhandle_t *handle);

int32_t aw_model_alert_user_slist(aw_model_t *model, const aw_model_userhandle_t *handle, 
                                  u_int32_t user_id, u_int32_t limit,
                                  aw_model_alert_slisting_t *alert_slisting);

/* --- netmon.c --- */

void aw_model_netmon_remove_probe(aw_model_t *model, 
                                  aw_model_netmon_class_t handler_class,
                                  u_int32_t id);

int32_t aw_model_netmon_add_probe_by_name(aw_model_t *model, 
                                          aw_model_netmon_class_t handler_class,
                                          u_int32_t id,
                                          const byte_t *name,
                                          const byte_t *ip,
                                          u_int32_t port,
                                          const byte_t *proto,
                                          const byte_t *handler,
                                          u_int32_t timeout,
                                          u_int32_t cycle,
                                          const byte_t *handlercron, 
                                          const byte_t *maintcron,
                                          u_int32_t perf
                                          );

void aw_model_netmon_init(aw_model_t *model);

u_int32_t aw_model_netmon_is_disabled(aw_model_t *model);

void aw_model_netmon_start(aw_model_t *model);

void aw_model_netmon_stop(aw_model_t *model);

void aw_model_netmon_restart(aw_model_t *model);

void aw_model_netmon_clear(aw_model_t *model);


/*\@}*/

#endif

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