Merge branch 'PGPRO9_6' into PGPROEE9_6

Author: vbwagner

contrib/pg_pathman/META.json

@@ -2,7 +2,7 @@
    "name": "pg_pathman",
    "abstract": "Partitioning tool",
    "description": "The `pg_pathman` module provides optimized partitioning mechanism and functions to manage partitions.",
-   "version": "1.4.6",
+   "version": "1.4.7",
    "maintainer": [
       "Ildar Musin <i.musin@postgrespro.ru>",
       "Dmitry Ivanov <d.ivanov@postgrespro.ru>",
@@ -24,7 +24,7 @@
        "pg_pathman": {
            "file": "pg_pathman--1.4.sql",
            "docfile": "README.md",
-           "version": "1.4.6",
+           "version": "1.4.7",
            "abstract": "Partitioning tool"
       }
    },

contrib/pg_pathman/expected/pathman_bgw.out

@@ -200,7 +200,8 @@ BEGIN
 
 			ASSERT rows IS NOT NULL;
 
-			IF rows_old = rows THEN
+			-- rows should increase!
+			IF rows_old <= rows THEN
 				i = i + 1;
 			END IF;
 		ELSE

contrib/pg_pathman/expected/pathman_calamity.out

@@ -12,7 +12,7 @@ SELECT debug_capture();
 SELECT get_pathman_lib_version();
  get_pathman_lib_version 
 -------------------------
- 10406
+ 10407
 (1 row)
 
 set client_min_messages = NOTICE;

contrib/pg_pathman/sql/pathman_bgw.sql

@@ -114,7 +114,8 @@ BEGIN
 
 			ASSERT rows IS NOT NULL;
 
-			IF rows_old = rows THEN
+			-- rows should increase!
+			IF rows_old <= rows THEN
 				i = i + 1;
 			END IF;
 		ELSE

contrib/pg_pathman/src/include/init.h

@@ -157,7 +157,7 @@ simpify_mcxt_name(MemoryContext mcxt)
 #define LOWEST_COMPATIBLE_FRONT		0x010400
 
 /* Current version of native C library (0xAA_BB_CC) */
-#define CURRENT_LIB_VERSION			0x010406
+#define CURRENT_LIB_VERSION			0x010407
 
 
 void *pathman_cache_search_relid(HTAB *cache_table,

contrib/pg_pathman/src/pathman_workers.c

@@ -569,6 +569,7 @@ bgw_main_concurrent_part(Datum main_arg)
 
 				/* Extract number of processed rows */
 				rows = DatumGetInt64(SPI_getbinval(tuple, tupdesc, 1, &isnull));
+				Assert(tupdesc->attrs[0]->atttypid == INT8OID); /* check type */
 				Assert(!isnull); /* ... and ofc it must not be NULL */
 			}
 			/* Else raise generic error */