#include "httpd.h"
#include "http_config.h"
#include "http_core.h"
#include "http_log.h"
#include "http_protocol.h"
#include "http_request.h"
#include "http_main.h"
#include "util_script.h"
#include "util_md5.h"
#define MAX_CONNECTS 16
module MODULE_VAR_EXPORT terravision_module;
typedef struct {
TsmConnection connect;
char const *dataset;
} tvmod_state_elem;
static tvmod_state_elem tvmod_state[MAX_CONNECTS];
static int tvmod_curr_state;
static void
tvmod_log_debug( const char *msg, ... )
{
#undef DEBUG
#ifdef DEBUG
va_list ap;
fprintf( stderr, "mod_terravision: " );
va_start( ap, msg );
vfprintf( stderr, msg, ap );
va_end( ap );
fprintf( stderr, "\n" );
#endif
}
static void
tvmod_log_error( request_rec *r, const char *msg, ... )
{
va_list ap;
fprintf( stderr, "mod_terravision: " );
va_start( ap, msg );
vfprintf( stderr, msg, ap );
va_end( ap );
fprintf( stderr, "\n" );
r->content_type = "text/html";
ap_send_http_header(r);
ap_rprintf(r, "Error: %s", msg);
}
static void
tvmod_free_elem( tvmod_state_elem *elem )
{
if ( elem == NULL ) return;
if ( elem->connect ) tsmDisconnect( elem->connect );
if ( elem->dataset ) tsmMemFree( elem->dataset );
elem->connect = NULL;
elem->dataset = NULL;
}
static void
tvmod_init( server_rec *s, pool *p )
{
int i;
/* initialise the array of connection structures to be empty */
tvmod_log_debug( "initialising connection array for pid %d", getpid() );
tvmod_curr_state = 0;
for ( i = 0; i < MAX_CONNECTS; i++ ) {
tvmod_state[i].connect = NULL;
tvmod_state[i].dataset = NULL;
}
}
static void
tvmod_shutdown( server_rec *s, pool *p )
{
int i;
/* disconnect from all of the datasets that we connected to */
tvmod_log_debug( "cleaning up connection array for pid %d", getpid() );
for ( i = 0; i < MAX_CONNECTS; i++ )
tvmod_free_elem( &tvmod_state[i] );
}
static int
tvmod_get_arg( request_rec *r, char const *opt )
{
char buffer[128] = "", *inptr, *outptr = buffer;
if ( ( inptr = strstr( r->args, opt ) ) == NULL )
return 0;
inptr += strlen(opt);
while ( *inptr != '&' && *inptr != '\0' )
*outptr++ = *inptr++;
*outptr++ = '\0';
if ( strlen(buffer) == 0 )
return 1;
return atoi( buffer );
}
static char *
tvmod_get_dataset( request_rec *r )
{
char buffer[512], *ptr;
strcpy( buffer, r->filename );
ptr = buffer + strlen(buffer) - 3;
if ( strcmp( ptr, "/TV" ) == 0 )
*ptr = '\0';
strcat( buffer, r->path_info );
return strdup( buffer );
}
static TsmConnection
tvmod_get_connection( request_rec *r, char const *dataset )
{
int i;
TsmConnection connect;
TsmConnectionParams params;
/* first of all check to see if we have a cached connection */
for ( i = 0; i < MAX_CONNECTS; i++ ) {
if ( tvmod_state[i].dataset ) {
if ( strcmp( tvmod_state[i].dataset, dataset ) == 0 ) {
tvmod_log_debug( "Returning cached connection for pid %d", getpid() );
return tvmod_state[i].connect;
}
}
}
/* otherwise create a new connection */
/* No read multiplicity needed. */
tsmInitParams (¶ms);
tsmSetParam (params, TSM_PARAM_READ_MULTI, 1);
if ( ( connect = tsmConnect( dataset, "r", params ) ) == NULL )
return NULL;
tvmod_log_debug( "Created a new connection for pid %d", getpid() );
/* find a new cache slot for it - is the slot empty? If so, clean it */
if ( tvmod_state[tvmod_curr_state].connect )
tvmod_free_elem( &tvmod_state[tvmod_curr_state] );
/* insert the new data for this connection into the cache */
tvmod_state[tvmod_curr_state].connect = connect;
tvmod_state[tvmod_curr_state].dataset = tsmMemStrdup( dataset );
/* move the cache pointer onto the next element, round robin */
tvmod_curr_state = ( tvmod_curr_state + 1 ) % MAX_CONNECTS;
return connect;
}
static void
tvmod_debug_info(request_rec *r)
{
const char* hostname;
r->content_type = "text/html";
ap_send_http_header(r);
hostname = ap_get_remote_host(r->connection,
r->per_dir_config, REMOTE_NAME);
ap_rputs("\n", r);
ap_rputs("\n", r);
ap_rputs("TerraVision Apache mod debug output\n", r);
ap_rputs("\n", r);
ap_rputs("\n", r);
ap_rprintf(r, "TerraVision Apache Mode Info
\n");
ap_rprintf(r, "unparsed_uri = %s\n", r->unparsed_uri);
ap_rprintf(r, "uri = %s\n", r->uri);
ap_rprintf(r, "filename = %s\n", r->filename);
ap_rprintf(r, "path_info = %s\n", r->path_info);
ap_rprintf(r, "args = %s\n\n", r->args);
ap_rprintf(r, "hostname = %s\n\n", hostname);
ap_rprintf(r, "dataset = %s\n", tvmod_get_dataset( r ) );
ap_rprintf(r, "x = %d\n", tvmod_get_arg( r, "x=" ) );
ap_rprintf(r, "y = %d\n", tvmod_get_arg( r, "y=" ) );
ap_rprintf(r, "level = %d\n", tvmod_get_arg( r, "level=" ) );
ap_rprintf(r, "debug = %d\n", tvmod_get_arg( r, "debug=" ) );
ap_rputs("\n", r);
ap_rputs("\n", r);
}
/* here's the content handler */
static int
terravision_handler(request_rec *r) {
int x, y, level;
char *dataset;
uchar *tileBuffer;
TsmConnection connect;
/* just output an empty page if we are checking for this mod */
if ( tvmod_get_arg( r, "check=" ) ) {
r->content_type = "text/html";
ap_send_http_header(r);
ap_rputs("mod_terravision installed\n", r);
return OK;
}
/* just output some debug information if &debug=& param found */
if ( tvmod_get_arg( r, "debug=" ) ) {
tvmod_debug_info( r );
return OK;
}
/* parse out all of the dataset parameters that we need */
x = tvmod_get_arg( r, "x=" );
y = tvmod_get_arg( r, "y=" );
level = tvmod_get_arg( r, "level=" );
dataset = tvmod_get_dataset( r );
/* try to connect to the dataset (or used a cached connection) */
if ( ( connect = tvmod_get_connection( r, dataset ) ) == NULL ) {
tvmod_log_error( r, "could not connect to dataset" );
free( dataset );
return OK;
}
free( dataset );
/* now allocate a tile buffer and read the requested tile */
if ( tsmAllocReadTile( connect, x, y, level, &tileBuffer ) == FALSE ) {
tvmod_log_error( r, "could not read the specified tile" );
return OK;
}
/* now output the tile to the client */
r->content_type = "text/html";
ap_send_http_header(r);
ap_rwrite(tileBuffer, tsmGet( connect, TSM_TILE_SIZE ), r );
tsmFreeTileBuffer( tileBuffer );
return OK;
}
/* Make the name of the content handler known to Apache */
static handler_rec terravision_handlers[] =
{
{ "terravision-handler", terravision_handler },
{ NULL }
};
/* Tell Apache what phases of the transaction we handle */
module MODULE_VAR_EXPORT terravision_module =
{
STANDARD_MODULE_STUFF,
NULL, /* module initializer */
NULL, /* per-directory config creator */
NULL, /* dir config merger */
NULL, /* server config creator */
NULL, /* server config merger */
NULL, /* command table */
terravision_handlers, /* [7] content handlers */
NULL, /* [2] URI-to-filename translation */
NULL, /* [5] check/validate user_id */
NULL, /* [6] check user_id is valid *here* */
NULL, /* [4] check access by host address */
NULL, /* [7] MIME type checker/setter */
NULL, /* [8] fixups */
NULL, /* [9] logger */
NULL, /* [3] header parser */
tvmod_init, /* process initialization */
tvmod_shutdown, /* process exit/cleanup */
NULL /* [1] post read_request handling */
};