* limitations under the License.
*
******************************************************************/
-
#include "SSMResourceServer.h"
#include "SSMCore.h"
#include "Common/PlatformLayer.h"
m_hSSMResource = resourceHandle;
}
- SSMRESULT onQueryEngineEvent(IN int cqid, IN IDataReader *pResult)
+ SSMRESULT onQueryEngineEvent(int cqid, IDataReader *pResult)
{
int dataCount = 0;
IModelData *pModelData = NULL;
g_vecQueryEventResults.push_back(queryEventResult);
//TODO: need to modify for notifying proper clients
- OCPlatform::notifyAllObservers(m_hSSMResource);
+ if (OCPlatform::notifyAllObservers(m_hSSMResource) != OC_STACK_OK)
+ return SSM_E_FAIL;
return SSM_S_OK;
}
response->setRequestHandle(request->getRequestHandle());
response->setResourceHandle(request->getResourceHandle());
- if (requestFlag & RequestHandlerFlag::InitFlag)
- {
- // entity handler to perform resource initialization operations
- }
-
if (requestFlag & RequestHandlerFlag::RequestFlag)
{
- cout << "\t\trequestFlag : Request\n";
-
// If the request type is GET
if (requestType == "GET")
{
}
else if (rep.getValue<std::string>("command") == "ReleaseQueryEngine")
{
- pQueryEngine = (IQueryEngine *) std::stoi(
+ pQueryEngine = (IQueryEngine *) std::stoll(
rep.getValue<std::string>("queryEngineId"));
ReleaseQueryEngine(pQueryEngine);
{
int CQID = 0;
- pQueryEngine = (IQueryEngine *) std::stoi(
+ pQueryEngine = (IQueryEngine *)std::stoll(
rep.getValue<std::string>("queryEngineId"));
res = pQueryEngine->executeContextQuery(
}
else if (rep.getValue<std::string>("command") == "KillContextQuery")
{
- pQueryEngine = (IQueryEngine *) std::stoi(
+ pQueryEngine = (IQueryEngine *)std::stoll(
rep.getValue<std::string>("queryEngineId"));
res = pQueryEngine->killContextQuery(std::stoi(rep.getValue<std::string>("CQID")));