files/change.c

   1 /*
   2  * Win32 file change notification functions
   3  *
   4  * Copyright 1998 Ulrich Weigand
   5  */
   6
   7 #include <assert.h>
   8 #include <stdlib.h>
   9 #include <unistd.h>
  10 #include <string.h>
  11 #include <time.h>
  12 #include "windows.h"
  13 #include "winbase.h"
  14 #include "winerror.h"
  15 #include "process.h"
  16 #include "thread.h"
  17 #include "heap.h"
  18 #include "debug.h"
  19
  20 static BOOL32 CHANGE_Signaled( K32OBJ *obj, DWORD thread_id );
  21 static BOOL32 CHANGE_Satisfied( K32OBJ *obj, DWORD thread_id );
  22 static void CHANGE_AddWait( K32OBJ *obj, DWORD thread_id );
  23 static void CHANGE_RemoveWait( K32OBJ *obj, DWORD thread_id );
  24 static void CHANGE_Destroy( K32OBJ *obj );
  25
  26 const K32OBJ_OPS CHANGE_Ops =
  27 {
  28     CHANGE_Signaled,    /* signaled */
  29     CHANGE_Satisfied,   /* satisfied */
  30     CHANGE_AddWait,     /* add_wait */
  31     CHANGE_RemoveWait,  /* remove_wait */
  32     NULL,               /* read */
  33     NULL,               /* write */
  34     CHANGE_Destroy      /* destroy */
  35 };
  36
  37 /* The change notification object */
  38 typedef struct
  39 {
  40     K32OBJ       header;
  41
  42     LPSTR        lpPathName;
  43     BOOL32       bWatchSubtree;
  44     DWORD        dwNotifyFilter;
  45
  46     THREAD_QUEUE wait_queue;
  47     BOOL32       notify;
  48
  49 } CHANGE_OBJECT;
  50
  51 /***********************************************************************
  52  *           CHANGE_Signaled
  53  */
  54 static BOOL32 CHANGE_Signaled( K32OBJ *obj, DWORD thread_id )
  55 {
  56     CHANGE_OBJECT *change = (CHANGE_OBJECT *)obj;
  57     assert( obj->type == K32OBJ_CHANGE );
  58     return change->notify;
  59 }
  60
  61 /***********************************************************************
  62  *           CHANGE_Satisfied
  63  *
  64  * Wait on this object has been satisfied.
  65  */
  66 static BOOL32 CHANGE_Satisfied( K32OBJ *obj, DWORD thread_id )
  67 {
  68     assert( obj->type == K32OBJ_CHANGE );
  69     return FALSE;  /* Not abandoned */
  70 }
  71
  72 /***********************************************************************
  73  *           CHANGE_AddWait
  74  *
  75  * Add thread to object wait queue.
  76  */
  77 static void CHANGE_AddWait( K32OBJ *obj, DWORD thread_id )
  78 {
  79     CHANGE_OBJECT *change = (CHANGE_OBJECT *)obj;
  80     assert( obj->type == K32OBJ_CHANGE );
  81     THREAD_AddQueue( &change->wait_queue, THREAD_ID_TO_THDB(thread_id) );
  82 }
  83
  84 /***********************************************************************
  85  *           CHANGE_RemoveWait
  86  *
  87  * Remove thread from object wait queue.
  88  */
  89 static void CHANGE_RemoveWait( K32OBJ *obj, DWORD thread_id )
  90 {
  91     CHANGE_OBJECT *change = (CHANGE_OBJECT *)obj;
  92     assert( obj->type == K32OBJ_CHANGE );
  93     THREAD_RemoveQueue( &change->wait_queue, THREAD_ID_TO_THDB(thread_id) );
  94 }
  95
  96 /****************************************************************************
  97  *              CHANGE_Destroy
  98  */
  99 static void CHANGE_Destroy( K32OBJ *obj )
 100 {
 101     CHANGE_OBJECT *change = (CHANGE_OBJECT *)obj;
 102     assert( obj->type == K32OBJ_CHANGE );
 103
 104     if ( change->lpPathName )
 105     {
 106         HeapFree( SystemHeap, 0, change->lpPathName );
 107         change->lpPathName = NULL;
 108     }
 109
 110     obj->type = K32OBJ_UNKNOWN;
 111     HeapFree( SystemHeap, 0, change );
 112 }
 113
 114 /****************************************************************************
 115  *              FindFirstChangeNotification32A (KERNEL32.248)
 116  */
 117 HANDLE32 WINAPI FindFirstChangeNotification32A( LPCSTR lpPathName,
 118                                                 BOOL32 bWatchSubtree,
 119                                                 DWORD dwNotifyFilter )
 120 {
 121     HANDLE32 handle;
 122     CHANGE_OBJECT *change;
 123
 124     change = HeapAlloc( SystemHeap, 0, sizeof(CHANGE_OBJECT) );
 125     if (!change) return INVALID_HANDLE_VALUE32;
 126
 127     change->header.type = K32OBJ_CHANGE;
 128     change->header.refcount = 1;
 129
 130     change->lpPathName = HEAP_strdupA( SystemHeap, 0, lpPathName );
 131     change->bWatchSubtree = bWatchSubtree;
 132     change->dwNotifyFilter = dwNotifyFilter;
 133
 134     change->wait_queue = NULL;
 135     change->notify = FALSE;
 136
 137     handle = HANDLE_Alloc( PROCESS_Current(), &change->header,
 138                            FILE_ALL_ACCESS /*FIXME*/, TRUE, -1 );
 139     /* If the allocation failed, the object is already destroyed */
 140     if (handle == INVALID_HANDLE_VALUE32) change = NULL;
 141     return handle;
 142 }
 143
 144 /****************************************************************************
 145  *              FindFirstChangeNotification32W (KERNEL32.249)
 146  */
 147 HANDLE32 WINAPI FindFirstChangeNotification32W( LPCWSTR lpPathName,
 148                                                 BOOL32 bWatchSubtree,
 149                                                 DWORD dwNotifyFilter)
 150 {
 151     LPSTR nameA = HEAP_strdupWtoA( GetProcessHeap(), 0, lpPathName );
 152     HANDLE32 ret = FindFirstChangeNotification32A( nameA, bWatchSubtree,
 153                                                           dwNotifyFilter );
 154     if (nameA) HeapFree( GetProcessHeap(), 0, nameA );
 155     return ret;
 156 }
 157
 158 /****************************************************************************
 159  *              FindNextChangeNotification (KERNEL32.252)
 160  */
 161 BOOL32 WINAPI FindNextChangeNotification( HANDLE32 handle )
 162 {
 163     CHANGE_OBJECT *change;
 164
 165     SYSTEM_LOCK();
 166     if (!(change = (CHANGE_OBJECT *)HANDLE_GetObjPtr( PROCESS_Current(),
 167                                                       handle, K32OBJ_CHANGE,
 168                                                       0 /*FIXME*/, NULL )) )
 169     {
 170         SYSTEM_UNLOCK();
 171         return FALSE;
 172     }
 173
 174     change->notify = FALSE;
 175     K32OBJ_DecCount( &change->header );
 176     SYSTEM_UNLOCK();
 177     return TRUE;
 178 }
 179
 180 /****************************************************************************
 181  *              FindCloseChangeNotification (KERNEL32.247)
 182  */
 183 BOOL32 WINAPI FindCloseChangeNotification( HANDLE32 handle)
 184 {
 185     return CloseHandle( handle );
 186 }
 187