sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2024-12-22 13:34:15 +03:00
Code

pvfs: trigger a write time update 2 seconds after the first write

Browse Source 
metze
(This used to be commit c8e15d4c18)
This commit is contained in:
Stefan Metzmacher 2008-06-03 11:36:08 +02:00
parent 47b54c7680
commit ad19d5455e
1 changed files with 55 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
source4/ntvfs/posix/pvfs_write.c
View File

@ -22,7 +22,60 @@
#include "includes.h"
#include "vfs_posix.h"
#include "librpc/gen_ndr/security.h"
#include "lib/events/events.h"
static void pvfs_write_time_update_handler(struct event_context *ev,
struct timed_event *te,
struct timeval tv,
void *private_data)
{
struct pvfs_file_handle *h = talloc_get_type(private_data,
struct pvfs_file_handle);
struct odb_lock *lck;
NTSTATUS status;
NTTIME write_time;
lck = odb_lock(h, h->pvfs->odb_context, &h->odb_locking_key);
if (lck == NULL) {
DEBUG(0,("Unable to lock opendb for write time update\n"));
return;
}
write_time = timeval_to_nttime(&tv);
status = odb_set_write_time(lck, write_time, false);
if (!NT_STATUS_IS_OK(status)) {
DEBUG(0,("Unable to update write time: %s\n",
nt_errstr(status)));
return;
}
talloc_free(lck);
h->write_time.update_event = NULL;
}
static void pvfs_trigger_write_time_update(struct pvfs_file_handle *h)
{
struct pvfs_state *pvfs = h->pvfs;
struct timeval tv;
if (h->write_time.update_triggered) {
return;
}
tv = timeval_current_ofs(0, pvfs->writetime_delay);
h->write_time.update_triggered = true;
h->write_time.update_on_close = true;
h->write_time.update_event = event_add_timed(pvfs->ntvfs->ctx->event_ctx,
h, tv,
pvfs_write_time_update_handler,
h);
if (!h->write_time.update_event) {
DEBUG(0,("Failed event_add_timed\n"));
}
}
/*
write to a file
@ -61,6 +114,8 @@ NTSTATUS pvfs_write(struct ntvfs_module_context *ntvfs,
status = pvfs_break_level2_oplocks(f);
NT_STATUS_NOT_OK_RETURN(status);
pvfs_trigger_write_time_update(f->handle);
if (f->handle->name->stream_name) {
ret = pvfs_stream_write(pvfs,
f->handle,