From: "Joost Kraaijeveld" <JKraaijeveld@askesis.nl>

To: "Pgsql-Ports@Postgresql. Org" <pgsql-ports@postgreSQL.org>

Subject: RE: [PORTS] Re: psql under win32

Date: Wed, 21 Apr 1999 07:07:47 +0200

Message-ID: <000001be8bb4$e59b0ab0$0300a8c0@abraracourcix.askesis.nl>

MIME-Version: 1.0

Installing PostgreSQL on NT:

---------------------------------------------------------------------------

1. Download the Cygwin32 IPC Package by Ludovic LANGE

http://www.multione.capgemini.fr:80/tools/pack_ipc/current.tar.gz

2. Untar the package and follow the readme instructions.

3. Apply the patchpgsql/src/win32/ipc.patch to the cygipc sources

3. Apply the patchat the end of this file to the cygipc sources

before compiling the library.

4. I tested 1.03.

5. I used the \cygwin-b20\h-i568-cygwin32\i586-cygwin32\lib and

PS: If you still have problems you can mail to Dan Horak <dan.horak@email.cz>

who is the maintainer for the win32 port

---------------------------------------------------------------------------

*** ./ipc-daemon.c.origTue Dec 01 00:04:24 1998

--- ./ipc-daemon.cFri Sep 24 13:34:16 1999

***************

*** 270,285 ****

{

itoa(100*id+Index, LBuff) ;

LHandle = OpenSemaphore(SEMAPHORE_ALL_ACCESS, FALSE, LBuff) ;

! while (LAdrSem->current_nb[id].current_nb[Index] > 0 )

! {

! WaitForSingleObject(LHandle, 0) ;

! LAdrSem->current_nb[id].current_nb[Index]-- ;

! }

! CloseHandle(LHandle) ;

}

LAdrSem->semary[id] = IPC_UNUSED ;

LAdrSem->state[id] = 0 ;

}

else

{

for (Index = 0; Index < sma->sem_nsems; Index++)

--- 270,284 ----

{

itoa(100*id+Index, LBuff) ;

LHandle = OpenSemaphore(SEMAPHORE_ALL_ACCESS, FALSE, LBuff) ;

! while (WaitForSingleObject(LHandle, 0) == WAIT_OBJECT_0)

! ;

! LAdrSem->current_nb[id].current_nb[Index] = 0;

! CloseHandle(LHandle) ;

}

LAdrSem->semary[id] = IPC_UNUSED ;

LAdrSem->state[id] = 0 ;

}

+ /*

else

{

for (Index = 0; Index < sma->sem_nsems; Index++)

***************

*** 288,293 ****

--- 287,293 ----

LHandle = OpenSemaphore(SEMAPHORE_ALL_ACCESS, FALSE, LBuff) ;

}

}

+ */

}

}

*** ./msg.c.origTue Dec 01 00:16:09 1998

--- ./msg.cFri Sep 17 12:50:50 1999

***************

*** 57,62 ****

--- 57,77 ----

static int GFirstMsg = 0;/*PCPC*/

static int GFdMsg ;/*PCPC*/

+ /*****************************************/

+ /*Initialization of static variables */

+ /*****************************************/

+ static pid_t GProcessId = 0;

+ static void init_globals(void)

+ {

+ pid_t pid;

+

+ if (pid=getpid(), pid != GProcessId)

+ {

+ GFirstMsg = 0;

+ msgbytes = msghdrs = msg_seq = used_queues = max_msqid = 0;

+ GProcessId = pid;

+ }

+ }

/************************************************************************/

/* Demande d'acces a la zone partagee de gestion des semaphores*/

/************************************************************************/

***************

*** 79,84 ****

--- 94,100 ----

