sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2025-02-02 09:47:23 +03:00
Code

opendb: send also the oplock break level on MSG_NTVFS_OPLOCK_BREAK

Browse Source 
metze
(This used to be commit 49402007f6e9e02a29792344c088e40d1a9b7acf)
This commit is contained in:
Stefan Metzmacher 2008-02-21 12:20:31 +01:00
parent 27e322bb4d
commit 6cb9c1c61d
2 changed files with 27 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source4/ntvfs/common/opendb.h
View File

@ -43,6 +43,10 @@ struct opendb_ops {
uint32_t access_mask);
};
struct opendb_oplock_break {
void *file_handle;
uint8_t level;
};
void odb_set_ops(const struct opendb_ops *new_ops);
void odb_tdb_init_ops(void);

28
source4/ntvfs/common/opendb_tdb.c
View File

@ -259,12 +259,28 @@ static NTSTATUS odb_push_record(struct odb_lock *lck, struct opendb_file *file)
/*
send an oplock break to a client
*/
static NTSTATUS odb_oplock_break_send(struct odb_context *odb, struct opendb_entry *e)
static NTSTATUS odb_oplock_break_send(struct odb_context *odb,
struct opendb_entry *e,
uint8_t level)
{
NTSTATUS status;
struct opendb_oplock_break op_break;
DATA_BLOB blob;
ZERO_STRUCT(op_break);
/* tell the server handling this open file about the need to send the client
a break */
return messaging_send_ptr(odb->ntvfs_ctx->msg_ctx, e->server,
MSG_NTVFS_OPLOCK_BREAK, e->file_handle);
op_break.file_handle = e->file_handle;
op_break.level = level;
blob = data_blob_const(&op_break, sizeof(op_break));
status = messaging_send(odb->ntvfs_ctx->msg_ctx, e->server,
MSG_NTVFS_OPLOCK_BREAK, &blob);
NT_STATUS_NOT_OK_RETURN(status);
return NT_STATUS_OK;
}
/*
@ -318,7 +334,8 @@ static NTSTATUS odb_tdb_open_file(struct odb_lock *lck, void *file_handle,
break request and suspending this call
until the break is acknowledged or the file
is closed */
odb_oplock_break_send(odb, &file.entries[i]);
odb_oplock_break_send(odb, &file.entries[i],
OPLOCK_BREAK_TO_LEVEL_II/*TODO*/);
return NT_STATUS_OPLOCK_NOT_GRANTED;
}
}
@ -342,7 +359,8 @@ static NTSTATUS odb_tdb_open_file(struct odb_lock *lck, void *file_handle,
exclusive oplocks afterwards. */
for (i=0;i<file.num_entries;i++) {
if (file.entries[i].oplock_level == OPLOCK_EXCLUSIVE) {
odb_oplock_break_send(odb, &file.entries[i]);
odb_oplock_break_send(odb, &file.entries[i],
OPLOCK_BREAK_TO_NONE/*TODO*/);
return NT_STATUS_OPLOCK_NOT_GRANTED;
}
}