Diff: source/jobSchedulesUpload.cpp

Revision:

15:f83485cc5a2c

Parent:

14:65d69aed6540

Child:

16:bef1673b199e

--- a/source/jobSchedulesUpload.cpp	Thu Aug 03 18:15:49 2017 +0000
+++ b/source/jobSchedulesUpload.cpp	Thu Aug 03 19:04:06 2017 +0000
@@ -65,6 +65,7 @@
         this->_scheduler.AppointmentList(apts);
         node<JobScheduler::Appointment>* aptn = apts.pop(1);
         int idx = 0;
+        pbJobs.items_count = 0;
         while (aptn != NULL) {
             JobScheduler::Appointment* apt = aptn->data;
             JobScheduler::Job* job = apt->GetJob();
@@ -79,6 +80,7 @@
             }
             tr_debug("schedule data size: %d", pbJobs.items[idx].ScheduleData.size);
             // pbJobs.items[idx].Data = 
+            pbJobs.items_count = idx;
             
             apts.remove(1);
             aptn = apts.pop(1);
@@ -86,6 +88,15 @@
         }
     }
     
+    pb_ostream_t sizeStream = {0};
+    pb_encode(&sizeStream, protocol_JobList_fields, &pbJobs);
+    tr_debug("JobsList payload size: %d", sizeStream.bytes_written);
+
+    uint8_t* outBuf = new uint8_t[sizeStream.bytes_written];
+    pb_ostream_t outStream = pb_ostream_from_buffer(outBuf, sizeof(outBuf));
+    pb_encode(&outStream, protocol_JobList_fields, &pbJobs);
+    delete outBuf;
+    
 //    protocol_Job job;
     // time_t now = time(NULL);
     //tr_debug("ADC created time is: %s\n", ctime(&now));