2 Unix SMB/Netbios implementation.
4 change notify handling - hash based implementation
5 Copyright (C) Jeremy Allison 1994-1998
6 Copyright (C) Andrew Tridgell 2000
8 This program is free software; you can redistribute it and/or modify
9 it under the terms of the GNU General Public License as published by
10 the Free Software Foundation; either version 2 of the License, or
11 (at your option) any later version.
13 This program is distributed in the hope that it will be useful,
14 but WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 GNU General Public License for more details.
18 You should have received a copy of the GNU General Public License
19 along with this program; if not, write to the Free Software
20 Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
25 extern int DEBUGLEVEL
;
29 time_t last_check_time
; /* time we last checked this entry */
30 time_t modify_time
; /* Info from the directory we're monitoring. */
31 time_t status_time
; /* Info from the directory we're monitoring. */
32 time_t total_time
; /* Total time of all directory entries - don't care if it wraps. */
33 unsigned int num_entries
; /* Zero or the number of files in the directory. */
37 /****************************************************************************
38 Create the hash we will use to determine if the contents changed.
39 *****************************************************************************/
40 static BOOL
notify_hash(connection_struct
*conn
, char *path
, uint32 flags
,
41 struct change_data
*data
, struct change_data
*old_data
)
53 if(vfs_stat(conn
,path
, &st
) == -1) return False
;
55 data
->modify_time
= st
.st_mtime
;
56 data
->status_time
= st
.st_ctime
;
60 * Shortcut to avoid directory scan if the time
61 * has changed - we always must return true then.
63 if (old_data
->modify_time
!= data
->modify_time
||
64 old_data
->status_time
!= data
->status_time
) {
70 * If we are to watch for changes that are only stored
71 * in inodes of files, not in the directory inode, we must
72 * scan the directory and produce a unique identifier with
73 * which we can determine if anything changed. We use the
74 * modify and change times from all the files in the
75 * directory, added together (ignoring wrapping if it's
76 * larger than the max time_t value).
79 if (!(flags
& (FILE_NOTIFY_CHANGE_SIZE
|FILE_NOTIFY_CHANGE_LAST_WRITE
))) return True
;
81 dp
= OpenDir(conn
, path
, True
);
82 if (dp
== NULL
) return False
;
84 data
->num_entries
= 0;
86 pstrcpy(full_name
, path
);
87 pstrcat(full_name
, "/");
89 fullname_len
= strlen(full_name
);
90 remaining_len
= sizeof(full_name
) - fullname_len
- 1;
91 p
= &full_name
[fullname_len
];
93 while ((fname
= ReadDirName(dp
))) {
94 if(strequal(fname
, ".") || strequal(fname
, "..")) continue;
97 safe_strcpy(p
, fname
, remaining_len
);
102 * Do the stat - but ignore errors.
104 vfs_stat(conn
,full_name
, &st
);
105 data
->total_time
+= (st
.st_mtime
+ st
.st_ctime
);
114 /****************************************************************************
115 register a change notify request
116 *****************************************************************************/
117 static void *hash_register_notify(connection_struct
*conn
, char *path
, uint32 flags
)
119 struct change_data data
;
121 if (!notify_hash(conn
, path
, flags
, &data
, NULL
)) return NULL
;
123 data
.last_check_time
= time(NULL
);
125 return (void *)memdup(&data
, sizeof(data
));
128 /****************************************************************************
129 Check if a change notify should be issued.
130 A time of zero means instantaneous check - don't modify the last check time.
131 *****************************************************************************/
132 static BOOL
hash_check_notify(connection_struct
*conn
, uint16 vuid
, char *path
, uint32 flags
, void *datap
, time_t t
)
134 struct change_data
*data
= (struct change_data
*)datap
;
135 struct change_data data2
;
137 if (t
&& t
< data
->last_check_time
+ lp_change_notify_timeout()) return False
;
139 if (!become_user(conn
,vuid
)) return True
;
140 if (!become_service(conn
,True
)) {
145 if (!notify_hash(conn
, path
, flags
, &data2
, data
) ||
146 data2
.modify_time
!= data
->modify_time
||
147 data2
.status_time
!= data
->status_time
||
148 data2
.total_time
!= data
->total_time
||
149 data2
.num_entries
!= data
->num_entries
) {
155 data
->last_check_time
= t
;
162 /****************************************************************************
163 remove a change notify data structure
164 *****************************************************************************/
165 static void hash_remove_notify(void *datap
)
171 /****************************************************************************
172 setup hash based change notify
173 ****************************************************************************/
174 struct cnotify_fns
*hash_notify_init(void)
176 static struct cnotify_fns cnotify
;
178 cnotify
.register_notify
= hash_register_notify
;
179 cnotify
.check_notify
= hash_check_notify
;
180 cnotify
.remove_notify
= hash_remove_notify
;
181 cnotify
.select_time
= lp_change_notify_timeout();
188 change_notify_reply_packet(cnbp->request_buf,ERRSRV,ERRaccess);
189 change_notify_reply_packet(cnbp->request_buf,0,NT_STATUS_NOTIFY_ENUM_DIR);
194 uint16 vuid = (lp_security() == SEC_SHARE) ? UID_FIELD_INVALID :
195 SVAL(cnbp->request_buf,smb_uid);