2 files changed, 75 insertions, 4 deletions

diff --git a/src/backend/postmaster/pgstat.c b/src/backend/postmaster/pgstat.c
index 2522793d2a..6b9b8ac1bc 100644
--- a/src/backend/postmaster/pgstat.c
+++ b/src/backend/postmaster/pgstat.c
@@ -13,7 +13,7 @@
  *
  *	Copyright (c) 2001-2003, PostgreSQL Global Development Group
  *
- *	$PostgreSQL: pgsql/src/backend/postmaster/pgstat.c,v 1.52 2004/01/09 04:58:09 momjian Exp $
+ *	$PostgreSQL: pgsql/src/backend/postmaster/pgstat.c,v 1.53 2004/01/11 03:49:31 momjian Exp $
  * ----------
  */
 #include "postgres.h"
@@ -50,6 +50,9 @@
 #include "utils/ps_status.h"
 #include "utils/syscache.h"
 
+#ifdef WIN32
+extern pid_t win32_forkexec(const char* path, char *argv[]);
+#endif
 
 /* ----------
  * GUC parameters
@@ -402,10 +405,13 @@ pgstat_forkexec(STATS_PROCESS_TYPE procType)
 	Assert(ac <= lengthof(av));
 
 	/* Fire off execv in child */
+#ifdef WIN32
+	pid = win32_forkexec(pg_pathname,av);
+#else
 	if ((pid = fork()) == 0 && (execv(pg_pathname,av) == -1))
 		/* FIXME: [fork/exec] suggestions for what to do here? Can't call elog... */
 		abort();
-
+#endif
 	return pid; /* Parent returns pid */
 }
 
diff --git a/src/backend/postmaster/postmaster.c b/src/backend/postmaster/postmaster.c
index 6ce0fe629b..56fec21acb 100644
--- a/src/backend/postmaster/postmaster.c
+++ b/src/backend/postmaster/postmaster.c
@@ -37,7 +37,7 @@
  *
  *
  * IDENTIFICATION
- *	  $PostgreSQL: pgsql/src/backend/postmaster/postmaster.c,v 1.357 2004/01/09 23:27:20 momjian Exp $
+ *	  $PostgreSQL: pgsql/src/backend/postmaster/postmaster.c,v 1.358 2004/01/11 03:49:31 momjian Exp $
  *
  * NOTES
  *
@@ -297,6 +297,10 @@ postmaster_error(const char *fmt,...)
 __attribute__((format(printf, 1, 2)));
 
 #ifdef EXEC_BACKEND
+#ifdef WIN32
+pid_t win32_forkexec(const char* path, char *argv[]);
+#endif
+
 static pid_t Backend_forkexec(Port *port);
 
 static unsigned long tmpBackendFileNum = 0;
@@ -923,7 +927,12 @@ pmdaemonize(int argc, char *argv[])
 	getitimer(ITIMER_PROF, &prof_itimer);
 #endif
 
+#ifdef WIN32
+	/* FIXME: [fork/exec] to be implemented? */
+	abort();
+#else
 	pid = fork();
+#endif
 	if (pid == (pid_t) -1)
 	{
 		postmaster_error("could not fork background process: %s",
@@ -2692,6 +2701,9 @@ Backend_forkexec(Port *port)
   	av[ac++] = NULL;
   	Assert(ac <= lengthof(av));
 
+#ifdef WIN32
+	pid = win32_forkexec(pg_pathname,av); /* logs on error */
+#else
 	/* Fire off execv in child */
 	if ((pid = fork()) == 0 && (execv(pg_pathname,av) == -1))
 		/*
@@ -2699,7 +2711,7 @@ Backend_forkexec(Port *port)
 		 *  Probably OK to issue error (unlike pgstat case)
 		 */
 		abort();
-
+#endif
 	return pid; /* Parent returns pid */
 }
 
@@ -3039,12 +3051,16 @@ SSDataBase(int xlop)
 
 #ifdef EXEC_BACKEND
 		/* EXEC_BACKEND case; fork/exec here */
+#ifdef WIN32
+		pid = win32_forkexec(pg_pathname,av); /* logs on error */
+#else
 		if ((pid = fork()) == 0 && (execv(pg_pathname,av) == -1))
 		{
 			/* in child */
 			elog(ERROR,"unable to execv in SSDataBase: %m");
 			exit(0);
 		}
+#endif
 #else
 		BootstrapMain(ac, av);
 		ExitPostmaster(0);
@@ -3335,3 +3351,52 @@ read_backend_variables(unsigned long id, Port *port)
 }
 
 #endif
+
+#ifdef WIN32
+
+pid_t win32_forkexec(const char* path, char *argv[])
+{
+	STARTUPINFO si;
+	PROCESS_INFORMATION pi;
+	char *p;
+	int i;
+	char cmdLine[MAXPGPATH];
+
+	/* Format the cmd line */
+	snprintf(cmdLine,sizeof(cmdLine),"%s",path);
+	i = 0;
+	while (argv[++i] != NULL)
+	{
+		/* FIXME: [fork/exec] some strlen checks might be prudent here */
+		strcat(cmdLine," ");
+		strcat(cmdLine,argv[i]);
+	}
+
+	/*
+	 * The following snippet can disappear when we consistently
+	 * use forward slashes.
+	 */
+	p = cmdLine;
+	while (*(p++) != '\0')
+		if (*p == '/') *p = '\\';
+
+	memset(&pi,0,sizeof(pi));
+	memset(&si,0,sizeof(si));
+	si.cb = sizeof(si);
+	if (!CreateProcess(NULL,cmdLine,NULL,NULL,TRUE,0,NULL,NULL,&si,&pi))
+	{
+		elog(ERROR,"CreateProcess call failed (%d): %m",GetLastError());
+		return -1;
+	}
+
+	/*
+	   FIXME: [fork/exec] we might need to keep the following handle/s,
+	   depending on how we implement signalling.
+	*/
+	CloseHandle(pi.hProcess);
+	CloseHandle(pi.hThread);
+
+	return pi.dwProcessId;
+}
+
+#endif