//
-// Open Service Platform
// Copyright (c) 2012 Samsung Electronics Co., Ltd.
//
// Licensed under the Apache License, Version 2.0 (the License);
*/
#include <typeinfo>
-#include <new>
#include <unique_ptr.h>
#include <appsvc/appsvc.h>
#include <FBaseInteger.h>
#include <FBaseString.h>
#include <FBaseLongLong.h>
+#include <FBaseColLinkedList.h>
#include <FBaseColIList.h>
#include <FBaseColIMap.h>
#include <FBaseColIMapEnumerator.h>
#include "FApp_SqlDataControlImpl.h"
#include "FApp_AppArg.h"
#include "FApp_DataControlManager.h"
+#include "FAppPkg_PackageManagerImpl.h"
#define DATACONTROL_PROTOCOL_VER_2_1_0_2 // ver_2.1.0.2
+#define DATACONTROL_PROTOCOL_VER_2_1_0_3 // ver_2.1.0.3
using namespace std;
using namespace Tizen::Base;
using namespace Tizen::Base::Collection;
using namespace Tizen::Base::Runtime;
-using namespace Tizen::App;
using namespace Tizen::Io;
+using namespace Tizen::App;
+using namespace Tizen::App::Package;
namespace Tizen { namespace App
{
static const int MAX_REQUEST_COUNT = 128;
+static const int REQUEST_THRESHOLD = 100;
static const int _MAX_ARGUMENT_SIZE = 16384; // 16KB
static const int _MAX_REQUEST_ARGUMENT_SIZE = 1048576; // 1MB
-static const char* _DATACONTROL_REQUEST_DIR = "/tmp/osp/DataControlRequest/\0";
+//static const char* _DATACONTROL_REQUEST_DIR = "/tmp/osp/DataControlRequest/\0";
+static const char* _DATACONTROL_REQUEST_DIR = "/tmp/osp/data-control/request/\0";
class _SqlDataControlEventArg
: public IEventArg
: public Event
{
protected:
- virtual void FireImpl(IEventListener& listener, const IEventArg& arg);
+ virtual void FireImpl(IEventListener& listener, const IEventArg& arg);
};
void
// private
_SqlDataControlImpl::_SqlDataControlImpl(void)
- : __appId(L"")
- , __providerId(L"")
- , __access(_DATACONTROL_ACCESS_UNDEFINED)
+ : __access(_DATACONTROL_ACCESS_UNDEFINED)
, __pPreviousListener(null)
, __pSqlDataControlEvent(null)
{
_SqlDataControlImpl::~_SqlDataControlImpl(void)
{
delete __pSqlDataControlEvent;
+
+ _DataControlManager* pDcMgr = _DataControlManager::GetInstance();
+
+ IEnumerator* pEnum = __pRequestList->GetEnumeratorN();
+ while (pEnum->MoveNext() == E_SUCCESS)
+ {
+ Integer* pReqId = dynamic_cast< Integer* >(pEnum->GetCurrent());
+ if (pReqId != null)
+ {
+ pDcMgr->RemoveRequestInfo(*pReqId);
+ }
+ }
+ delete __pRequestList;
}
_SqlDataControlImpl*
result r = E_SUCCESS;
int req = -1;
- _AppControlManager* pAppManagerImpl = _AppControlManager::GetInstance();
+ _DataControlManager* pDcMgr = _DataControlManager::GetInstance();
// Check the request count of DataControl operation
- int count = pAppManagerImpl->GetLaunchRequestCount();
+ int count = pDcMgr->GetRequestCount();
SysLog(NID_APP, "Current launch request count: %d", count);
+ if (count > REQUEST_THRESHOLD)
+ {
+ _AppManagerImpl* pImpl = _AppManagerImpl::GetInstance();
+
+ // Clear the request queue if the provider is terminated
+ if (!pImpl->IsRunning(__appId))
+ {
+ SysLog(NID_APP, "The request queue is cleared due to the invalid provider.");
+
+ pDcMgr->RemoveAllRequests();
+ }
+ }
+
SysTryReturnResult(NID_APP, count < MAX_REQUEST_COUNT, E_MAX_EXCEEDED, "The number of requests has exceeded the maximum limit.");
_AppArg* pArg = new (std::nothrow) _AppArg; // XXX: pArg will be released in _AppManagerImpl::LaunchApp().
pArg->Construct(*this, static_cast <_DataControlRequestType>(type), pDataList);
+ _AppControlManager* pAppManagerImpl = _AppControlManager::GetInstance();
+
if (__pSqlDataControlEvent)
{
// reqId is system-wide id because the bundle is system-wide.
_AppControlManager::_RequestGuard reqObj = _AppControlManager::_RequestGuard(*pAppManagerImpl, pArg, SqlDataControlCallback, __pSqlDataControlEvent, -1);
req = reqObj.GetRequestNumber();
#else
- _DataControlManager* pDcMgr = _DataControlManager::GetInstance();
_AppControlManager::_RequestGuard reqObj = _AppControlManager::_RequestGuard(*pAppManagerImpl, pArg, SqlDataControlCallback, pDcMgr, -1);
req = reqObj.GetRequestNumber();
#endif
"[E_OUT_OF_MEMORY] The memory is insufficient");
pReqInfo = new (std::nothrow) _DataControlRequestInfo(__pSqlDataControlEvent);
- SysTryCatch(NID_APP, pReqId != null, r = E_OUT_OF_MEMORY, E_OUT_OF_MEMORY,
+ SysTryCatch(NID_APP, pReqInfo != null, r = E_OUT_OF_MEMORY, E_OUT_OF_MEMORY,
"[E_OUT_OF_MEMORY] The memory is insufficient");
+ pReqInfo->SetSqlDataControlImpl(this);
r = pDcMgr->AddRequestInfo(pReqId, pReqInfo);
SysTryCatch(NID_APP, !IsFailed(r), r = E_SYSTEM, E_SYSTEM, "[%s] Failed to add request info", GetErrorMessage(r));
SysPropagate(NID_APP, r);
reqObj.Invalidate();
pDcMgr->RemoveRequestInfo(*pReqId);
- delete pArg;
return r;
}
+ __pRequestList->Add(new (std::nothrow) Integer(req));
+
if (pReq)
{
*pReq = req;
pArgList->Add(*(new String(L"NULL")));
}
SysTryCatch(NID_APP, argSize <= _MAX_ARGUMENT_SIZE, r = E_MAX_EXCEEDED, E_MAX_EXCEEDED,
- "[E_MAX_EXCEEDED] The size of sending argument (%d) exceeds the maximum limit.", argSize);
+ "[E_MAX_EXCEEDED] The size of sending argument (%lld) exceeds the maximum limit.", argSize);
pArgList->Add(*(new String(Integer::ToString(pageNo)))); // list(5): page number
_DataControlManager* pDcMgr = static_cast< _DataControlManager* >(data);
_DataControlRequestInfo* pReqInfo = pDcMgr->GetRequestInfo(key);
- SysTryCatch(NID_APP, pReqInfo != null, r = E_SYSTEM, E_SYSTEM,
- "[E_SYSTEM] Failed to get request info");
+ if (pReqInfo == null)
+ {
+ SysLog(NID_APP, "No request info of reqId %d", reqId);
+ return E_SUCCESS;
+ }
_SqlDataControlEvent* pSqlDataControlEvent = dynamic_cast< _SqlDataControlEvent* >(pReqInfo->GetEvent());
- SysTryCatch(NID_APP, pSqlDataControlEvent != null, r = E_SYSTEM, E_SYSTEM,
- "[E_SYSTEM] invalid request info");
+ SysTryCatch(NID_APP, pSqlDataControlEvent != null, r = E_SYSTEM, E_SYSTEM, "[E_SYSTEM] invalid request info");
pDcMgr->RemoveRequestInfo(key);
+ _SqlDataControlImpl* pDcImpl = pReqInfo->GetSqlDataControlImpl();
+ SysTryCatch(NID_APP, pDcImpl != null, r = E_SYSTEM, E_SYSTEM, "[E_SYSTEM] invalid request info");
+ pDcImpl->__pRequestList->Remove(key);
+
+ // Remove the request from the queue
+ SysLog(NID_APP, "Remove the request, req: %d", reqId);
+
if (pSqlDataControlEvent != null && typeid(pSqlDataControlEvent) == typeid(_SqlDataControlEvent*))
{
// result list
SysTryCatch(NID_APP, pDataId, r = E_OUT_OF_MEMORY, E_OUT_OF_MEMORY,
"[E_OUT_OF_MEMORY] The memory is insufficient.");
- SysLog(NID_APP, "[DC_CALLER_RECV] provider result: %ld, requestType: %d, req: %d, provider: %ls, data: %ls, errorMsg: %ls ",
+ SysSecureLog(NID_APP, "[DC_CALLER_RECV] provider result: %ld, requestType: %d, req: %d, provider: %ls, data: %ls, errorMsg: %ls ",
providerRes, requestType, reqId, pProviderId->GetPointer(), pDataId->GetPointer(), pErrorMsg->GetPointer());
switch (static_cast <_DataControlRequestType>(requestType))
SysTryCatch(NID_APP, p, r = E_SYSTEM, E_SYSTEM, "[E_SYSTEM] invalid bundle");
launchReqId = atoi(p);
- // Remove the request count
- SysLog(NID_APP, "Remove a launch request: req: %d", launchReqId);
- _AppControlManager::GetInstance()->RemoveLaunchRequest(launchReqId);
-
return E_SUCCESS;
CATCH:
int columnCount = 0;
int id = 0;
- int i = 0;
int uniqueId = -1;
File request;
IMapEnumerator* pMapEnum = null;
+ _PackageManagerImpl* pPkgMgrImpl = null;
+ unique_ptr< String > pProviderAppId(null);
result r = E_SUCCESS;
SysLog(NID_APP, "[DC_CALLER_SEND] SqlDataControl INSERT");
#endif
}
SysTryCatch(NID_APP, argSize <= _MAX_REQUEST_ARGUMENT_SIZE, r = E_MAX_EXCEEDED, E_MAX_EXCEEDED,
- "[E_MAX_EXCEEDED] The size of sending argument (%d) exceeds the maximum limit.", argSize);
+ "[E_MAX_EXCEEDED] The size of sending argument (%lld) exceeds the maximum limit.", argSize);
#ifdef DATACONTROL_PROTOCOL_VER_2_1_0_2
request.Flush();
#endif
+#ifdef DATACONTROL_PROTOCOL_VER_2_1_0_3
+ pPkgMgrImpl = _PackageManagerImpl::GetInstance();
+ pProviderAppId.reset(pPkgMgrImpl->GetAppIdOfDataControlN(this->__providerId.GetPointer()));
+ SysTryCatch(NID_APP, pProviderAppId != null, r = E_SYSTEM, E_SYSTEM,
+ "[E_SYSTEM] The method cannot proceed due to a severe system error.");
+ r = pDcMgr->AllowAccess(*(pProviderAppId.get()));
+ SysTryCatch(NID_APP, !IsFailed(r), , r, "[%s] Propagating to caller...", GetErrorMessage(r));
+#endif
r = StartSqlDataControl(_DATACONTROL_REQUEST_TYPE_SQL_INSERT, pArgList, &id);
SysTryCatch(NID_APP, !IsFailed(r), , r, "[%s] Propagating to caller...", GetErrorMessage(r));
int columnCount = 0;
int id = 0;
- int i = 0;
int uniqueId = -1;
File request;
IMapEnumerator* pMapEnum = null;
+ _PackageManagerImpl* pPkgMgrImpl = null;
+ unique_ptr< String > pProviderAppId(null);
result r = E_SUCCESS;
SysLog(NID_APP, "[DC_CALLER_SEND] SqlDataControl UPDATE");
pArgList->Add(new (std::nothrow) String(L"NULL"));
}
SysTryCatch(NID_APP, argSize <= _MAX_REQUEST_ARGUMENT_SIZE, r = E_MAX_EXCEEDED, E_MAX_EXCEEDED,
- "[E_MAX_EXCEEDED] The size of sending argument (%d) exceeds the maximum limit.", argSize);
+ "[E_MAX_EXCEEDED] The size of sending argument (%lld) exceeds the maximum limit.", argSize);
+
+#ifdef DATACONTROL_PROTOCOL_VER_2_1_0_3
+ pPkgMgrImpl = _PackageManagerImpl::GetInstance();
+ pProviderAppId.reset(pPkgMgrImpl->GetAppIdOfDataControlN(this->__providerId.GetPointer()));
+ SysTryCatch(NID_APP, pProviderAppId != null, r = E_SYSTEM, E_SYSTEM,
+ "[E_SYSTEM] The method cannot proceed due to a severe system error.");
+ r = pDcMgr->AllowAccess(*(pProviderAppId.get()));
+ SysTryCatch(NID_APP, !IsFailed(r), , r, "[%s] Propagating to caller...", GetErrorMessage(r));
+#endif
r = StartSqlDataControl(_DATACONTROL_REQUEST_TYPE_SQL_UPDATE, pArgList, &id);
SysTryCatch(NID_APP, !IsFailed(r), , r, "[%s] Propagating to caller...", GetErrorMessage(r));
pArgList->Add(*(new String(L"NULL")));
}
SysTryCatch(NID_APP, argSize <= _MAX_ARGUMENT_SIZE, r = E_MAX_EXCEEDED, E_MAX_EXCEEDED,
- "[E_MAX_EXCEEDED] The size of sending argument (%d) exceeds the maximum limit.", argSize);
+ "[E_MAX_EXCEEDED] The size of sending argument (%lld) exceeds the maximum limit.", argSize);
r = StartSqlDataControl(_DATACONTROL_REQUEST_TYPE_SQL_DELETE, pArgList, &id);
SysTryCatch(NID_APP, !IsFailed(r), , r, "[%s] Propagating to caller...", GetErrorMessage(r));
unique_ptr<_SqlDataControlEvent> pSqlDataControlEvent(new (std::nothrow) _SqlDataControlEvent);
SysTryReturn(NID_IO, pSqlDataControlEvent != null, null, E_OUT_OF_MEMORY, "[E_OUT_OF_MEMORY] The memory is insufficient.");
+ pDcImpl->__pRequestList = new (std::nothrow) LinkedList(SingleObjectDeleter);
+ SysTryReturn(NID_IO, pDcImpl->__pRequestList != null, null, E_OUT_OF_MEMORY, "[E_OUT_OF_MEMORY] The memory is insufficient.");
+
pDcImpl->__pSqlDataControlEvent = pSqlDataControlEvent.release();
if (access == L"readonly")
projects / platform / framework / native / appfw.git / blobdiff