/*
HTTP?Simple?Queue?Service?-?httpsqs?v1.7
Author:?Zhang?Yan?（http://blog.s135.com）?E-mail:?net@s135.com
This?is?free?software?and?you?are?welcome?to?modify?and?redistribute?it?under?the?New?BSD?License
*/

#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?

#include?
#include?
#include?

#include?

#include?“prename.h“

#define?VERSION?“1.7“

/*?每個隊列的默認最大長度為100萬條?*/
#define?HTTPSQS_DEFAULT_MAXQUEUE?1000000

/*?全局設置?*/
TCBDB?*httpsqs_db_tcbdb;?/*?數據表?*/
int?httpsqs_settings_syncinterval;?/*?同步更新內容到磁盤的間隔時間?*/
char?*httpsqs_settings_pidfile;?/*?PID文件?*/
char?*httpsqs_settings_auth;?/*?驗證密碼?*/

/*?創建多層目錄的函數?*/
void?create_multilayer_dir（?char?*muldir?）?
{
????int????ilen;
????char????str[512];
????
????strncpy（?str?muldir?512?）;
????len=strlen（str）;
????for（?i=0;?i????{
????????if（?str[i]==‘/‘?）
????????{
????????????str[i]?=?‘\0‘;
????????????//判斷此目錄是否存在不存在則創建
????????????if（?access（str?F_OK）!=0?）
????????????{
????????????????mkdir（?str?0777?）;
????????????}
????????????str[i]=‘/‘;
????????}
????}
????if（?len>0?&&?access（str?F_OK）!=0?）
????{
????????mkdir（?str?0777?）;
????}

????return;
}

char?*urldecode（char?*input_str）?
{
		int?len?=?strlen（input_str）;
		char?*str?=?strdup（input_str）;
		
????????char?*dest?=?str;?
????????char?*data?=?str;?

????????int?value;?
????????int?c;?

????????while?（len--）?{?
????????????????if?（*data?==?‘+‘）?{?
????????????????????????*dest?=?‘?‘;?
????????????????}?
????????????????else?if?（*data?==?‘%‘?&&?len?>=?2?&&?isxdigit（（int）?*（data?+?1））?
??&&?isxdigit（（int）?*（data?+?2）））?
????????????????{?

????????????????????????c?=?（（unsigned?char?*）（data+1））[0];?
????????????????????????if?（isupper（c））?
????????????????????????????????c?=?tolower（c）;?
????????????????????????value?=?（c?>=?‘0‘?&&?c?<=?‘9‘???c?-?‘0‘?:?c?-?‘a‘?+?10）?*?16;?
????????????????????????c?=?（（unsigned?char?*）（data+1））[1];?
????????????????????????if?（isupper（c））?
????????????????????????????????c?=?tolower（c）;?
????????????????????????????????value?+=?c?>=?‘0‘?&&?c?<=?‘9‘???c?-?‘0‘?:?c?-?‘a‘?+?10;?

????????????????????????*dest?=?（char）value?;?
????????????????????????data?+=?2;?
????????????????????????len?-=?2;?
????????????????}?else?{?
????????????????????????*dest?=?*data;?
????????????????}?
????????????????data++;?
????????????????dest++;?
????????}?
????????*dest?=?‘\0‘;?
????????return?str;?
}

/*?讀取隊列寫入點的值?*/
static?int?httpsqs_read_putpos（const?char*?httpsqs_input_name）
{
	int?queue_value?=