Removed trailing whitespace from scheduler code

Author: vbwagner

contrib/pgpro_scheduler/src/cron_string.c

@@ -49,7 +49,7 @@ char *_cps_append_string(char *str, char *to_add)
 {
 	int end = str ? strlen(str): 0;
 	int len = strlen(to_add);
-	
+
 	str = realloc(str, end + len + 1);
 	memcpy(str+end, to_add, len);
 	str[end+len] = 0;
@@ -66,7 +66,7 @@ char *_cps_make_array(int *src, int len)
 	out = _cps_append_string(out, "[");
 	for(i=0; i<len; i++)
 	{
-		sprintf(buff, "%d,", src[i]); 
+		sprintf(buff, "%d,", src[i]);
 		if(len == (i+1)) buff[strlen(buff)-1] = 0;
 		out = _cps_append_string(out, buff);
 	}
@@ -78,7 +78,7 @@ int _cps_dig_digit(char *str)
 	int len = strlen(str);
 	char *endptr = NULL;
 	int res;
-	
+
 	if(len == 1 && str[0] == '*')
 	{
 		return -1;
@@ -110,14 +110,14 @@ char **_cps_split_by(char sep, char *src, int *N)
 	char **res = NULL;
 	int i, n = 1, ri = 0, ti = 0;
 	char tmp[1024];
-	
+
 	for(i=0; i<len; i++)
 	{
 		if(src[i] == sep) n++;
 	}
 	res = malloc(sizeof(char *)*n);
 	*N = n;
-	
+
 	for(i=0; i < len; i++)
 	{
 		if(src[i] == sep)
@@ -205,7 +205,7 @@ int *_cps_parse_range(char *src, int start, int end, int *len)
 					}
 					for(i = 0; i < range_len; i++)
 					{
-						if(i >= (a-start) && i <= (b-start)) values[i] = 1; 
+						if(i >= (a-start) && i <= (b-start)) values[i] = 1;
 					}
 					_cps_clean_charchar(elements, e_len);
 				}
@@ -272,16 +272,16 @@ int *_cps_parse_range(char *src, int start, int end, int *len)
 				}
 				values[a-start] = 1;
 			}
-		} 
+		}
 	}
