77 *
88 *
99 * IDENTIFICATION
10- * $Header: /cvsroot/pgsql/src/backend/commands/async.c,v 1.8 1996/12/07 04:36:38 momjian Exp $
10+ * $Header: /cvsroot/pgsql/src/backend/commands/async.c,v 1.9 1996/12/19 04:54:56 scrappy Exp $
1111 *
1212 *-------------------------------------------------------------------------
1313 */
@@ -117,13 +117,17 @@ Async_NotifyHandler(SIGNAL_ARGS)
117117if ((CurrentTransactionState -> state == TRANS_DEFAULT )&&
118118(CurrentTransactionState -> blockState == TRANS_DEFAULT )) {
119119
120+ #ifdef ASYNC_DEBUG
120121elog (DEBUG ,"Waking up sleeping backend process" );
122+ #endif
121123Async_NotifyFrontEnd ();
122124
123125 }else {
126+ #ifdef ASYNC_DEBUG
124127elog (DEBUG ,"Process is in the middle of another transaction, state = %d, block state = %d" ,
125128CurrentTransactionState -> state ,
126129CurrentTransactionState -> blockState );
130+ #endif
127131notifyFrontEndPending = 1 ;
128132 }
129133}
@@ -167,7 +171,9 @@ Async_Notify(char *relname)
167171
168172char * notifyName ;
169173
174+ #ifdef ASYNC_DEBUG
170175elog (DEBUG ,"Async_Notify: %s" ,relname );
176+ #endif
171177
172178if (!pendingNotifies )
173179pendingNotifies = DLNewList ();
@@ -249,7 +255,9 @@ Async_NotifyAtCommit()
249255if (notifyIssued ) {/* 'notify <relname>' issued by us */
250256notifyIssued = 0 ;
251257StartTransactionCommand ();
258+ #ifdef ASYNC_DEBUG
252259elog (DEBUG ,"Async_NotifyAtCommit." );
260+ #endif
253261ScanKeyEntryInitialize (& key ,0 ,
254262Anum_pg_listener_notify ,
255263Integer32EqualRegProcedure ,
@@ -268,10 +276,14 @@ Async_NotifyAtCommit()
268276tdesc ,& isnull );
269277
270278if (ourpid == DatumGetInt32 (d )) {
279+ #ifdef ASYNC_DEBUG
271280elog (DEBUG ,"Notifying self, setting notifyFronEndPending to 1" );
281+ #endif
272282notifyFrontEndPending = 1 ;
273283 }else {
284+ #ifdef ASYNC_DEBUG
274285elog (DEBUG ,"Notifying others" );
286+ #endif
275287#ifndef win32
276288if (kill (DatumGetInt32 (d ),SIGUSR2 )< 0 ) {
277289if (errno == ESRCH ) {
@@ -373,7 +385,9 @@ Async_Listen(char *relname, int pid)
373385char * relnamei ;
374386TupleDesc tupDesc ;
375387
388+ #ifdef ASYNC_DEBUG
376389elog (DEBUG ,"Async_Listen: %s" ,relname );
390+ #endif
377391for (i = 0 ;i < Natts_pg_listener ;i ++ ) {
378392nulls [i ]= ' ' ;
379393values [i ]= PointerGetDatum (NULL );
@@ -514,7 +528,9 @@ Async_NotifyFrontEnd()
514528
515529notifyFrontEndPending = 0 ;
516530
531+ #ifdef ASYNC_DEBUG
517532elog (DEBUG ,"Async_NotifyFrontEnd: notifying front end." );
533+ #endif
518534
519535StartTransactionCommand ();
520536ourpid = getpid ();