support windows

Author: imaben

beast.c

@@ -24,11 +24,15 @@
 
 #include <sys/types.h>
 #include <sys/stat.h>
-#include <unistd.h>
 #include <fcntl.h>
 #include <signal.h>
 #include <time.h>
-#include <pwd.h>
+
+#ifdef PHP_WIN32
+#else
+	#include <pwd.h>
+	#include <unistd.h>
+#endif
 
 typedef struct yy_buffer_state *YY_BUFFER_STATE;
 
@@ -131,7 +135,9 @@ extern struct file_handler pipe_handler;
 static struct file_handler *default_file_handler = NULL;
 static struct file_handler *file_handlers[] = {
     &tmpfile_handler,
+#ifndef PHP_WIN32
     &pipe_handler,
+#endif
     NULL
 };
 
@@ -875,6 +881,9 @@ PHP_INI_END()
 
 void segmentfault_deadlock_fix(int sig)
 {
+#ifdef PHP_WIN32 // windows not support backtrace
+	beast_write_log(beast_log_error, "Segmentation fault and fix deadlock");
+#else
     void *array[10] = {0};
     size_t size;
     char **info = NULL;
@@ -891,7 +900,7 @@ void segmentfault_deadlock_fix(int sig)
         }
         free(info);
     }
-
+#endif
     beast_mm_unlock();     /* Maybe lock mm so free here */
     beast_cache_unlock();  /* Maybe lock cache so free here */
 
@@ -1034,6 +1043,7 @@ PHP_MINIT_FUNCTION(beast)
         return FAILURE;
     }
 
+#ifndef PHP_WIN32
     if (getuid() == 0 && beast_log_user) { /* Change log file owner user */
         struct passwd *pwd;
 
@@ -1050,11 +1060,17 @@ PHP_MINIT_FUNCTION(beast)
             return FAILURE;
         }
     }
+#endif
 
     old_compile_file = zend_compile_file;
     zend_compile_file = cgi_compile_file;
-
-    beast_ncpu = sysconf(_SC_NPROCESSORS_ONLN); /* Get CPU nums */
+#ifdef PHP_WIN32
+	SYSTEM_INFO info;
+	GetSystemInfo(&info);
+	beast_ncpu = info.dwNumberOfProcessors;
+#else
+	beast_ncpu = sysconf(_SC_NPROCESSORS_ONLN); /* Get CPU nums */
+#endif
     if (beast_ncpu <= 0) {
         beast_ncpu = 1;
     }

beast_log.c

@@ -2,7 +2,10 @@
 #include <string.h>
 #include <stdio.h>
 #include <stdarg.h>
+#ifdef PHP_WIN32
+#else
 #include <unistd.h>
+#endif
 #include "main/php_reentrancy.h"
 #include "beast_log.h"
 