-	
+
 	if(isError == 0)
 	{
 		for(i =0; i < range_len; i++)
 		{
 			if(values[i]) (*len)++;
 		}
-			
+
 		if(*len > 0)
 		{
 			ptr = malloc(sizeof(int)*(*len));
@@ -290,7 +290,7 @@ int *_cps_parse_range(char *src, int start, int end, int *len)
 		{
 			ptr = NULL;
 		}
-		
+
 		for(i = 0; i < range_len; i++)
 		{
 			if(values[i]) ptr[ni++] = i+start;
@@ -450,11 +450,11 @@ cron_ent_t *parse_crontab(char *cron_str)
 	int N = strlen(cron_str);
 	char tmp[256];
 	int i, ti =0, en = 0 ;
-	
+
 	if(N == 7 && strcmp(cron_str, "@reboot") == 0)
 	{
 		CE = (cron_ent_t *)malloc(sizeof(cron_ent_t));
-		memset((void *)CE, 0, sizeof(cron_ent_t)); 
+		memset((void *)CE, 0, sizeof(cron_ent_t));
 		CE->onstart = 1;
 
 		return CE;
@@ -492,11 +492,11 @@ cron_ent_t *parse_crontab(char *cron_str)
 	}
 
 	CE = (cron_ent_t *)malloc(sizeof(cron_ent_t));
-	memset((void *)CE, 0, sizeof(cron_ent_t)); 
+	memset((void *)CE, 0, sizeof(cron_ent_t));
 
 
 	entrs[3] = _cps_subst_str(entrs[3], cps_month_subst_data, 12, 1);
-	entrs[4] = _cps_subst_str(entrs[4], cps_wday_subst_data, 7, 0); 
+	entrs[4] = _cps_subst_str(entrs[4], cps_wday_subst_data, 7, 0);
 
 	CE->mins = _cps_parse_range(entrs[0], 0, 59, &(CE->mins_len));
 	if(CE->mins) CE->hour = _cps_parse_range(entrs[1], 0, 23, &(CE->hour_len));

contrib/pgpro_scheduler/src/pgpro_scheduler.c

@@ -119,7 +119,7 @@ char *make_date_from_timestamp(TimestampTz ts, bool hires)
 	fsec_t fsec;
 	const char *tzn;
 
-	timestamp2tm(ts, &tz, &dt, &fsec, &tzn, NULL ); 
+	timestamp2tm(ts, &tz, &dt, &fsec, &tzn, NULL );
 	sprintf(str, "%04d-%02d-%02d %02d:%02d:%02d", dt.tm_year , dt.tm_mon,
 			dt.tm_mday, dt.tm_hour, dt.tm_min, dt.tm_sec);
 	if(!hires) str[16] = 0;
@@ -178,7 +178,7 @@ char *set_schema(const char *name, bool get_old)
 	}
 	else
 	{
-		schema_name = _copy_string((char *)GetConfigOption("schedule.schema", true, false));	
+		schema_name = _copy_string((char *)GetConfigOption("schedule.schema", true, false));
 		free_name = true;
 	}
 	SetConfigOption("search_path", schema_name,  PGC_USERSET, PGC_S_SESSION);
@@ -264,7 +264,7 @@ char_array_t *readBasesToCheck(void)
 	{
 		appendStringInfo(&sql, "'%s'", names->data[i]);
 		if(i + 1  != names->n) appendStringInfo(&sql, ",");
-	} 
+	}
 	destroyCharArray(names);
 	appendStringInfo(&sql, ")");
 
@@ -304,7 +304,7 @@ void parent_scheduler_main(Datum arg)
 	CurrentResourceOwner = ResourceOwnerCreate(NULL, "pgpro_scheduler");
 
 	init_worker_mem_ctx("Parent scheduler context");
-	elog(LOG, "Start PostgresPro scheduler."); 
+	elog(LOG, "Start PostgresPro scheduler.");
 
 	SetConfigOption("application_name", "pgp-s supervisor", PGC_USERSET, PGC_S_SESSION);
 	pgstat_report_activity(STATE_RUNNING, "Initialize");
@@ -358,7 +358,7 @@ void parent_scheduler_main(Datum arg)
 				destroyCharArray(names);
 			}
 		}
