test adding pglite diffs

Author: tudor

contrib/pgstattuple/pgstatindex.c

@@ -656,9 +656,9 @@ pgstathashindex(PG_FUNCTION_ARGS)
 			stats.unused_pages++;
 		else if (PageGetSpecialSize(page) !=
 				 MAXALIGN(sizeof(HashPageOpaqueData)))
-			ereport(ERROR,
+			ereport(WARNING,
 					(errcode(ERRCODE_INDEX_CORRUPTED),
-					 errmsg("index \"%s\" contains corrupted page at block %u",
+					 errmsg("# 661(FATAL block=%d): index \"%s\" contains corrupted page at block %u", blkno,
 							RelationGetRelationName(rel),
 							BufferGetBlockNumber(buf))));
 		else

contrib/xml2/Makefile

@@ -11,7 +11,7 @@ DATA = xml2--1.1.sql xml2--1.0--1.1.sql
 PGFILEDESC = "xml2 - XPath querying and XSLT"
 
 REGRESS = xml2
-
+PG_CFLAGS=$(shell xml2-config --cflags)
 SHLIB_LINK += $(filter -lxslt, $(LIBS)) -lxml2
 
 ifdef USE_PGXS

src/Makefile.shlib

@@ -233,6 +233,33 @@ ifeq ($(SHLIB_EXPORTS),)
   override CXXFLAGS += $(CXXFLAGS_SL_MODULE)
 endif
 
+ifeq ($(PORTNAME), emscripten)
+  LINK.shared       = emsdk-shared
+  ifdef soname
+    # emscripten uses unversioned shared libraries
+    shlib     = $(shlib_bare)
+    soname        = $(shlib_bare)
+  endif
+  BUILD.exports     = ( echo '{ global:'; $(AWK) '/^[^\#]/ {printf "%s;\n",$$1}' $<; echo ' local: *; };' ) >$@
+  exports_file      = $(SHLIB_EXPORTS:%.txt=%.list)
+#  ifneq (,$(exports_file))
+#    LINK.shared     += -Wl,--version-script=$(exports_file)
+#  endif
+endif
+
+ifeq ($(PORTNAME), wasi)
+  LINK.shared       = wasi-shared
+  ifdef soname
+    # emscripten uses unversioned shared libraries
+    shlib     = $(shlib_bare)
+    soname        = $(shlib_bare)
+  endif
+  BUILD.exports     = ( echo '{ global:'; $(AWK) '/^[^\#]/ {printf "%s;\n",$$1}' $<; echo ' local: *; };' ) >$@
+  exports_file      = $(SHLIB_EXPORTS:%.txt=%.list)
+#  ifneq (,$(exports_file))
+#    LINK.shared     += -Wl,--version-script=$(exports_file)
+#  endif
+endif
 
 ##
 ## BUILD
@@ -248,8 +275,11 @@ all-lib: lib$(NAME).pc
 endif
 
 all-static-lib: $(stlib)
-
+ifdef wasi
+all-shared-lib: all-static-lib
+else
 all-shared-lib: $(shlib)
+endif
 
 # In this rule, "touch $@" works around a problem on some platforms wherein
 # ar updates the library file's mod time with a value calculated to

src/backend/Makefile

@@ -65,7 +65,7 @@ ifneq ($(PORTNAME), win32)
 ifneq ($(PORTNAME), aix)
 
 postgres: $(OBJS)
-	$(CC) $(CFLAGS) $(call expand_subsys,$^) $(LDFLAGS) $(LIBS) -o $@
+	$(CC) $(MAIN_MODULE) $(CFLAGS) $(call expand_subsys,$^) $(LDFLAGS) $(LIBS) -o $@
 
 endif
 endif

src/backend/access/nbtree/nbtutils.c

@@ -2732,7 +2732,7 @@ _bt_allequalimage(Relation rel, bool debugmessage)
 			break;
 		}
 	}