@@ -24,6 +27,9 @@ int beast_log_init(char *log_file)
 
 int beast_log_chown(uid_t uid, gid_t gid)
 {
+#ifdef PHP_WIN32
+	return 1;
+#else
     int fd;
 
     if (!beast_log_fp) {
@@ -33,11 +39,13 @@ int beast_log_chown(uid_t uid, gid_t gid)
     fd = fileno(beast_log_fp);
 
     return fchown(fd, uid, gid);
+#endif
 }
 
 
 void beast_write_log(beast_log_level level, const char *fmt, ...)
 {
+
     struct tm local_tm, *result_tm;
     time_t the_time;
     char buf[64];

beast_log.h

@@ -1,7 +1,11 @@
 #ifndef BEAST_LOG_H
 #define BEAST_LOG_H
 
+#ifdef PHP_WIN32
+#include "win95nt.h"
+#else
 #include <unistd.h>
+#endif
 
 typedef enum {
     beast_log_debug,  /* 0 */

beast_mm.c

@@ -9,7 +9,11 @@
 #include <limits.h>
 #include <fcntl.h>
 #include <sys/types.h>
+#ifdef PHP_WIN32
+#include <Windows.h>
+#else
 #include <sys/mman.h>
+#endif
 
 #include "spinlock.h"
 #include "beast_log.h"
@@ -216,12 +220,28 @@ int beast_mm_init(int block_size)
     }
 
     /* init memory manager lock */
+#ifdef PHP_WIN32
+	mm_lock = NULL;
+	HANDLE hLockMapFile = CreateFileMapping(INVALID_HANDLE_VALUE,
+		NULL, PAGE_READWRITE, 0, sizeof(int), NULL);
+	if (hLockMapFile) {
+		mm_lock = MapViewOfFile(
+			hLockMapFile,
+			FILE_MAP_ALL_ACCESS,
+			0,
+			0,
+			sizeof(int)
+		);
+		CloseHandle(hLockMapFile);
+}
+#else
     mm_lock = (int *)mmap(NULL,
                           sizeof(int),
                           PROT_READ|PROT_WRITE,
                           MAP_SHARED|MAP_ANON,
                           -1,
                           0);
+#endif
     if (!mm_lock) {
         beast_write_log(beast_log_error,
                         "Unable alloc share memory for memory manager lock");
@@ -236,16 +256,35 @@ int beast_mm_init(int block_size)
         beast_mm_block_size = block_size;
     }
 
+#ifdef PHP_WIN32
+	HANDLE hBlockMapFile = CreateFileMapping(INVALID_HANDLE_VALUE,
+		NULL, PAGE_READWRITE, 0, beast_mm_block_size, NULL);
+	if (hBlockMapFile) {
+		shmaddr = beast_mm_block = MapViewOfFile(
+			hBlockMapFile,
+			FILE_MAP_ALL_ACCESS,
+			0,
+			0,
+			beast_mm_block_size
+		);
+		CloseHandle(hBlockMapFile);
+	}
+#else
     shmaddr = beast_mm_block = (void *)mmap(NULL,
                                             beast_mm_block_size,
                                             PROT_READ|PROT_WRITE,
                                             MAP_SHARED|MAP_ANON,
                                             -1,
                                             0);
+#endif
     if (!beast_mm_block) {
         beast_write_log(beast_log_error,
                         "Unable alloc share memory for beast");
+#ifdef PHP_WIN32
+		UnmapViewOfFile(mm_lock);
+#else
         munmap((void *)mm_lock, sizeof(int));
+#endif
         return -1;
     }
 
@@ -388,10 +427,15 @@ int beast_mm_realspace()
 void beast_mm_destroy()
 {
     if (beast_mm_initialized) {
+#ifdef PHP_WIN32
+		UnmapViewOfFile(beast_mm_block);
+		UnmapViewOfFile(mm_lock);
+#else
         /* Free cache memory */
         munmap((void *)beast_mm_block, beast_mm_block_size);
         /* Free memory lock */
         munmap((void *)mm_lock, sizeof(int));
+#endif
         beast_mm_initialized = 0;
     }
 }

cache.c

@@ -18,7 +18,9 @@
 
 #include <stdlib.h>
 #include <sys/types.h>
+#ifndef PHP_WIN32
 #include <sys/mman.h>
+#endif
 
 #include "beast_mm.h"
 #include "spinlock.h"
@@ -77,12 +79,28 @@ int beast_cache_init(int size)
     }
 
     /* init cache lock */
+#ifdef PHP_WIN32
+	cache_lock = NULL;
+	HANDLE hLockMapFile = CreateFileMapping(INVALID_HANDLE_VALUE,
+		NULL, PAGE_READWRITE, 0, sizeof(int), NULL);
+	if (hLockMapFile) {
+		cache_lock = MapViewOfFile(
+			hLockMapFile,
+			FILE_MAP_ALL_ACCESS,
+			0,
+			0,
+			sizeof(int)
+		);
+		CloseHandle(hLockMapFile);
+	}
+#else
     cache_lock = (int *)mmap(NULL,
                              sizeof(int),
                              PROT_READ|PROT_WRITE,
                              MAP_SHARED|MAP_ANON,
                              -1,
                              0);
+#endif
     if (!cache_lock) {
         beast_write_log(beast_log_error,
                         "Unable alloc share memory for cache lock");
@@ -95,16 +113,36 @@ int beast_cache_init(int size)
     /* init cache buckets's memory */
     bucket_size = sizeof(cache_item_t *) * BUCKETS_DEFAULT_SIZE;
 
+#ifdef PHP_WIN32
+	HANDLE hBucketsMapFile = CreateFileMapping(INVALID_HANDLE_VALUE,
+		NULL, PAGE_READWRITE, 0, bucket_size, NULL);
+	if (hBucketsMapFile) {
+		beast_cache_buckets = (cache_item_t **)MapViewOfFile(
+			hBucketsMapFile, 
+			FILE_MAP_ALL_ACCESS,
+			0,
+			0,
+			bucket_size
+		);
+		CloseHandle(hBucketsMapFile);
+	}
+#else
     beast_cache_buckets = (cache_item_t **)mmap(NULL,
                                                 bucket_size,
                                                 PROT_READ|PROT_WRITE,
                                                 MAP_SHARED|MAP_ANON,
                                                 -1,
                                                 0);
+#endif
+
     if (!beast_cache_buckets) {
         beast_write_log(beast_log_error,
                         "Unable alloc share memory for cache buckets");
-        munmap((void *)cache_lock, sizeof(int));
+#ifdef PHP_WIN32
+		UnmapViewOfFile(cache_lock);
+#else
+		munmap((void *)cache_lock, sizeof(int));
+#endif
         beast_mm_destroy();
         return -1;
     }
@@ -228,11 +266,15 @@ int beast_cache_destroy()
     beast_mm_destroy(); /* destroy memory manager */
 
     /* free cache buckets's mmap memory */
+#ifdef PHP_WIN32
+	UnmapViewOfFile((void *)cache_lock);
+	UnmapViewOfFile((void *)beast_cache_buckets);
+#else
     munmap((void *)beast_cache_buckets,
            sizeof(cache_item_t *) * BUCKETS_DEFAULT_SIZE);
 
     munmap((void *)cache_lock, sizeof(int));
-
+#endif
     beast_cache_initialization = 0;
 
     return 0;

spinlock.c

@@ -17,17 +17,23 @@
 */
 
 #include <stdlib.h>
-#include <pthread.h>
 #include "spinlock.h"
-
+#ifdef PHP_WIN32
+#include <Windows.h>
+#define __sync_bool_compare_and_swap(lock, o, n) (o == InterlockedExchange(lock, n))
+#define __asm__(c) __asm { pause }
+#define sched_yield() __asm { rep nop } 
+#else
+#include <pthread.h>
+#endif
+#include "beast_log.h"
 
 extern int beast_ncpu;
 
 
 void beast_spinlock(beast_atomic_t *lock, int pid)
 {
     int i, n;
-
     for ( ;; ) {
 
         if (*lock == 0 &&