{

int LRet ;

+ init_globals();

if( GFirstMsg == 0 )

{

if( IsGSemMsgExist() )

*** ./sem.c.origTue Dec 01 00:16:25 1998

--- ./sem.cFri Sep 17 12:47:11 1999

***************

*** 58,63 ****

--- 58,78 ----

static int GFirstSem = 0;/*PCPC*/

static int GFdSem ;/*PCPC*/

+ static pid_tGProcessId = 0;

+

+ static voidinit_globals(void)

+ {

+ pid_t pid;

+

+ if (pid=getpid(), pid != GProcessId)

+ {

+ GFirstSem = 0;

+ used_sems = used_semids = max_semid = 0;

+ sem_seq = 0;

+ GProcessId = pid;

+ }

+ }

+

/************************************************************************/

/* Demande d'acces a la zone partagee de gestion des semaphores*/

/************************************************************************/

***************

*** 77,82 ****

--- 92,98 ----

{

int LRet ;

+ init_globals();

if( GFirstSem == 0 )

{

if( IsGSemSemExist() )

***************

*** 187,193 ****

{

CloseHandle ( LHandle ) ;

}

! LHandle = CreateSemaphore(NULL, 0, 0x7FFFFFFF, LBuff) ;

if( LHandle == NULL )

{

printf( "Creation de Semaphore \"Sem\" impossible\n" ) ;

--- 203,209 ----

{

CloseHandle ( LHandle ) ;

}

! LHandle = CreateSemaphore(NULL, 0, 1, LBuff) ;

if( LHandle == NULL )

{

printf( "Creation de Semaphore \"Sem\" impossible\n" ) ;

***************

*** 357,371 ****

debug_printf("do_semop : return -EACCES\n");

CYGWIN32_IPCNT_RETURN (-EACCES) ;

}

! ReleaseSemaphore(LHandle, sop->sem_op, &LVal) ;

! shareadrsem->current_nb[id].current_nb[sop->sem_num] +=

! sop->sem_op ;

sem_deconnect() ;

} else {

if( sop->sem_flg == IPC_NOWAIT )

{

! LRet = WaitForSingleObject(LHandle, 0) ;

! if( LRet == WAIT_TIMEOUT )

{

debug_printf("do_semop : return -EAGAIN\n");

CYGWIN32_IPCNT_RETURN (-EAGAIN) ;

--- 373,386 ----

debug_printf("do_semop : return -EACCES\n");

CYGWIN32_IPCNT_RETURN (-EACCES) ;

}

! shareadrsem->current_nb[id].current_nb[sop->sem_num] +=

! sop->sem_op ;

sem_deconnect() ;

+ ReleaseSemaphore(LHandle, 1 , &LVal) ;

} else {

if( sop->sem_flg == IPC_NOWAIT )

{

! if( sop->sem_op + shareadrsem->current_nb[id].current_nb[sop->sem_num] <0 )

{

debug_printf("do_semop : return -EAGAIN\n");

CYGWIN32_IPCNT_RETURN (-EAGAIN) ;

***************

*** 375,390 ****

debug_printf("do_semop : return -EACCES\n");

CYGWIN32_IPCNT_RETURN (-EACCES) ;

}

! shareadrsem->current_nb[id].current_nb[sop->sem_num] -= 1 ;

sem_deconnect() ;

} else {

! LRet = WaitForSingleObject(LHandle, INFINITE) ;

if (sem_connect() == 0)

{

debug_printf("do_semop : return -EACCES\n");

CYGWIN32_IPCNT_RETURN (-EACCES) ;

}

! shareadrsem->current_nb[id].current_nb[sop->sem_num] -= 1 ;

sem_deconnect() ;

}

}

--- 390,407 ----

debug_printf("do_semop : return -EACCES\n");

CYGWIN32_IPCNT_RETURN (-EACCES) ;

}

! shareadrsem->current_nb[id].current_nb[sop->sem_num] += sop->sem_op;

sem_deconnect() ;

} else {

! while(sop->sem_op + shareadrsem->current_nb[id].current_nb[sop->sem_num] <0)

! LRet = WaitForSingleObject(LHandle, INFINITE) ;

!

if (sem_connect() == 0)

{

debug_printf("do_semop : return -EACCES\n");

CYGWIN32_IPCNT_RETURN (-EACCES) ;

}

! shareadrsem->current_nb[id].current_nb[sop->sem_num] += sop->sem_op ;

sem_deconnect() ;

}

}

***************

*** 435,441 ****

char LBuff[100] ;

HANDLE LHandle ;

long LPrevious ;

- int LIndex;

debug_printf("semctl : semid=%X semnum=%X cmd=0x%02X arg=%p\n",semid,semnum,cmd,arg);

if (semid < 0 || semnum < 0 || cmd < 0)

--- 452,457 ----

***************

*** 568,589 ****

if( LHandle != NULL )

{

if( arg.val > shareadrsem->current_nb[id].current_nb[semnum] )

! {

! ReleaseSemaphore(LHandle,

! arg.val-shareadrsem->current_nb[id].current_nb[semnum],

! &LPrevious) ;

! }

! else if (arg.val <

! shareadrsem->current_nb[id].current_nb[semnum] )

! {

! for( LIndex = arg.val;

! LIndex < shareadrsem->current_nb[id].current_nb[semnum];

! LIndex++ )

! {

! WaitForSingleObject(LHandle, 0) ;

! }

! }

! shareadrsem->current_nb[id].current_nb[semnum] = arg.val ;

}

debug_printf("semctl : SETVAL : return 0\n");

CYGWIN32_IPCNT_RETURN_DECONNECT (0);

--- 584,591 ----

if( LHandle != NULL )

{

if( arg.val > shareadrsem->current_nb[id].current_nb[semnum] )

! ReleaseSemaphore(LHandle,1,&LPrevious) ;

! shareadrsem->current_nb[id].current_nb[semnum] = arg.val ;

}

debug_printf("semctl : SETVAL : return 0\n");

CYGWIN32_IPCNT_RETURN_DECONNECT (0);

*** ./shm.c.origFri Sep 17 12:46:24 1999

--- ./shm.cFri Sep 17 12:47:11 1999

***************

*** 59,64 ****

--- 59,81 ----

static int GFirstShm = 0;/*PCPC*/

static int GFdShm ;/*PCPC*/

+ /*****************************************/

+ /*Initialization of static variables */

+ /*****************************************/

+ static pid_t GProcessId = 0;

+ static void init_globals(void)

+ {

+ pid_t pid;

+

+ if (pid=getpid(), pid != GProcessId)

+ {

+ GFirstShm = 0;

+ shm_rss = shm_swp = max_shmid = 0;

+ shm_seq = 0;

+ GProcessId = pid;

+ }

+ }

+

/************************************************************************/

/* Demande d'acces a la zone partagee de gestion des shm*/

/************************************************************************/

***************

*** 82,87 ****

--- 99,105 ----

{

int LRet ;

+ init_globals();

if( GFirstShm == 0 )

{

if( IsGSemShmExist() )

time=localtime(&tm);

sprintf(pid,"[%d]",MyProcPid);

sprintf(timestamp,"%02d%02d%02d.%02d:%02d:%02d.%03d %7s ",

time->tm_year,time->tm_mon+1,time->tm_mday,

sprintf(timestamp,"%04d%02d%02d.%02d:%02d:%02d.%03d %7s ",

time->tm_year+1900,time->tm_mon+1,time->tm_mday,

time->tm_hour,time->tm_min,time->tm_sec,

(int) (tv.tv_usec/1000),pid);