-
+#if !defined(__EMSCRIPTEN__)
 	if (debugmessage)
 	{
 		if (allequalimage)
@@ -2742,6 +2742,6 @@ _bt_allequalimage(Relation rel, bool debugmessage)
 			elog(DEBUG1, "index \"%s\" cannot use deduplication",
 				 RelationGetRelationName(rel));
 	}
-
+#endif
 	return allequalimage;
 }

src/backend/access/transam/xact.c

@@ -1740,6 +1740,7 @@ RecordTransactionAbort(bool isSubXact)
 	if (TransactionIdDidCommit(xid))
 		elog(PANIC, "cannot abort transaction %u, it was already committed",
 			 xid);
+	else elog(WARNING, "# 1743: aborting transaction %u", xid);
 
 	/*
 	 * Are we using the replication origins feature?  Or, in other words, are
@@ -2748,7 +2749,9 @@ AbortTransaction(void)
 	 * handler.  We do this fairly early in the sequence so that the timeout
 	 * infrastructure will be functional if needed while aborting.
 	 */
+#if !defined(__EMSCRIPTEN__) && !defined(__wasi__)
 	sigprocmask(SIG_SETMASK, &UnBlockSig, NULL);
+#endif
 
 	/*
 	 * check the current transaction state
@@ -5107,7 +5110,10 @@ AbortSubTransaction(void)
 	 * handler.  We do this fairly early in the sequence so that the timeout
 	 * infrastructure will be functional if needed while aborting.
 	 */
+#if !defined(__EMSCRIPTEN__) && !defined(__wasi__)
 	sigprocmask(SIG_SETMASK, &UnBlockSig, NULL);
+#endif
+
 
 	/*
 	 * check the current transaction state

src/backend/access/transam/xlogarchive.c

@@ -33,6 +33,10 @@
 #include "storage/ipc.h"
 #include "storage/lwlock.h"
 
+#if defined(__wasi__)
+#define system(cmd) system_wasi(cmd)
+#endif
+
 /*
  * Attempt to retrieve the specified file from off-line archival storage.
  * If successful, fill "path" with its complete path (note that this will be

src/backend/bootstrap/bootstrap.c

@@ -199,7 +199,11 @@ CheckerModeMain(void)
  *	 to shared memory sizing, options work (or at least do not cause an error
  *	 up to shared memory creation).
  */
+#if !defined(__EMSCRIPTEN__) && !defined(__wasi__)
 void
+#else
+int
+#endif
 BootstrapModeMain(int argc, char *argv[], bool check_only)
 {
 	int			i;
@@ -353,7 +357,7 @@ BootstrapModeMain(int argc, char *argv[], bool check_only)
 	 */
 	if (pg_link_canary_is_frontend())
 		elog(ERROR, "backend is incorrectly linked to frontend functions");
-
+puts("# 360: InitPostgres(boot): " __FILE__ );
 	InitPostgres(NULL, InvalidOid, NULL, InvalidOid, false, false, NULL);
 
 	/* Initialize stuff for bootstrap-file processing */
@@ -378,7 +382,12 @@ BootstrapModeMain(int argc, char *argv[], bool check_only)
 
 	/* Clean up and exit */
 	cleanup();
+#if !defined(__EMSCRIPTEN__) && !defined(__wasi__)
 	proc_exit(0);
+#else
+	puts("# 338 cleanup(boot): " __FILE__);
+	return 0;
+#endif
 }
 
 

src/backend/catalog/index.c

