run tasks but still fail sometimes

Author: Vladimir Ershov

src/memutils.c

@@ -15,6 +15,12 @@ MemoryContext init_worker_mem_ctx(const char *name)
 	return SchedulerWorkerContext;
 }
 
+MemoryContext switch_to_worker_context(void)
+{
+	AssertState(SchedulerWorkerContext != NULL);
+	return MemoryContextSwitchTo(SchedulerWorkerContext);
+}
+
 void *worker_alloc(Size size)
 {
 	AssertState(SchedulerWorkerContext != NULL);

src/memutils.h

@@ -7,6 +7,7 @@
 extern MemoryContext SchedulerWorkerContext;
 
 MemoryContext init_worker_mem_ctx(const char *name);
+MemoryContext switch_to_worker_context(void);
 void *worker_alloc(Size size);
 void delete_worker_mem_ctx(void);
 

src/pgpro_scheduler.c

@@ -63,6 +63,8 @@ worker_spi_sigterm(SIGNAL_ARGS)
 	errno = save_errno;
 }
 
+/** Some utils **/
+
 TimestampTz timestamp_add_seconds(TimestampTz to, int add)
 {
 	if(to == 0) to = GetCurrentTimestamp();
@@ -72,6 +74,63 @@ TimestampTz timestamp_add_seconds(TimestampTz to, int add)
 	return add + to;
 }
 
+int get_integer_from_string(char *s, int start, int len)
+{
+	char buff[100];
+
+	memcpy(buff, s + start, len);
+	buff[len] = 0;
+	return atoi(buff);
+}
+
+char *make_date_from_timestamp(TimestampTz ts)
+{
+	struct pg_tm dt;
+	char *str = worker_alloc(sizeof(char) * 17);
+	int tz;
+	fsec_t fsec;
+	const char *tzn;
+
+	timestamp2tm(ts, &tz, &dt, &fsec, &tzn, NULL ); /* TODO ERROR */
+	sprintf(str, "%04d-%02d-%02d %02d:%02d", dt.tm_year , dt.tm_mon,
+			dt.tm_mday, dt.tm_hour, dt.tm_min);
+	return str;
+}
+
+TimestampTz get_timestamp_from_string(char *str)
+{
+    struct pg_tm dt;
+    int tz;
+    TimestampTz ts;
+
+    memset(&dt, 0, sizeof(struct tm));
+    dt.tm_year  = get_integer_from_string(str,  0, 4);
+    dt.tm_mon   = get_integer_from_string(str,  5, 2);
+    dt.tm_mday  = get_integer_from_string(str,  8, 2);
+    dt.tm_hour  = get_integer_from_string(str, 11, 2);
+    dt.tm_min   = get_integer_from_string(str, 14, 2);
+
+    tz = DetermineTimeZoneOffset(&dt, session_timezone);
+
+    tm2timestamp(&dt, 0, &tz, &ts);
+
+    return ts;
+}
+
+TimestampTz _round_timestamp_to_minute(TimestampTz ts)
+{
+#ifdef HAVE_INT64_TIMESTAMP
+	return ts - ts % USECS_PER_MINUTE;
+#else
+	return ts - ts % SECS_PER_MINUTE;
+#endif
+}
+
+
+/** END of SOME UTILS **/
+
+
+
 char_array_t *readBasesToCheck(void)
 {
 	const char *value;

src/pgpro_scheduler.h

@@ -23,6 +23,11 @@ void parent_scheduler_main(Datum) pg_attribute_noreturn();
 int checkSchedulerNamespace(void);
 void manager_worker_main(Datum arg);
 pid_t registerManagerWorker(schd_manager_t *man);
+
 TimestampTz timestamp_add_seconds(TimestampTz to, int add);
+char *make_date_from_timestamp(TimestampTz ts);
+int get_integer_from_string(char *s, int start, int len);
+TimestampTz get_timestamp_from_string(char *str);
+TimestampTz _round_timestamp_to_minute(TimestampTz ts);
 
 #endif