Small refacroting
authorzev <zev@radensolutions.com>
Wed, 8 Jun 2016 09:38:00 +0000 (12:38 +0300)
committerzev <zev@radensolutions.com>
Wed, 8 Jun 2016 09:38:11 +0000 (12:38 +0300)
src/server/core/ap_jobs.cpp
src/server/core/job.cpp
src/server/core/upload_job.cpp
src/server/include/nxcore_jobs.h

index 4c7b01c..51ac505 100644 (file)
@@ -163,13 +163,13 @@ ServerJobResult PolicyDeploymentJob::run()
 /**
  * Serializes job parameters into TCHAR line separated by ';'
  */
-TCHAR *PolicyDeploymentJob::serializeParameters()
+const String PolicyDeploymentJob::serializeParameters()
 {
    String params;
    params.append(m_policy->getId());
    params.append(_T(','));
    params.append(m_retryCount);
-   return _tcsdup(params.getBuffer());
+   return params;
 }
 
 /**
@@ -177,9 +177,7 @@ TCHAR *PolicyDeploymentJob::serializeParameters()
  */
 void PolicyDeploymentJob::rescheduleExecution()
 {
-   TCHAR *params = serializeParameters();
-   AddOneTimeScheduledTask(_T("Policy.Deploy"), time(NULL) + getNextJobExecutionTime(), params, 0, getRemoteNode(), SYSTEM_ACCESS_FULL, SCHEDULED_TASK_SYSTEM);//TODO: change to correct user
-   free(params);
+   AddOneTimeScheduledTask(_T("Policy.Deploy"), time(NULL) + getNextJobExecutionTime(), serializeParameters(), 0, getRemoteNode(), SYSTEM_ACCESS_FULL, SCHEDULED_TASK_SYSTEM);//TODO: change to correct user
 }
 
 
@@ -320,13 +318,13 @@ ServerJobResult PolicyUninstallJob::run()
 /**
  * Serializes job parameters into TCHAR line separated by ';'
  */
-TCHAR *PolicyUninstallJob::serializeParameters()
+const String PolicyUninstallJob::serializeParameters()
 {
    String params;
    params.append(m_policy->getId());
    params.append(_T(','));
    params.append(m_retryCount);
-   return _tcsdup(params.getBuffer());
+   return params;
 }
 
 /**
@@ -334,7 +332,5 @@ TCHAR *PolicyUninstallJob::serializeParameters()
  */
 void PolicyUninstallJob::rescheduleExecution()
 {
-   TCHAR *params = serializeParameters();
-   AddOneTimeScheduledTask(_T("Policy.Uninstall"), time(NULL) + getNextJobExecutionTime(), params, 0, getRemoteNode(), SYSTEM_ACCESS_FULL, SCHEDULED_TASK_SYSTEM);//TODO: change to correct user
-   free(params);
+   AddOneTimeScheduledTask(_T("Policy.Uninstall"), time(NULL) + getNextJobExecutionTime(), serializeParameters(), 0, getRemoteNode(), SYSTEM_ACCESS_FULL, SCHEDULED_TASK_SYSTEM);//TODO: change to correct user
 }
index 5262770..e60c728 100644 (file)
@@ -384,9 +384,9 @@ const TCHAR *ServerJob::getAdditionalInfo()
 /**
  * Serializes job parameters into TCHAR line separated by ';'
  */
-TCHAR *ServerJob::serializeParameters()
+const String ServerJob::serializeParameters()
 {
-   return _tcsdup(_T(""));
+   return String();
 }
 
 /**
index 7f4574f..d211d36 100644 (file)
@@ -221,7 +221,7 @@ const TCHAR *FileUploadJob::getAdditionalInfo()
 /**
  * Serializes job parameters into TCHAR line separated by ';'
  */
-TCHAR *FileUploadJob::serializeParameters()
+const String FileUploadJob::serializeParameters()
 {
    String params;
    params.append(m_localFile);
@@ -229,7 +229,7 @@ TCHAR *FileUploadJob::serializeParameters()
    params.append(CHECK_NULL_EX(m_remoteFile));
    params.append(_T(','));
    params.append(m_retryCount);
-   return _tcsdup(params.getBuffer());
+   return params;
 }
 
 /**
@@ -237,8 +237,6 @@ TCHAR *FileUploadJob::serializeParameters()
  */
 void FileUploadJob::rescheduleExecution()
 {
-   TCHAR *param = serializeParameters();
-   AddOneTimeScheduledTask(_T("Policy.Uninstall"), time(NULL) + getNextJobExecutionTime(), param, 0, getRemoteNode(), SYSTEM_ACCESS_FULL, SCHEDULED_TASK_SYSTEM);//TODO: change to correct user
-   free(param);
+   AddOneTimeScheduledTask(_T("Policy.Uninstall"), time(NULL) + getNextJobExecutionTime(), serializeParameters(), 0, getRemoteNode(), SYSTEM_ACCESS_FULL, SCHEDULED_TASK_SYSTEM);//TODO: change to correct user
 }
 
index ebec557..1931b77 100644 (file)
@@ -131,7 +131,7 @@ public:
        void setOwningQueue(ServerJobQueue *queue);
 
        void fillMessage(NXCPMessage *msg);
-       virtual TCHAR *serializeParameters();
+       virtual const String serializeParameters();
        virtual void rescheduleExecution();
        int getNextJobExecutionTime();
 };
@@ -202,7 +202,7 @@ public:
        FileUploadJob(TCHAR* params, UINT32 node, UINT32 userId);
        virtual ~FileUploadJob();
 
-       virtual TCHAR *serializeParameters();
+       virtual const String serializeParameters();
        virtual void rescheduleExecution();
        void setLocalFileFullPath();
 };
@@ -259,7 +259,7 @@ public:
    PolicyDeploymentJob(const TCHAR* params, UINT32 node, UINT32 userId);
        virtual ~PolicyDeploymentJob();
 
-       virtual TCHAR *serializeParameters();
+       virtual const String serializeParameters();
        virtual void rescheduleExecution();
 };
 
@@ -280,7 +280,7 @@ public:
    PolicyUninstallJob(const TCHAR* params, UINT32 node, UINT32 userId);
        virtual ~PolicyUninstallJob();
 
-       virtual TCHAR *serializeParameters();
+       virtual const String serializeParameters();
        virtual void rescheduleExecution();
 };