Small fixes.

Author: arssher

shard.sql

@@ -192,14 +192,15 @@ BEGIN
 	-- and dangerous: what if table was created and dropped before this
 	-- change reached us? We might also use it with local table (create
 	-- foreign server pointing to it, etc), but that's just ugly.
+	RAISE DEBUG '[SHARDMAN] my id: %, creating ft %',
+		shardman.get_node_id(), part.part_name;
 	EXECUTE format('CREATE FOREIGN TABLE %I %s SERVER %I OPTIONS (table_name %L)',
 				   fdw_part_name,
 				   (SELECT
 						shardman.reconstruct_table_attrs(
 							format('%I', part.relation))),
 							part.part_name,
 							part.part_name);
-	RAISE DEBUG '[SHARDMAN] my id: %, new part: %', shardman.get_node_id(), part.part_name;
 	-- replace local partition with foreign table
 	EXECUTE format('SELECT replace_hash_partition(%L, %L)',
 				   part.part_name, fdw_part_name);

src/shard.c

@@ -626,11 +626,10 @@ calc_timeout(slist_head *timeout_states)
 		CopyPartState *cps = cps_node->cps;
 
 		/* If waketm is not set, what this node does in this list? */
-		elog(INFO, "waketm is %ld:%ld", cps->waketm.tv_sec, cps->waketm.tv_nsec);
 		Assert(cps->waketm.tv_nsec != 0);
 		if (!waketm_set || timespeccmp(cps->waketm, waketm) < 0)
 		{
-			shmn_elog(DEBUG1, "Waketm updated, old %d s, new %d s",
+			shmn_elog(DEBUG5, "Waketm updated, old %d s, new %d s",
 					  waketm_set ? (int) waketm.tv_sec : 0,
 					  (int) cps->waketm.tv_sec);
 			waketm = cps->waketm;
@@ -1011,7 +1010,7 @@ reset_pqconn_and_res(PGconn **conn, PGresult *res)
  */
 void configure_retry(CopyPartState *cps, int millis)
 {
-	shmn_elog(DEBUG1, "Moving mpart %s: sleeping %d ms and retrying",
+	shmn_elog(DEBUG1, "Copying mpart %s: sleeping %d ms and retrying",
 			  cps->part_name, millis);
 	cps->waketm = timespec_now_plus_millis(millis);
 	cps->exec_res = TASK_WAKEMEUP;

src/shardman_hooks.c

@@ -36,8 +36,6 @@ shardman_log_hook(ErrorData *edata)
 
 		edata->message = psprintf("[SHNODE %d] %s",
 								  shardman_my_node_id, edata->message);
-		printf("Log hook called, line pref is %s, message is %s", Log_line_prefix,
-		edata->message);
 
 		MemoryContextSwitchTo(oldcontext);
 	}