mctxhandler.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_MCTX__
#define __AWHANDLER_MCTX__

#include "monitor.h"

#include "wire.h"

#include "mctxrx.h"

/*

Changes:


*/

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

typedef struct {

  aw_event_sig_t
   sent,                   /* could send file */
   error;                 /* error sending file */

} aw_mctxhandler_events_t;

typedef enum {

  AW_MCTXHANDLER_IDLE,               
  AW_MCTXHANDLER_WRITING,            
  AW_MCTXHANDLER_WAIT_RETX,          
} aw_mctxhandler_state_cd_t;

typedef struct {

  aw_mctxhandler_state_cd_t
   state_cd;

  aw_event_t
   *current_event;

  u_int32_t
   xtnid;

  aw_address_t
   retx_event_id,
   timeout_event_id;

  aw_timestamp_t
   sendfile_tstamp,   /* start of sending file */
   start_retx_timeout;  /* last time we sent a packet in re-transmit phase */

  int32_t
   file_fd,
   mc_fd,
   retx_fd;

  /* space to write packets, max size of a UDP packet */
  byte_t
   message[0xffff]; 
  int32_t
   message_size; /* how much is actually used */

  /* count of block writes that failed */
  u_int32_t
   nblocks_error;

  /* count of block writes re-sent */
  u_int32_t
  nblocks_retx;

  u_int32_t
   nblocks_written;

  /* current file info */
  aw_mctxrx_info_t
   info;

  /* bitvector indicating which blocks have not been read by clients (1), if read then 0 */
  aw_bitvector_t
   *unread_blocks;

} aw_mctxhandler_state_t;


typedef struct {

  aw_handler_t 
    handler_header;

  aw_mctxhandler_state_t
   state;

  aw_mctxhandler_events_t
   events;

  /* address of interface to send multicast packets */
  struct in_addr
   mcast_if_addr;

  /* non-zero if enabling IP_MULTICAST_LOOP */
  u_int32_t
   mcast_loopback;

  /* multicast address to send packets */
  struct sockaddr_in
   mcast_grp_addr;

  /* constant desired write rate in bytes per second */
  u_int64_t
   write_rate;

  /* calibrated delay between writes based on write_rate */
  struct timespec
   write_delay;

  /* max time allowed to succeed per try */
  aw_timestamp_t
   timeout;

  /* message size, must fit in datagram! */
  u_int32_t
   messagesize;

} aw_mctxhandler_t ;


aw_mctxhandler_t *aw_create_mctxhandler(const byte_t *filename,
                                        u_int32_t rate,
                                        u_int32_t messagesize,
                                        const byte_t *mcaddress,
                                        u_int32_t mcport,
                                        const byte_t *mcinterface,
                                        u_int32_t mcloopback,
                                        u_int32_t retxport,
                                        aw_timestamp_t timeout,
                                        const aw_mctxhandler_events_t *events,
                                        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
                                        );

#endif

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