diff options
Diffstat (limited to 'curlmanager.cpp')
| -rw-r--r-- | curlmanager.cpp | 897 |
1 files changed, 0 insertions, 897 deletions
diff --git a/curlmanager.cpp b/curlmanager.cpp deleted file mode 100644 index 973d133..0000000 --- a/curlmanager.cpp +++ /dev/null @@ -1,897 +0,0 @@ -#include "curlmanager.h" - -#ifdef PLATFORM_LINUX -#include <netinet/in.h> -#endif - - -cURLManager g_cURLManager; - - -struct data_t { - data_t(cURLHandle *_handle, size_t _bytes, size_t _nmemb): - handle(_handle), buffer(NULL), bytes(_bytes), nmemb(_nmemb) - { - } - cURLHandle *handle; - char *buffer; - size_t bytes; - size_t nmemb; - size_t return_value; -}; - -/* Write Function */ -static size_t curl_write_function_default(void *ptr, size_t bytes, size_t nmemb, void *stream) -{ - FILE *file = (FILE *)stream; -#ifdef WIN32 - if(file->_file >= 3) -#else - if(file->_fileno >= 3) -#endif - { - return fwrite(ptr, bytes, nmemb, file); - } - return (bytes * nmemb); -} - -static size_t Call_Write_Function(cURLHandle *handle, const char *buffer, size_t bytes, size_t nmemb) -{ - IPluginFunction *pFunc = handle->callback_Function[cURL_CallBack_WRITE_FUNCTION]; - assert((pFunc != NULL)); - cell_t result = bytes * nmemb; - if(pFunc != NULL) - { - pFunc->PushCell(handle->hndl); - pFunc->PushStringEx((char *)buffer, nmemb+1, SM_PARAM_STRING_COPY|SM_PARAM_STRING_BINARY, 0); - pFunc->PushCell(bytes); - pFunc->PushCell(nmemb); - pFunc->PushCell(handle->UserData[UserData_Type_Write_Func]); - pFunc->Execute(&result); - } - return result; -} - -static void sm_write_function_FrameAction(void *data) -{ - if(data == NULL) - return; - - data_t *wdata = (data_t*)data; - wdata->return_value = Call_Write_Function(wdata->handle, wdata->buffer, wdata->bytes, wdata->nmemb); - wdata->handle->thread->EventSignal(); -} - -static size_t curl_write_function_SM(void *ptr, size_t bytes, size_t nmemb, void *stream) -{ - cURLHandle *handle = (cURLHandle *)stream; - - size_t ret; - if(handle->thread == NULL) - { - char *buffer = new char[nmemb+1]; - memcpy(buffer,ptr, nmemb); - buffer[nmemb] = '\0'; - ret = Call_Write_Function(handle, buffer, bytes, nmemb); - delete [] buffer; - } else { - if(g_cURL_SM.IsShutdown()) - return (bytes * nmemb); - - data_t *data = new data_t(handle, bytes, nmemb); - data->buffer = new char[nmemb+1]; - memcpy(data->buffer,ptr, nmemb); - data->buffer[nmemb] = '\0'; - - smutils->AddFrameAction(sm_write_function_FrameAction, data); - handle->thread->EventWait(); - - ret = data->return_value; - delete [] data->buffer; - delete data; - - if(g_cURL_SM.IsShutdown()) - return (bytes * nmemb); - } - - return ret; -} - -/* Read Function */ -static size_t Call_Read_Function(cURLHandle *handle, size_t bytes, size_t nmemb) -{ - IPluginFunction *pFunc = handle->callback_Function[cURL_CallBack_READ_FUNCTION]; - assert((pFunc != NULL)); - cell_t result = bytes * nmemb; - if(pFunc != NULL) - { - pFunc->PushCell(handle->hndl); - pFunc->PushCell(bytes); - pFunc->PushCell(nmemb); - pFunc->PushCell(handle->UserData[UserData_Type_Read_Func]); - pFunc->Execute(&result); - } - return result; -} - -static void sm_read_function_FrameAction(void *data) -{ - if(data == NULL) - return; - - data_t *rdata = (data_t*)data; - rdata->return_value = Call_Read_Function(rdata->handle, rdata->bytes, rdata->nmemb); - rdata->handle->thread->EventSignal(); -} - - -static size_t curl_read_function_SM(char *ptr, size_t bytes, size_t nmemb, void *stream) -{ - cURLHandle *handle = (cURLHandle *)stream; - - size_t ret = 0; - if(handle->thread == NULL) - { - ret = Call_Read_Function(handle, bytes, nmemb); - } else { - if(g_cURL_SM.IsShutdown()) - return 0; - - data_t *data = new data_t(handle, bytes, nmemb); - - smutils->AddFrameAction(sm_read_function_FrameAction, data); - handle->thread->EventWait(); - - ret = data->return_value; - delete data; - - if(g_cURL_SM.IsShutdown()) - return 0; - } - - if(ret > 0) - { - memcpy(ptr,handle->send_buffer.data(), handle->send_buffer.size()); - } - - return ret; -} - -static curl_socket_t curl_opensocket_function(void *clientp, curlsocktype purpose, struct curl_sockaddr *address) -{ - cURLHandle *handle = (cURLHandle *)clientp; - if(handle->is_udp) - { - address->socktype = SOCK_DGRAM; - address->protocol = IPPROTO_UDP; - address->family = AF_INET; - } - - return socket(address->family, address->socktype, address->protocol); -} - -void cURLManager::SDK_OnLoad() -{ - curlhandle_list_mutex = threader->MakeMutex(); - shutdown_event = threader->MakeEventSignal(); - closehelper_list_mutex = threader->MakeMutex(); - - waiting = false; -} - -void cURLManager::SDK_OnUnload() -{ - curlhandle_list_mutex->Lock(); - if(g_cURLThread_List.size() > 0) - { - printf("[%s] Waiting %d cURL Threads Terminate...\n",SMEXT_CONF_LOGTAG,g_cURLThread_List.size()); - - SourceHook::List<cURLThread *>::iterator iter = g_cURLThread_List.begin(); - cURLThread *pInfo; - while (iter != g_cURLThread_List.end()) - { - pInfo = (*iter); - if(pInfo->waiting) { - pInfo->event->Signal(); - } - iter++; - } - - curlhandle_list_mutex->Unlock(); - - waiting = true; - shutdown_event->Wait(); - - printf("[%s] All cURL Thread Terminated !!!\n",SMEXT_CONF_LOGTAG); - } else { - curlhandle_list_mutex->Unlock(); - } - - shutdown_event->DestroyThis(); - curlhandle_list_mutex->DestroyThis(); - - shutdown_event = NULL; - curlhandle_list_mutex = NULL; - g_cURLThread_List.clear(); - - g_CloseHelper_List.clear(); -} - -void cURLManager::CreatecURLThread(cURLThread *thread) -{ - if(g_cURL_SM.IsShutdown()) - { - delete thread; - return; - } - curlhandle_list_mutex->Lock(); - g_cURLThread_List.push_back(thread); - curlhandle_list_mutex->Unlock(); - - threader->MakeThread(thread); -} - -void cURLManager::RemovecURLThread(cURLThread *thread) -{ - if(g_cURL_SM.IsShutdown()) - { - RemovecURLHandle(thread->handle); - } - - curlhandle_list_mutex->Lock(); - g_cURLThread_List.remove(thread); - - if(waiting) - { - if(g_cURLThread_List.size() == 0) - { - curlhandle_list_mutex->Unlock(); - shutdown_event->Signal(); - return; - } - } - curlhandle_list_mutex->Unlock(); -} - -void cURLManager::AddCloseHelperHandle(ICloseHelper *helper) -{ - closehelper_list_mutex->Lock(); - if(g_CloseHelper_List.find(helper) == g_CloseHelper_List.end()) - { - g_CloseHelper_List.push_back(helper); - } - closehelper_list_mutex->Unlock(); -} - -void cURLManager::RemoveCloseHelperHandle(ICloseHelper *helper) -{ - closehelper_list_mutex->Lock(); - g_CloseHelper_List.remove(helper); - closehelper_list_mutex->Unlock(); -} - -void cURLManager::RemoveLinkedICloseHelper(cURLHandle *handle) -{ - closehelper_list_mutex->Lock(); - - SourceHook::List<ICloseHelper *>::iterator iter; - ICloseHelper *pInfo; - for (iter=g_CloseHelper_List.begin(); iter!=g_CloseHelper_List.end(); iter++) - { - pInfo = (*iter); - if(pInfo->_handle == handle) - { - pInfo->_handle = NULL; - if(pInfo->_marked_delete) - { - pInfo->Delete(); - iter = g_CloseHelper_List.erase(iter); - } - } - } - - closehelper_list_mutex->Unlock(); -} - -void cURLManager::RemovecURLHandle(cURLHandle *handle) -{ - if(!handle || handle->running) - return; - - if(handle->thread != NULL) - { - handle->thread->handle = NULL; - } - curl_easy_cleanup(handle->curl); - handle->curl = NULL; - - SourceHook::List<cURLOpt_string *>::iterator iter; - cURLOpt_string *pInfo; - for (iter=handle->opt_string_list.begin(); iter!=handle->opt_string_list.end(); iter++) - { - pInfo = (*iter); - delete [] pInfo->value; - delete pInfo; - } - handle->opt_string_list.clear(); - - SourceHook::List<cURLOpt_int *>::iterator iter2; - cURLOpt_int*pInfo2; - for (iter2=handle->opt_int_list.begin(); iter2!=handle->opt_int_list.end(); iter2++) - { - pInfo2 = (*iter2); - delete pInfo2; - } - handle->opt_int_list.clear(); - - SourceHook::List<cURLOpt_pointer *>::iterator iter3; - cURLOpt_pointer *pInfo3; - for(iter3=handle->opt_pointer_list.begin(); iter3!=handle->opt_pointer_list.end(); iter3++) - { - pInfo3 = (*iter3); - delete pInfo3; - } - handle->opt_pointer_list.clear(); - - SourceHook::List<cURLOpt_int64 *>::iterator iter4; - cURLOpt_int64 *pInfo4; - for(iter4=handle->opt_int64_list.begin(); iter4!=handle->opt_int64_list.end(); iter4++) - { - pInfo4 = (*iter4); - delete pInfo4; - } - handle->opt_int64_list.clear(); - - handle->send_buffer.clear(); - - RemoveLinkedICloseHelper(handle); - - delete handle; -} - -bool cURLManager::AddcURLOptionString(cURLHandle *handle, CURLoption opt, char *value) -{ - if(!handle || handle->running || !value) - return false; - - std::string value_str; - - bool supported = false; - switch(opt) - { - case CURLOPT_URL: - { - char *lowercase_value = UTIL_ToLowerCase(value); - std::string value_str_lower(lowercase_value); - delete [] lowercase_value; - - if(!value_str_lower.compare(0,6, "udp://")) - { - handle->is_udp = true; - value_str.assign(&value[6]); - } else { - value_str = value; - handle->is_udp = false; - } - supported = true; - break; - } - case CURLOPT_PROXY: - case CURLOPT_PROXYUSERPWD: - case CURLOPT_RANGE: - case CURLOPT_USERPWD: - case CURLOPT_KEYPASSWD: - case CURLOPT_POSTFIELDS: - case CURLOPT_REFERER: - case CURLOPT_FTPPORT: - case CURLOPT_USERAGENT: - case CURLOPT_COOKIE: - case CURLOPT_ENCODING: - case CURLOPT_CUSTOMREQUEST: - case CURLOPT_WRITEINFO: - case CURLOPT_INTERFACE: - case CURLOPT_KRBLEVEL: - case CURLOPT_SSL_CIPHER_LIST: - case CURLOPT_SSLCERTTYPE: - case CURLOPT_SSLKEYTYPE: - case CURLOPT_SSLENGINE: - case CURLOPT_FTP_ACCOUNT: - case CURLOPT_COOKIELIST: - case CURLOPT_FTP_ALTERNATIVE_TO_USER: - case CURLOPT_SSH_HOST_PUBLIC_KEY_MD5: - case CURLOPT_USERNAME: - case CURLOPT_PASSWORD: - case CURLOPT_PROXYUSERNAME: - case CURLOPT_PROXYPASSWORD: - case CURLOPT_NOPROXY: - case CURLOPT_SOCKS5_GSSAPI_SERVICE: - case CURLOPT_MAIL_FROM: - case CURLOPT_RTSP_SESSION_ID: - case CURLOPT_RTSP_STREAM_URI: - case CURLOPT_RTSP_TRANSPORT: - value_str.assign(value); - supported = true; - break; - case CURLOPT_COOKIEFILE: - case CURLOPT_COOKIEJAR: - case CURLOPT_RANDOM_FILE: - case CURLOPT_EGDSOCKET: - case CURLOPT_SSLCERT: - case CURLOPT_SSLKEY: - case CURLOPT_CAINFO: - case CURLOPT_CAPATH: - case CURLOPT_NETRC_FILE: - case CURLOPT_SSH_PUBLIC_KEYFILE: - case CURLOPT_SSH_PRIVATE_KEYFILE: - case CURLOPT_CRLFILE: - case CURLOPT_ISSUERCERT: - case CURLOPT_SSH_KNOWNHOSTS: - { - char realpath[PLATFORM_MAX_PATH]; - g_pSM->BuildPath(Path_Game, realpath, sizeof(realpath), "%s", value); - value_str.assign(realpath); - supported = true; - break; - } - } - - assert((supported != false)); - if(!supported) - return false; - - cURLOpt_string *stringopt = new cURLOpt_string(); - stringopt->opt = opt; - stringopt->value = new char[value_str.size()+1]; - memset(stringopt->value, 0, value_str.size()+1); - memcpy(stringopt->value,value_str.c_str(), value_str.size()); - - handle->opt_string_list.push_back(stringopt); - - return true; -} - -bool cURLManager::AddcURLOptionInt(cURLHandle *handle, CURLoption opt, int value) -{ - if(!handle || handle->running) - return false; - - bool supported = false; - switch(opt) - { - case CURLOPT_PORT: - case CURLOPT_NOPROGRESS: - case CURLOPT_VERBOSE: - case CURLOPT_PROXYTYPE: - case CURLOPT_HTTPPROXYTUNNEL: - case CURLOPT_TIMEOUT: - case CURLOPT_SSL_VERIFYPEER: - case CURLOPT_SSL_VERIFYHOST: - case CURLOPT_UPLOAD: - case CURLOPT_INFILESIZE: - case CURLOPT_LOW_SPEED_LIMIT: - case CURLOPT_LOW_SPEED_TIME: - case CURLOPT_RESUME_FROM: - case CURLOPT_CRLF: - case CURLOPT_SSLVERSION: - case CURLOPT_TIMECONDITION: - case CURLOPT_TIMEVALUE: - case CURLOPT_HEADER: - case CURLOPT_NOBODY: - case CURLOPT_FAILONERROR: - case CURLOPT_POST: - case CURLOPT_DIRLISTONLY: - case CURLOPT_APPEND: - case CURLOPT_NETRC: - case CURLOPT_FOLLOWLOCATION: - case CURLOPT_TRANSFERTEXT: - case CURLOPT_PUT: - case CURLOPT_AUTOREFERER: - case CURLOPT_PROXYPORT: - case CURLOPT_POSTFIELDSIZE: - case CURLOPT_MAXREDIRS: - case CURLOPT_FILETIME: - case CURLOPT_MAXCONNECTS: - case CURLOPT_CLOSEPOLICY: - case CURLOPT_FRESH_CONNECT: - case CURLOPT_FORBID_REUSE: - case CURLOPT_CONNECTTIMEOUT: - case CURLOPT_HTTPGET: - case CURLOPT_HTTP_VERSION: - case CURLOPT_FTP_USE_EPSV: - case CURLOPT_SSLENGINE_DEFAULT: - case CURLOPT_DNS_USE_GLOBAL_CACHE: - case CURLOPT_DNS_CACHE_TIMEOUT: - case CURLOPT_COOKIESESSION: - case CURLOPT_BUFFERSIZE: - case CURLOPT_NOSIGNAL: - case CURLOPT_UNRESTRICTED_AUTH: - case CURLOPT_FTP_USE_EPRT: - case CURLOPT_HTTPAUTH: - case CURLOPT_FTP_CREATE_MISSING_DIRS: - case CURLOPT_PROXYAUTH: - case CURLOPT_FTP_RESPONSE_TIMEOUT: - case CURLOPT_IPRESOLVE: - case CURLOPT_MAXFILESIZE: - case CURLOPT_USE_SSL: - case CURLOPT_TCP_NODELAY: - case CURLOPT_FTPSSLAUTH: - case CURLOPT_IGNORE_CONTENT_LENGTH: - case CURLOPT_FTP_SKIP_PASV_IP: - case CURLOPT_FTP_FILEMETHOD: - case CURLOPT_LOCALPORT: - case CURLOPT_LOCALPORTRANGE: - case CURLOPT_CONNECT_ONLY: - case CURLOPT_SSL_SESSIONID_CACHE: - case CURLOPT_SSH_AUTH_TYPES: - case CURLOPT_FTP_SSL_CCC: - case CURLOPT_TIMEOUT_MS: - case CURLOPT_CONNECTTIMEOUT_MS: - case CURLOPT_HTTP_TRANSFER_DECODING: - case CURLOPT_HTTP_CONTENT_DECODING: - case CURLOPT_NEW_FILE_PERMS: - case CURLOPT_NEW_DIRECTORY_PERMS: - case CURLOPT_POSTREDIR: - case CURLOPT_PROXY_TRANSFER_MODE: - case CURLOPT_ADDRESS_SCOPE: - case CURLOPT_CERTINFO: - case CURLOPT_TFTP_BLKSIZE: - case CURLOPT_PROTOCOLS: - case CURLOPT_REDIR_PROTOCOLS: - case CURLOPT_FTP_USE_PRET: - case CURLOPT_RTSP_REQUEST: - case CURLOPT_RTSP_CLIENT_CSEQ: - case CURLOPT_RTSP_SERVER_CSEQ: - case CURLOPT_WILDCARDMATCH: - case CURLOPT_TRANSFER_ENCODING: - case CURLOPT_GSSAPI_DELEGATION: - supported = true; - break; - } - - assert((supported != false)); - if(!supported) - return false; - - cURLOpt_int *intopt = new cURLOpt_int(); - intopt->opt = opt; - intopt->value = value; - - handle->opt_int_list.push_back(intopt); - - return true; -} - -bool cURLManager::AddcURLOptionInt64(cURLHandle *handle, CURLoption opt, long long value) -{ - if(!handle || handle->running) - return false; - - bool supported = false; - switch(opt) - { - case CURLOPT_INFILESIZE_LARGE: - case CURLOPT_RESUME_FROM_LARGE: - case CURLOPT_MAXFILESIZE_LARGE: - case CURLOPT_POSTFIELDSIZE_LARGE: - case CURLOPT_MAX_SEND_SPEED_LARGE: - case CURLOPT_MAX_RECV_SPEED_LARGE: - supported = true; - break; - } - - assert((supported != false)); - if(!supported) - return false; - - cURLOpt_int64 *int64opt = new cURLOpt_int64(); - int64opt->opt = opt; - int64opt->value = (curl_off_t)value; - - handle->opt_int64_list.push_back(int64opt); - return true; -} - -bool cURLManager::AddcURLOptionFunction(IPluginContext *pContext, cURLHandle *handle, CURLoption opt, IPluginFunction *pFunction, int value) -{ - if(!handle || handle->running) - return false; - - cURL_CallBack index = cURL_CallBack_NOTHING; - switch(opt) - { - case CURLOPT_WRITEFUNCTION: - index = cURL_CallBack_WRITE_FUNCTION; - handle->UserData[UserData_Type_Write_Func] = value; - break; - case CURLOPT_READFUNCTION: - index = cURL_CallBack_READ_FUNCTION; - handle->UserData[UserData_Type_Read_Func] = value; - break; - } - - if(index == cURL_CallBack_NOTHING) - return false; - - handle->callback_Function[index] = pFunction; - return true; -} - - -bool cURLManager::AddcURLOptionHandle(IPluginContext *pContext, cURLHandle *handle, HandleSecurity *sec, CURLoption opt, Handle_t hndl) -{ - if(!handle || handle->running) - return false; - - void *pointer = NULL; - int err = SP_ERROR_NONE; - ICloseHelper *helper = NULL; - - switch(opt) - { - case CURLOPT_WRITEDATA: - case CURLOPT_HEADERDATA: - case CURLOPT_READDATA: - case CURLOPT_STDERR: - case CURLOPT_INTERLEAVEDATA: - { - cURL_OpenFile *openfile = NULL; - err = handlesys->ReadHandle(hndl, g_cURLFile, sec, (void **)&openfile); - if(openfile != NULL) - { - pointer = openfile->pFile; - openfile->_handle = handle; - helper = openfile; - } - break; - } - case CURLOPT_HTTPPOST: - { - WebForm *webform = NULL; - err = handlesys->ReadHandle(hndl, g_WebForm, sec, (void **)&webform); - if(webform != NULL) { - pointer = webform->first; - webform->_handle = handle; - helper = webform; - - SourceHook::List<cURL_slist_pack *>::iterator iter; - cURL_slist_pack *pInfo; - for(iter=webform->slist_record.begin(); iter!=webform->slist_record.end(); iter++) - { - pInfo = (*iter); - pInfo->_handle = handle; - AddCloseHelperHandle(pInfo); - } - } - break; - } - case CURLOPT_HTTPHEADER: - case CURLOPT_QUOTE: - case CURLOPT_POSTQUOTE: - case CURLOPT_TELNETOPTIONS: - case CURLOPT_PREQUOTE: - case CURLOPT_HTTP200ALIASES: - case CURLOPT_MAIL_RCPT: - case CURLOPT_RESOLVE: - { - cURL_slist_pack *slist = NULL; - err = handlesys->ReadHandle(hndl, g_cURLSlist, sec, (void **)&slist); - if(slist != NULL) { - pointer = slist->chunk; - slist->_handle = handle; - helper = slist; - } - break; - } - } - - if(err != SP_ERROR_NONE) - { - pContext->ThrowNativeErrorEx(err, NULL); - return false; - } - - assert((pointer != NULL)); - if(pointer == NULL) - return false; - - - cURLOpt_pointer *pointeropt = new cURLOpt_pointer(); - pointeropt->opt = opt; - pointeropt->value = pointer; - - handle->opt_pointer_list.push_back(pointeropt); - - AddCloseHelperHandle(helper); - return true; -} - -void cURLManager::LoadcURLOption(cURLHandle *handle) -{ - if(!handle || handle->opt_loaded) - return; - - handle->opt_loaded = true; - - curl_easy_setopt(handle->curl, CURLOPT_ERRORBUFFER, handle->errorBuffer); - - curl_easy_setopt(handle->curl, CURLOPT_OPENSOCKETFUNCTION, curl_opensocket_function); - curl_easy_setopt(handle->curl, CURLOPT_OPENSOCKETDATA, handle); - - if(handle->callback_Function[cURL_CallBack_WRITE_FUNCTION] == NULL) { - curl_easy_setopt(handle->curl, CURLOPT_WRITEFUNCTION, curl_write_function_default); - } else { - curl_easy_setopt(handle->curl, CURLOPT_WRITEFUNCTION, curl_write_function_SM); - curl_easy_setopt(handle->curl, CURLOPT_WRITEDATA, handle); - } - - if(handle->callback_Function[cURL_CallBack_READ_FUNCTION] != NULL) { - curl_easy_setopt(handle->curl, CURLOPT_READFUNCTION, curl_read_function_SM); - curl_easy_setopt(handle->curl, CURLOPT_READDATA, handle); - } - - - SourceHook::List<cURLOpt_string *>::iterator iter; - cURLOpt_string *pInfo; - for(iter=handle->opt_string_list.begin(); iter!=handle->opt_string_list.end(); iter++) - { - pInfo = (*iter); - if((handle->lasterror = curl_easy_setopt(handle->curl, pInfo->opt, pInfo->value)) != CURLE_OK) - return; - } - - SourceHook::List<cURLOpt_int *>::iterator iter2; - cURLOpt_int *pInfo2; - for(iter2=handle->opt_int_list.begin(); iter2!=handle->opt_int_list.end(); iter2++) - { - pInfo2 = (*iter2); - if((handle->lasterror = curl_easy_setopt(handle->curl, pInfo2->opt, pInfo2->value)) != CURLE_OK) - return; - } - - SourceHook::List<cURLOpt_pointer *>::iterator iter3; - cURLOpt_pointer *pInfo3; - for(iter3=handle->opt_pointer_list.begin(); iter3!=handle->opt_pointer_list.end(); iter3++) - { - pInfo3 = (*iter3); - //Not allow use CURLOPT_WRITEDATA, CURLOPT_READDATA, if write/read function set - if((handle->callback_Function[cURL_CallBack_WRITE_FUNCTION] != NULL && pInfo3->opt == CURLOPT_WRITEDATA) - || (handle->callback_Function[cURL_CallBack_READ_FUNCTION] != NULL && pInfo3->opt == CURLOPT_READDATA)) - { - continue; - } - if((handle->lasterror = curl_easy_setopt(handle->curl, pInfo3->opt, pInfo3->value)) != CURLE_OK) - return; - } - - SourceHook::List<cURLOpt_int64 *>::iterator iter4; - cURLOpt_int64 *pInfo4; - for(iter4=handle->opt_int64_list.begin(); iter4!=handle->opt_int64_list.end(); iter4++) - { - pInfo4 = (*iter4); - if((handle->lasterror = curl_easy_setopt(handle->curl, pInfo4->opt, (curl_off_t)pInfo4->value)) != CURLE_OK) - return; - } -} - -CURLFORMcode cURLManager::cURLFormAdd(IPluginContext *pContext, const cell_t *params, WebForm *handle) -{ - assert((handle != NULL)); - if(handle == NULL) - return CURL_FORMADD_INCOMPLETE; - - unsigned int numparams = (unsigned)params[0]; - unsigned int startparam = 2; - if(numparams <= 1 || numparams > 22) - return CURL_FORMADD_INCOMPLETE; - - // there are only 10 available/supported CURLFORM_* - CURLformoption form_opts[11] = {CURLFORM_NOTHING}; - - char *form_data[10]; - memset(form_data, 0, sizeof(form_data)); - - cell_t *addr; - int count = 0; - int err; - int value; - for(unsigned int i=startparam;i<=numparams;i++) - { - if((err=pContext->LocalToPhysAddr(params[i], &addr)) != SP_ERROR_NONE) - { - pContext->ThrowNativeErrorEx(err, NULL); - return CURL_FORMADD_INCOMPLETE; - } - CURLformoption form_code = (CURLformoption)*addr; - switch(form_code) - { - case CURLFORM_COPYNAME: - case CURLFORM_COPYCONTENTS: - case CURLFORM_FILECONTENT: - case CURLFORM_FILE: - case CURLFORM_CONTENTTYPE: - case CURLFORM_FILENAME: - if((err=pContext->LocalToString(params[i+1], &form_data[count])) != SP_ERROR_NONE) - { - pContext->ThrowNativeErrorEx(err, NULL); - return CURL_FORMADD_INCOMPLETE; - } - if(form_code == CURLFORM_FILE || form_code == CURLFORM_FILECONTENT) // absolute path - { - char realpath[PLATFORM_MAX_PATH]; - g_pSM->BuildPath(Path_Game, realpath, sizeof(realpath), "%s", form_data[count]); - - form_data[count] = realpath; - } - form_opts[count] = form_code; - count++; - i++; - break; - case CURLFORM_NAMELENGTH: - case CURLFORM_CONTENTSLENGTH: - if((err=pContext->LocalToPhysAddr(params[i+1], &addr)) != SP_ERROR_NONE) - { - pContext->ThrowNativeErrorEx(err, NULL); - return CURL_FORMADD_INCOMPLETE; - } - form_opts[count] = form_code; - value = *addr; - form_data[count] = (char *)value; - count++; - i++; - break; - case CURLFORM_CONTENTHEADER: - { - if((err=pContext->LocalToPhysAddr(params[i+1], &addr)) != SP_ERROR_NONE) - { - pContext->ThrowNativeErrorEx(err, NULL); - return CURL_FORMADD_INCOMPLETE; - } - cURL_slist_pack *slist; - HandleError hndl_err; - HandleSecurity sec(pContext->GetIdentity(), myself_Identity); - if((hndl_err = handlesys->ReadHandle(*addr, g_cURLSlist, &sec, (void **)&slist)) != HandleError_None) - { - pContext->ThrowNativeError("Invalid curl_slist Handle %x (error %d)", params[1], hndl_err); - return CURL_FORMADD_INCOMPLETE; - } - form_opts[count] = form_code; - form_data[count] = (char *)slist->chunk; - handle->slist_record.push_back(slist); // when webform add into curlhandle, will add slist handle to close helper - count++; - i++; - break; - } - case CURLFORM_END: - form_opts[count] = CURLFORM_END; - goto end; - } - } - -end: - CURLFORMcode ret = curl_formadd(&handle->first, &handle->last, - form_opts[0], - form_data[0], - form_opts[1], - form_data[1], - form_opts[2], - form_data[2], - form_opts[3], - form_data[3], - form_opts[4], - form_data[4], - form_opts[5], - form_data[5], - form_opts[6], - form_data[6], - form_opts[7], - form_data[7], - form_opts[8], - form_data[8], - form_opts[9], - form_data[9], - form_opts[10] - ); - return ret; -} - - |