@@ -2995,7 +2995,7 @@ index_build(Relation heapRelation,
 		indexInfo->ii_ParallelWorkers =
 			plan_create_index_workers(RelationGetRelid(heapRelation),
 									  RelationGetRelid(indexRelation));
-
+#if !defined(__EMSCRIPTEN__)
 	if (indexInfo->ii_ParallelWorkers == 0)
 		ereport(DEBUG1,
 				(errmsg_internal("building index \"%s\" on table \"%s\" serially",
@@ -3007,7 +3007,7 @@ index_build(Relation heapRelation,
 								 RelationGetRelationName(indexRelation),
 								 RelationGetRelationName(heapRelation),
 								 indexInfo->ii_ParallelWorkers)));
-
+#endif
 	/*
 	 * Switch to the table owner's userid, so that any index functions are run
 	 * as that user.  Also lock down security-restricted operations and

src/backend/commands/async.c

@@ -1700,8 +1700,12 @@ SignalBackends(void)
 		 * NotifyQueueLock; which is unlikely but certainly possible. So we
 		 * just log a low-level debug message if it happens.
 		 */
+#if defined(__EMSCRIPTEN__)
+        HandleNotifyInterrupt();
+#else
 		if (SendProcSignal(pid, PROCSIG_NOTIFY_INTERRUPT, ids[i]) < 0)
 			elog(DEBUG3, "could not signal backend with PID %d: %m", pid);
+#endif
 	}
 
 	pfree(pids);

src/backend/commands/collationcmds.c

@@ -828,14 +828,14 @@ pg_import_system_collations(PG_FUNCTION_ARGS)
 		maxaliases = 100;
 		aliases = (CollAliasData *) palloc(maxaliases * sizeof(CollAliasData));
 		naliases = 0;
-
 		locale_a_handle = OpenPipeStream("locale -a", "r");
-		if (locale_a_handle == NULL)
+		if (locale_a_handle == NULL) {
+            puts("======================== ERROR ================");
 			ereport(ERROR,
 					(errcode_for_file_access(),
 					 errmsg("could not execute command \"%s\": %m",
 							"locale -a")));
-
+        }
 		while (fgets(localebuf, sizeof(localebuf), locale_a_handle))
 		{
 			size_t		len;

src/backend/commands/dbcommands.c

@@ -1776,8 +1776,9 @@ dropdb(const char *dbname, bool missing_ok, bool force)
 	RequestCheckpoint(CHECKPOINT_IMMEDIATE | CHECKPOINT_FORCE | CHECKPOINT_WAIT);
 
 	/* Close all smgr fds in all backends. */
+#if !defined(__wasi__) && !defined(__EMSCRIPTEN__)
 	WaitForProcSignalBarrier(EmitProcSignalBarrier(PROCSIGNAL_BARRIER_SMGRRELEASE));
-
+#endif
 	/*
 	 * Remove all tablespace subdirs belonging to the database.
 	 */

src/backend/commands/event_trigger.c

@@ -642,6 +642,8 @@ EventTriggerDDLCommandStart(Node *parsetree)
 	List	   *runlist;
 	EventTriggerData trigdata;
 
+#if defined(__EMSCRIPTEN__) || defined(__wasi__)
+#else
 	/*
 	 * Event Triggers are completely disabled in standalone mode.  There are
 	 * (at least) two reasons for this:
@@ -660,6 +662,7 @@ EventTriggerDDLCommandStart(Node *parsetree)
 	 */
 	if (!IsUnderPostmaster)
 		return;
+#endif
 
 	runlist = EventTriggerCommonSetup(parsetree,
 									  EVT_DDLCommandStart,
@@ -690,12 +693,15 @@ EventTriggerDDLCommandEnd(Node *parsetree)
 	List	   *runlist;
 	EventTriggerData trigdata;
 
+#if defined(__EMSCRIPTEN__) || defined(__wasi__)
+#else
 	/*
 	 * See EventTriggerDDLCommandStart for a discussion about why event
 	 * triggers are disabled in single user mode.
 	 */
 	if (!IsUnderPostmaster)
 		return;
+#endif
 
 	/*
 	 * Also do nothing if our state isn't set up, which it won't be if there
@@ -738,12 +744,15 @@ EventTriggerSQLDrop(Node *parsetree)
 	List	   *runlist;
 	EventTriggerData trigdata;
 
+#if defined(__EMSCRIPTEN__) || defined(__wasi__)
+#else
 	/*
 	 * See EventTriggerDDLCommandStart for a discussion about why event
 	 * triggers are disabled in single user mode.
 	 */
 	if (!IsUnderPostmaster)
 		return;
+#endif
 
 	/*
 	 * Use current state to determine whether this event fires at all.  If
@@ -809,12 +818,15 @@ EventTriggerTableRewrite(Node *parsetree, Oid tableOid, int reason)
 	List	   *runlist;
 	EventTriggerData trigdata;
 
+#if defined(__EMSCRIPTEN__) || defined(__wasi__)
+#else
 	/*
 	 * See EventTriggerDDLCommandStart for a discussion about why event
 	 * triggers are disabled in single user mode.
 	 */
 	if (!IsUnderPostmaster)
 		return;
+#endif
 
 	/*
 	 * Also do nothing if our state isn't set up, which it won't be if there

src/backend/libpq/auth.c

@@ -1866,7 +1866,7 @@ auth_peer(hbaPort *port)
 		return STATUS_ERROR;
 	}
 
-#ifndef WIN32
+#if !defined(WIN32) && !defined(__wasi__)
 	errno = 0;					/* clear errno before call */
 	pw = getpwuid(uid);
 	if (!pw)

src/backend/libpq/be-fsstubs.c

@@ -150,8 +150,12 @@ be_lo_close(PG_FUNCTION_ARGS)
  *
  *****************************************************************************/
 
+#if defined(__EMSCRIPTEN__) || defined(__wasi__)
+static int
+#else
 int
-lo_read(int fd, char *buf, int len)
+#endif
+lo_read3(int fd, char *buf, int len)
 {
 	int			status;
 	LargeObjectDesc *lobj;
@@ -178,8 +182,12 @@ lo_read(int fd, char *buf, int len)
 	return status;
 }
 
+#if defined(__EMSCRIPTEN__) || defined(__wasi__)
+static int
+#else
 int
-lo_write(int fd, const char *buf, int len)
+#endif
+lo_write3(int fd, const char *buf, int len)
 {
 	int			status;
 	LargeObjectDesc *lobj;
@@ -190,7 +198,7 @@ lo_write(int fd, const char *buf, int len)
 				 errmsg("invalid large-object descriptor: %d", fd)));
 	lobj = cookies[fd];
 
-	/* see comment in lo_read() */
+	/* see comment in lo_read3() */
 	if ((lobj->flags & IFS_WRLOCK) == 0)
 		ereport(ERROR,
 				(errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
@@ -365,7 +373,7 @@ be_loread(PG_FUNCTION_ARGS)
 		len = 0;
 
 	retval = (bytea *) palloc(VARHDRSZ + len);
-	totalread = lo_read(fd, VARDATA(retval), len);
+	totalread = lo_read3(fd, VARDATA(retval), len);
 	SET_VARSIZE(retval, totalread + VARHDRSZ);
 
 	PG_RETURN_BYTEA_P(retval);
@@ -382,7 +390,7 @@ be_lowrite(PG_FUNCTION_ARGS)
 	PreventCommandIfReadOnly("lowrite()");
 
 	bytestowrite = VARSIZE_ANY_EXHDR(wbuf);
-	totalwritten = lo_write(fd, VARDATA_ANY(wbuf), bytestowrite);
+	totalwritten = lo_write3(fd, VARDATA_ANY(wbuf), bytestowrite);
 	PG_RETURN_INT32(totalwritten);
 }
 
@@ -560,7 +568,7 @@ lo_truncate_internal(int32 fd, int64 len)
 				 errmsg("invalid large-object descriptor: %d", fd)));
 	lobj = cookies[fd];
 
-	/* see comment in lo_read() */
+	/* see comment in lo_read3() */
 	if ((lobj->flags & IFS_WRLOCK) == 0)
 		ereport(ERROR,
 				(errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),