httphandler.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_HTTP__
#define __AWHANDLER_HTTP__

#include "regexmatch.h"

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

/*

Changes:

03/12/04 Russell Leighton
Port to handler

05/04/02  Russell Leighton
Added service,noservice events.

04/16/02  Russell Leighton
Made stateful.

03/08/02 Russell Leighton
Added triptime: support

*/

typedef struct {

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

} aw_httphandler_cevents_t;


typedef struct {

  aw_event_sig_t
   match,                    
   nomatch;                  
} aw_httphandler_revents_t;

typedef enum {

  AW_HTTPHANDLER_IDLE,                    
  AW_HTTPHANDLER_WAIT_HEAD_CONNECT,       
  AW_HTTPHANDLER_WAIT_HEAD_WRITE,         
  AW_HTTPHANDLER_WAIT_HEAD_READ,          
  AW_HTTPHANDLER_WAIT_GET_CONNECT,        
  AW_HTTPHANDLER_WAIT_GET_WRITE,          
  AW_HTTPHANDLER_WAIT_GET_READ,           
  AW_HTTPHANDLER_DONE                     
} aw_httphandler_state_cd_t;

/* should be bigger than the MTU you expect...usually, at least 1500 */
#define AW_HTTPHANDLER_READ_BUFFER_SIZE 4096

/* holds the last value for header (e.g., Last-Modified: Sat, 02 Feb 2002 17:00:14 GMT) */
#define AW_HTTPHANDLER_LASTMODIFIED_BUFFER_SIZE 64


typedef struct {

  aw_httphandler_state_cd_t
   state_cd;

  int32_t
   sfd;

  aw_event_t
   *current_event;

  /* marks start time of connection , used for timeouts */
  aw_timestamp_t
   starttime;

  /* bytes read or written (depending on state_cd) */
  u_int32_t
   nbytes;

  /* -1 on start and the value of Content-Length: (if present in header) plus header size */
  int64_t
   data_left;

  byte_t
   read_buffer[AW_HTTPHANDLER_READ_BUFFER_SIZE];

  time_t
   last_modified;

  /* array 1-1 with the watchers, each val marks
     if a match occured during the handler, could be a bitmap, but I am being lazy */
  u_int32_t
   *match_markers;

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

  /* 1 if last handler could get service, -1 if noservice */
  int32_t
   service;

} aw_httphandler_state_t;


typedef struct {

  aw_httphandler_revents_t
    revents;

  /* regex string */
  const byte_t
   *regex;

  /* holds substitution string, may be NULL */
  const byte_t
   *subst;

} aw_httphandler_regex_t;

typedef struct {

  aw_httphandler_revents_t
    revents;

  /* holds compiled regular expression  */
  regex_t
   pattern;

  /* holds substitution string, may be NULL */
  byte_t
   *subst;

} aw_httphandler_watcher_t;

typedef struct {

  byte_t
   *filename;

  int32_t
   fd;

  aw_event_sig_t
   updated;                    /* done updating mirror */

} aw_httphandler_mirror_t;


typedef struct {

  aw_handler_t 
    handler_header;

  aw_httphandler_state_t
   state;

  aw_httphandler_cevents_t
   cevents;

  struct sockaddr_in
    service_addr;

  /* used for timeout callbacks */
  aw_address_t
   timeout_event_id;

  /* sched for timeout alarm */
  aw_alarm_sched_t
   timeout_sched;

  byte_t
    *url,                      /* full URL */
    *headreq,                  /* HEAD request */
    *getreq;                   /* GET request */

  u_int32_t
   nwatchers;

  aw_httphandler_watcher_t
   *watchers;

  aw_httphandler_mirror_t
   mirror;

} aw_httphandler_t ;


aw_httphandler_t *aw_create_httphandler(const byte_t *url,
                                        const aw_httphandler_cevents_t *cevents,
                                        const aw_timestamp_t timeout,
                                        u_int32_t nregexs,
                                        const aw_httphandler_regex_t *regexs,   
                                        const byte_t *mirror_filename,       
                                        const aw_event_sig_t *mirror_updated,
                                        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_httphandler(aw_httphandler_t *p);


aw_handler_t *aw_wire_httphandler(aw_wire_mkhandler_args_t *args);


#endif

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