httpget.cpp File Reference

#include "httpget.h"

Include dependency graph for httpget.cpp:

Functions
static int	http_get_init (struct soap *soap, struct http_get_data *data, int(*handler)(struct soap *))
static void	http_get_delete (struct soap *soap, struct soap_plugin *p)
static int	http_get_parse (struct soap *soap)
int	http_get (struct soap *soap, struct soap_plugin *p, void *arg)
int	soap_get_connect (struct soap *soap, const char *endpoint, const char *action)
char *	query (struct soap *soap)
char *	query_key (struct soap *soap, char **s)
char *	query_val (struct soap *soap, char **s)
int	soap_encode_string (const char *s, char *t, size_t len)
const char *	soap_decode_string (char *buf, size_t len, const char *val)

Variables
const char	http_get_id [13] = HTTP_GET_ID

Function Documentation

int http_get	(	struct soap *	soap,
		struct soap_plugin *	p,
		void *	arg
	)

{ p->id = http_get_id;
 p->data = (void*)malloc(sizeof(struct http_get_data));
 /* p->fcopy = http_get_copy; obsolete, see note with http_get_copy() */
 p->fdelete = http_get_delete;
 if (p->data)
 if (http_get_init(soap, (struct http_get_data*)p->data, (int (*)(struct soap*))arg))
 { free(p->data); /* error: could not init */
 return SOAP_EOM; /* return error */
 }
 return SOAP_OK;
}

Here is the call graph for this function:

Here is the caller graph for this function:

static void http_get_delete ( struct soap *  soap, struct soap_plugin *  p  )

static

{ free(p->data); /* free allocated plugin data (this function is not called for shared plugin data, but only when the final soap_done() is invoked on the original soap struct) */
}

Here is the caller graph for this function:

static int http_get_init ( struct soap *  soap, struct http_get_data *  data, int(*)(struct soap *)  handler  )

static

{ data->fparse = soap->fparse; /* save old HTTP header parser callback */
 data->fget = handler;
 data->stat_get = 0;
 data->stat_post = 0;
 data->stat_fail = 0;
 memset(data->min, 0, sizeof(data->min));
 memset(data->hour, 0, sizeof(data->hour));
 memset(data->day, 0, sizeof(data->day));
 soap->fparse = http_get_parse; /* replace HTTP header parser callback with ours */
 return SOAP_OK;
}

Here is the call graph for this function:

Here is the caller graph for this function:

static int http_get_parse ( struct soap *  soap )

static

{
#ifndef WITH_LEAN
 time_t t;
 struct tm T, *pT;
#endif
 struct http_get_data *data = (struct http_get_data*)soap_lookup_plugin(soap, http_get_id);
 if (!data)
 return SOAP_PLUGIN_ERROR;
#ifndef WITH_LEAN
 time(&t);
#ifdef HAVE_LOCALTIME_R
 pT = localtime_r(&t, &T);
#else
 pT = localtime(&t);
#endif
 /* updates should be in mutex, but we don't mind some inaccuracy in the count to preserve performance */
 data->day[pT->tm_yday]++;
 data->day[(pT->tm_yday + 1) % 365] = 0;
 data->hour[pT->tm_hour]++;
 data->hour[(pT->tm_hour + 1) % 24] = 0;
 data->min[pT->tm_min]++;
 data->min[(pT->tm_min + 1) % 60] = 0;
#endif
 soap->error = data->fparse(soap); /* parse HTTP header */
 if (soap->error == SOAP_OK)
 { /* update should be in mutex, but we don't mind some inaccuracy in the count */
 data->stat_post++;
 }
 else if (soap->error == SOAP_GET_METHOD && data->fget)
 { soap->error = SOAP_OK;
 if ((soap->error = data->fget(soap))) /* call user-defined HTTP GET handler */
 { /* update should be in mutex, but we don't mind some inaccuracy in the count */
 data->stat_fail++;
 return soap->error;
 }
 /* update should be in mutex, but we don't mind some inaccuracy in the count */
 data->stat_get++;
 return SOAP_STOP; /* stop processing the request and do not return SOAP Fault */
 }
 else
 { /* update should be in mutex, but we don't mind some inaccuracy in the count */
 data->stat_fail++;
 }
 return soap->error;
}

Here is the call graph for this function:

Here is the caller graph for this function:

char* query

(

struct soap *

soap

)

{ return strchr(soap->path, '?');
}

Here is the caller graph for this function:

char* query_key	(	struct soap *	soap,
		char **	s
	)

{ char *t = *s;
 if (t && *t)
 { *s = (char*)soap_decode_string(t, strlen(t), t + 1);
 return t;
 }
 return *s = NULL;
}

Here is the call graph for this function:

char* query_val	(	struct soap *	soap,
		char **	s
	)

{ char *t = *s;
 if (t && *t == '=')
 { *s = (char*)soap_decode_string(t, strlen(t), t + 1);
 return t;
 }
 return NULL;
}

Here is the call graph for this function:

const char* soap_decode_string	(	char *	buf,
		size_t	len,
		const char *	val
	)

{ const char *s;
 char *t;
 for (s = val; *s; s++)
 if (*s != ' ' && *s != '=')
 break;
 if (*s == '"')
 { t = buf;
 s++;
 while (*s && *s != '"' && --len)
 *t++ = *s++;
 *t = '\0';
 do s++;
 while (*s && *s != '&' && *s != '=');
 }
 else
 { t = buf;
 while (*s && *s != '&' && *s != '=' && --len)
 { switch (*s)
 { case '+':
 *t++ = ' ';
 case ' ':
 s++;
 break;
 case '%':
 *t++ = ((s[1] >= 'A' ? (s[1]&0x7) + 9 : s[1] - '0') << 4) + (s[2] >= 'A' ? (s[2]&0x7) + 9 : s[2] - '0');
 s += 3;
 break;
 default:
 *t++ = *s++;
 }
 }
 *t = '\0';
 }
 return s;
}

Here is the caller graph for this function:

int soap_encode_string	(	const char *	s,
		char *	t,
		size_t	len
	)

{ register int c;
 register size_t n = len;
 while ((c = *s++) && n-- > 1)
 { if (c == ' ') 
 *t++ = '+';
 else if (c == '!'
 || c == '$'
 || (c >= '(' && c <= '.')
 || (c >= '0' && c <= '9')
 || (c >= 'A' && c <= 'Z')
 || c == '_'
 || (c >= 'a' && c <= 'z'))
 *t++ = (char)c;
 else if (n > 2)
 { *t++ = '%';
 *t++ = (char)((c >> 4) + (c > 159 ? '7' : '0'));
 c &= 0xF;
 *t++ = (char)(c + (c > 9 ? '7' : '0'));
 n -= 2;
 }
 else
 break;
 }
 *t = '\0';
 return len - n;
}

int soap_get_connect	(	struct soap *	soap,
		const char *	endpoint,
		const char *	action
	)

{ return soap_connect_command(soap, SOAP_GET, endpoint, action);
}

Here is the call graph for this function:

Variable Documentation

const char http_get_id[13] = HTTP_GET_ID