-		else 
+		else
 		{
 			for(i=0; i < pool->n; i++)
 			{
@@ -417,7 +417,7 @@ pg_scheduler_startup(void)
 	memcpy(worker.bgw_library_name, "pgpro_scheduler", 16);
 	memcpy(worker.bgw_name, "pgpro scheduler", 16);
 
-	RegisterBackgroundWorker(&worker); 
+	RegisterBackgroundWorker(&worker);
 }
 
 void _PG_init(void)
@@ -468,7 +468,7 @@ void _PG_init(void)
 		"schedule.transaction_state",
 		"State of scheduler executor transaction",
 		"If not under scheduler executor process the variable has no mean and has a value = 'undefined', possible values: progress, success, failure",
-		&scheduler_transaction_state , 
+		&scheduler_transaction_state ,
 		"undefined",
 		PGC_INTERNAL,
 		0,
@@ -542,14 +542,14 @@ cron_string_to_json_text(PG_FUNCTION_ARGS)
 	text *text_p;
 	int len;
 	char *error = NULL;
-	
+
 	if(PG_ARGISNULL(0))
-	{  
+	{
 		PG_RETURN_NULL();
 	}
 	source = PG_GETARG_CSTRING(0);
 	jsonText = parse_crontab_to_json_text(source);
-	
+
 	if(jsonText)
 	{
 		len = strlen(jsonText);

contrib/pgpro_scheduler/src/sched_manager_poll.c

@@ -238,7 +238,7 @@ pid_t registerManagerWorker(schd_manager_t *man)
 
 void _sortPollManagers(schd_managers_poll_t *poll)
 {
-	if(poll->n > 1) 
+	if(poll->n > 1)
 		qsort(poll->workers, poll->n, sizeof(schd_manager_t *), __cmp_managers);
 }
 

contrib/pgpro_scheduler/src/scheduler_executor.c

@@ -182,7 +182,7 @@ int do_one_job(schd_executor_share_t *shared, schd_executor_status_t *status)
 	if(!job)
 	{
 		if(shared->message[0] == 0)
-			snprintf(shared->message, PGPRO_SCHEDULER_EXECUTOR_MESSAGE_MAX, 
+			snprintf(shared->message, PGPRO_SCHEDULER_EXECUTOR_MESSAGE_MAX,
 											"Cannot retrive job information");
 		shared->worker_exit = true;
 		*status = shared->status = SchdExecutorError;
@@ -324,7 +324,7 @@ int do_one_job(schd_executor_share_t *shared, schd_executor_status_t *status)
 
 	return 1;
 }
-	
+
 
 int set_session_authorization(char *username, char **error)
 {
@@ -337,7 +337,7 @@ int set_session_authorization(char *username, char **error)
 	char *sql = "select oid, rolsuper from pg_catalog.pg_roles where rolname = $1";
 	char buff[1024];
 
-	values[0] = CStringGetTextDatum(username);	
+	values[0] = CStringGetTextDatum(username);
 	START_SPI_SNAP();
 	r = execute_spi_sql_with_args(sql, 1, types, values, NULL);
 
@@ -431,7 +431,7 @@ TimestampTz get_next_excution_time(char *sql, executor_error_t *ee)
 		return 0;
 	}
 	if(r->n_rows == 0)
-	{	
+	{
 		push_executor_error(ee, "next time statement returns 0 rows");
 	}
 	else if(r->types[0] != TIMESTAMPTZOID)
@@ -581,33 +581,33 @@ int push_executor_error(executor_error_t *e, char *fmt, ...)
 }
 
 PG_FUNCTION_INFO_V1(get_self_id);
-Datum 
+Datum
 get_self_id(PG_FUNCTION_ARGS)
 {
 	if(current_job_id == -1)
 	{
-		elog(ERROR, "There is no active job in progress");	
+		elog(ERROR, "There is no active job in progress");
 	}
 	PG_RETURN_INT64(current_job_id);
 }
 
 PG_FUNCTION_INFO_V1(resubmit);
-Datum 
+Datum
 resubmit(PG_FUNCTION_ARGS)
 {
-	Interval *interval;	
+	Interval *interval;
 
 	if(current_job_id == -1)
 	{
-		elog(ERROR, "There is no active job in progress");	
+		elog(ERROR, "There is no active job in progress");
 	}
 	if(PG_ARGISNULL(0))
 	{
-		resubmit_current_job = 1;		
+		resubmit_current_job = 1;
 		PG_RETURN_INT64(1);
 	}
 	interval = PG_GETARG_INTERVAL_P(0);
-#ifdef HAVE_INT64_TIMESTAMP 
+#ifdef HAVE_INT64_TIMESTAMP
     resubmit_current_job = interval->time / 1000000.0;
 #else
     resubmit_current_job = interval->time;
@@ -662,7 +662,7 @@ void at_executor_worker_main(Datum arg)
 
 	while(1)
 	{
-		if(shared->stop_worker) break; 
+		if(shared->stop_worker) break;
 		if(got_sighup)
 		{
 			got_sighup = false;
@@ -671,7 +671,7 @@ void at_executor_worker_main(Datum arg)
 		CHECK_FOR_INTERRUPTS();
 		result = process_one_job(shared, &status);
 
-		if(result == 0) 
+		if(result == 0)
 		{
 			lets_sleep = true;
 		}
@@ -812,7 +812,7 @@ int process_one_job(schd_executor_share_state_t *shared, schd_executor_status_t
 		set_ret = set_at_job_done(job, NULL, resubmit_current_job, &set_error);
 	}
 	destroy_spi_data(r);
-	
+
 	resubmit_current_job = 0;
 	current_job_id = -1;
 	pgstat_report_activity(STATE_RUNNING, "finish job processing");