{
const uint8_t *inbody;
const struct iovec *indyniov;
- int i = smb2req->current_idx;
uint8_t in_oplock_level;
uint32_t in_impersonation_level;
uint32_t in_desired_access;
if (!NT_STATUS_IS_OK(status)) {
return smbd_smb2_request_error(smb2req, status);
}
- inbody = (const uint8_t *)smb2req->in.vector[i+1].iov_base;
+ inbody = SMBD_SMB2_IN_BODY_PTR(smb2req);
in_oplock_level = CVAL(inbody, 0x03);
in_impersonation_level = IVAL(inbody, 0x04);
* overlap
*/
- dyn_offset = SMB2_HDR_BODY + smb2req->in.vector[i+1].iov_len;
+ dyn_offset = SMB2_HDR_BODY + SMBD_SMB2_IN_BODY_LEN(smb2req);
if (in_name_offset == 0 && in_name_length == 0) {
/* This is ok */
name_offset = in_name_offset - dyn_offset;
}
- indyniov = &smb2req->in.vector[i+2];
+ indyniov = SMBD_SMB2_IN_DYN_IOV(smb2req);
if (name_offset > indyniov->iov_len) {
return smbd_smb2_request_error(smb2req, NT_STATUS_INVALID_PARAMETER);
static uint64_t get_mid_from_smb2req(struct smbd_smb2_request *smb2req)
{
- uint8_t *reqhdr = (uint8_t *)smb2req->out.vector[smb2req->current_idx].iov_base;
+ uint8_t *reqhdr = SMBD_SMB2_OUT_HDR_PTR(smb2req);
return BVAL(reqhdr, SMB2_HDR_MESSAGE_ID);
}
NTSTATUS status;
NTSTATUS error; /* transport error */
- if (smb2req->cancelled) {
- uint64_t mid = get_mid_from_smb2req(smb2req);
- DEBUG(10,("smbd_smb2_request_create_done: cancelled mid %llu\n",
- (unsigned long long)mid ));
- error = smbd_smb2_request_error(smb2req, NT_STATUS_CANCELLED);
- if (!NT_STATUS_IS_OK(error)) {
- smbd_server_connection_terminate(smb2req->sconn,
- nt_errstr(error));
- return;
- }
- return;
- }
-
status = smbd_smb2_create_recv(tsubreq,
smb2req,
&out_oplock_level,
struct smbd_smb2_create_state {
struct smbd_smb2_request *smb2req;
struct smb_request *smb1req;
- struct timed_event *te;
+ bool open_was_deferred;
+ struct tevent_timer *te;
struct tevent_immediate *im;
struct timeval request_time;
struct file_id id;
struct timespec write_time_ts;
struct smb2_create_blobs out_context_blobs;
int requested_oplock_level;
+ struct smb2_create_blob *dhnc = NULL;
+ struct smb2_create_blob *dh2c = NULL;
+ struct smbXsrv_open *op = NULL;
ZERO_STRUCT(out_context_blobs);
in_name ));
}
+ dhnc = smb2_create_blob_find(&in_context_blobs,
+ SMB2_CREATE_TAG_DHNC);
+
+ if (dhnc) {
+ if (dhnc->data.length != 16) {
+ tevent_req_nterror(req, NT_STATUS_INVALID_PARAMETER);
+ return tevent_req_post(req, ev);
+ }
+ if (in_context_blobs.num_blobs != 1) {
+ /*
+ * DHNC should be the only one.
+ */
+ tevent_req_nterror(req, NT_STATUS_OBJECT_NAME_NOT_FOUND);
+ return tevent_req_post(req, ev);
+ }
+ }
+
+ dh2c = smb2_create_blob_find(&in_context_blobs,
+ SMB2_CREATE_TAG_DH2C);
+ if (dh2c) {
+ if (dh2c->data.length != 36) {
+ tevent_req_nterror(req, NT_STATUS_INVALID_PARAMETER);
+ return tevent_req_post(req, ev);
+ }
+ if (in_context_blobs.num_blobs != 1) {
+ /*
+ * DH2C should be the only one.
+ */
+ tevent_req_nterror(req, NT_STATUS_OBJECT_NAME_NOT_FOUND);
+ return tevent_req_post(req, ev);
+ }
+ }
+
if (IS_IPC(smb1req->conn)) {
const char *pipe_name = in_name;
+ if (dhnc || dh2c) {
+ /* durable handles are not supported on IPC$ */
+ tevent_req_nterror(req, NT_STATUS_OBJECT_NAME_NOT_FOUND);
+ return tevent_req_post(req, ev);
+ }
+
if (!lp_nt_pipe_support()) {
tevent_req_nterror(req, NT_STATUS_ACCESS_DENIED);
return tevent_req_post(req, ev);
}
info = FILE_WAS_OPENED;
} else if (CAN_PRINT(smb1req->conn)) {
+ if (dhnc || dh2c) {
+ /* durable handles are not supported on printers */
+ tevent_req_nterror(req, NT_STATUS_OBJECT_NAME_NOT_FOUND);
+ return tevent_req_post(req, ev);
+ }
+
status = file_new(smb1req, smb1req->conn, &result);
if(!NT_STATUS_IS_OK(status)) {
tevent_req_nterror(req, status);
info = FILE_WAS_CREATED;
} else {
char *fname;
- struct smb_filename *smb_fname = NULL;
struct smb2_create_blob *exta = NULL;
struct ea_list *ea_list = NULL;
struct smb2_create_blob *mxac = NULL;
struct smb2_create_blob *secd = NULL;
struct security_descriptor *sec_desc = NULL;
struct smb2_create_blob *dhnq = NULL;
- struct smb2_create_blob *dhnc = NULL;
struct smb2_create_blob *alsi = NULL;
uint64_t allocation_size = 0;
struct smb2_create_blob *twrp = NULL;
struct smb2_create_blob *qfid = NULL;
+ struct GUID create_guid = GUID_zero();
+ bool update_open = false;
+ bool durable_requested = false;
+ uint32_t durable_timeout_msec = 0;
+ bool do_durable_reconnect = false;
+ struct smb2_create_blob *dh2q = NULL;
+ uint64_t persistent_id = 0;
exta = smb2_create_blob_find(&in_context_blobs,
SMB2_CREATE_TAG_EXTA);
SMB2_CREATE_TAG_SECD);
dhnq = smb2_create_blob_find(&in_context_blobs,
SMB2_CREATE_TAG_DHNQ);
- dhnc = smb2_create_blob_find(&in_context_blobs,
- SMB2_CREATE_TAG_DHNC);
alsi = smb2_create_blob_find(&in_context_blobs,
SMB2_CREATE_TAG_ALSI);
twrp = smb2_create_blob_find(&in_context_blobs,
SMB2_CREATE_TAG_TWRP);
qfid = smb2_create_blob_find(&in_context_blobs,
SMB2_CREATE_TAG_QFID);
+ dh2q = smb2_create_blob_find(&in_context_blobs,
+ SMB2_CREATE_TAG_DH2Q);
fname = talloc_strdup(state, in_name);
if (tevent_req_nomem(fname, req)) {
}
if (exta) {
- if (dhnc) {
- tevent_req_nterror(req,NT_STATUS_OBJECT_NAME_NOT_FOUND);
- return tevent_req_post(req, ev);
- }
-
ea_list = read_nttrans_ea_list(mem_ctx,
(const char *)exta->data.data, exta->data.length);
if (!ea_list) {
}
if (mxac) {
- if (dhnc) {
- tevent_req_nterror(req, NT_STATUS_OBJECT_NAME_NOT_FOUND);
- return tevent_req_post(req, ev);
- }
-
if (mxac->data.length == 0) {
max_access_time = 0;
} else if (mxac->data.length == 8) {
if (secd) {
enum ndr_err_code ndr_err;
- if (dhnc) {
- tevent_req_nterror(req, NT_STATUS_OBJECT_NAME_NOT_FOUND);
- return tevent_req_post(req, ev);
- }
-
sec_desc = talloc_zero(state, struct security_descriptor);
if (tevent_req_nomem(sec_desc, req)) {
return tevent_req_post(req, ev);
}
if (dhnq) {
- if (dhnc) {
- tevent_req_nterror(req, NT_STATUS_OBJECT_NAME_NOT_FOUND);
+ if (dhnq->data.length != 16) {
+ tevent_req_nterror(req, NT_STATUS_INVALID_PARAMETER);
return tevent_req_post(req, ev);
}
- if (dhnq->data.length != 16) {
+ if (dh2q) {
tevent_req_nterror(req, NT_STATUS_INVALID_PARAMETER);
return tevent_req_post(req, ev);
}
+
/*
- * we don't support durable handles yet
- * and have to ignore this
+ * durable handle request is processed below.
*/
+ durable_requested = true;
+ /*
+ * Set the timeout to 16 mins.
+ *
+ * TODO: test this against Windows 2012
+ * as the default for durable v2 is 1 min.
+ */
+ durable_timeout_msec = (16*60*1000);
}
- if (dhnc) {
- if (dhnc->data.length != 16) {
+ if (dh2q) {
+ const uint8_t *p = dh2q->data.data;
+ uint32_t durable_v2_timeout = 0;
+ DATA_BLOB create_guid_blob;
+
+ if (dh2q->data.length != 32) {
tevent_req_nterror(req, NT_STATUS_INVALID_PARAMETER);
return tevent_req_post(req, ev);
}
- /* we don't support durable handles yet */
- tevent_req_nterror(req, NT_STATUS_OBJECT_NAME_NOT_FOUND);
- return tevent_req_post(req, ev);
+
+ if (dhnq) {
+ tevent_req_nterror(req, NT_STATUS_INVALID_PARAMETER);
+ return tevent_req_post(req, ev);
+ }
+
+ durable_v2_timeout = IVAL(p, 0);
+ create_guid_blob = data_blob_const(p + 16, 16);
+
+ status = GUID_from_ndr_blob(&create_guid_blob,
+ &create_guid);
+ if (tevent_req_nterror(req, status)) {
+ return tevent_req_post(req, ev);
+ }
+ /*
+ * we need to store the create_guid later
+ */
+ update_open = true;
+
+ /*
+ * durable handle v2 request processed below
+ */
+ durable_requested = true;
+ durable_timeout_msec = durable_v2_timeout;
+ if (durable_timeout_msec == 0) {
+ /*
+ * Set the timeout to 1 min as default.
+ *
+ * This matches Windows 2012.
+ */
+ durable_timeout_msec = (60*1000);
+ }
}
- if (alsi) {
- if (dhnc) {
- tevent_req_nterror(req, NT_STATUS_OBJECT_NAME_NOT_FOUND);
+ if (dhnc) {
+ persistent_id = BVAL(dhnc->data.data, 0);
+
+ do_durable_reconnect = true;
+ }
+
+ if (dh2c) {
+ const uint8_t *p = dh2c->data.data;
+ DATA_BLOB create_guid_blob;
+
+ persistent_id = BVAL(p, 0);
+ create_guid_blob = data_blob_const(p + 16, 16);
+
+ status = GUID_from_ndr_blob(&create_guid_blob,
+ &create_guid);
+ if (tevent_req_nterror(req, status)) {
return tevent_req_post(req, ev);
}
+ do_durable_reconnect = true;
+ }
+
+ if (alsi) {
if (alsi->data.length != 8) {
tevent_req_nterror(req, NT_STATUS_INVALID_PARAMETER);
return tevent_req_post(req, ev);
time_t t;
struct tm *tm;
- if (dhnc) {
- tevent_req_nterror(req, NT_STATUS_OBJECT_NAME_NOT_FOUND);
- return tevent_req_post(req, ev);
- }
-
if (twrp->data.length != 8) {
tevent_req_nterror(req, NT_STATUS_INVALID_PARAMETER);
return tevent_req_post(req, ev);
in_create_options &= ~(0x10);/* NTCREATEX_OPTIONS_SYNC_ALERT */
in_create_options &= ~(0x20);/* NTCREATEX_OPTIONS_ASYNC_ALERT */
- /*
- * For a DFS path the function parse_dfs_path()
- * will do the path processing.
- */
+ in_file_attributes &= ~FILE_FLAG_POSIX_SEMANTICS;
- if (!(smb1req->flags2 & FLAGS2_DFS_PATHNAMES)) {
- /* convert '\\' into '/' */
- status = check_path_syntax(fname);
+ DEBUG(10, ("smbd_smb2_create_send: open execution phase\n"));
+
+ /*
+ * For the backend file open procedure, there are
+ * two possible modes: durable_reconnect or not.
+ */
+ if (do_durable_reconnect) {
+ DATA_BLOB new_cookie = data_blob_null;
+ NTTIME now = timeval_to_nttime(&smb2req->request_time);
+
+ status = smb2srv_open_recreate(smb2req->sconn->conn,
+ smb1req->conn->session_info,
+ persistent_id, create_guid,
+ now, &op);
if (!NT_STATUS_IS_OK(status)) {
+ DEBUG(3, ("smbd_smb2_create_send: "
+ "smb2srv_open_recreate failed: %s\n",
+ nt_errstr(status)));
tevent_req_nterror(req, status);
return tevent_req_post(req, ev);
}
- }
- status = filename_convert(req,
- smb1req->conn,
- smb1req->flags2 & FLAGS2_DFS_PATHNAMES,
- fname,
- 0, /* unix_convert flags */
- NULL, /* ppath_contains_wcards */
- &smb_fname);
- if (!NT_STATUS_IS_OK(status)) {
- tevent_req_nterror(req, status);
- return tevent_req_post(req, ev);
- }
+ DEBUG(10, ("smb2_create_send: %s to recreate the "
+ "smb2srv_open struct for a durable handle.\n",
+ op->global->durable ? "succeded" : "failed"));
- in_file_attributes &= ~FILE_FLAG_POSIX_SEMANTICS;
+ if (!op->global->durable) {
+ talloc_free(op);
+ tevent_req_nterror(req,
+ NT_STATUS_OBJECT_NAME_NOT_FOUND);
+ return tevent_req_post(req, ev);
+ }
- status = SMB_VFS_CREATE_FILE(smb1req->conn,
- smb1req,
- 0, /* root_dir_fid */
- smb_fname,
- in_desired_access,
- in_share_access,
- in_create_disposition,
- in_create_options,
- in_file_attributes,
- map_smb2_oplock_levels_to_samba(requested_oplock_level),
- allocation_size,
- 0, /* private_flags */
- sec_desc,
- ea_list,
- &result,
- &info);
- if (!NT_STATUS_IS_OK(status)) {
- if (open_was_deferred(smb1req->sconn, smb1req->mid)) {
- return req;
+ status = SMB_VFS_DURABLE_RECONNECT(smb1req->conn,
+ smb1req,
+ op, /* smbXsrv_open input */
+ op->global->backend_cookie,
+ op, /* TALLOC_CTX */
+ &result, &new_cookie);
+ if (!NT_STATUS_IS_OK(status)) {
+ NTSTATUS return_status;
+
+ return_status = NT_STATUS_OBJECT_NAME_NOT_FOUND;
+
+ DEBUG(3, ("smbd_smb2_create_send: "
+ "durable_reconnect failed: %s => %s\n",
+ nt_errstr(status),
+ nt_errstr(return_status)));
+
+ tevent_req_nterror(req, return_status);
+ return tevent_req_post(req, ev);
}
- tevent_req_nterror(req, status);
- return tevent_req_post(req, ev);
+
+ data_blob_free(&op->global->backend_cookie);
+ op->global->backend_cookie = new_cookie;
+
+ op->status = NT_STATUS_OK;
+ op->global->disconnect_time = 0;
+
+ /* save the timout for later update */
+ durable_timeout_msec = op->global->durable_timeout_msec;
+
+ update_open = true;
+
+ info = FILE_WAS_OPENED;
+ } else {
+ struct smb_filename *smb_fname = NULL;
+
+ /*
+ * For a DFS path the function parse_dfs_path()
+ * will do the path processing.
+ */
+
+ if (!(smb1req->flags2 & FLAGS2_DFS_PATHNAMES)) {
+ /* convert '\\' into '/' */
+ status = check_path_syntax(fname);
+ if (!NT_STATUS_IS_OK(status)) {
+ tevent_req_nterror(req, status);
+ return tevent_req_post(req, ev);
+ }
+ }
+
+ status = filename_convert(req,
+ smb1req->conn,
+ smb1req->flags2 & FLAGS2_DFS_PATHNAMES,
+ fname,
+ 0, /* unix_convert flags */
+ NULL, /* ppath_contains_wcards */
+ &smb_fname);
+ if (!NT_STATUS_IS_OK(status)) {
+ tevent_req_nterror(req, status);
+ return tevent_req_post(req, ev);
+ }
+
+ status = SMB_VFS_CREATE_FILE(smb1req->conn,
+ smb1req,
+ 0, /* root_dir_fid */
+ smb_fname,
+ in_desired_access,
+ in_share_access,
+ in_create_disposition,
+ in_create_options,
+ in_file_attributes,
+ map_smb2_oplock_levels_to_samba(requested_oplock_level),
+ allocation_size,
+ 0, /* private_flags */
+ sec_desc,
+ ea_list,
+ &result,
+ &info);
+ if (!NT_STATUS_IS_OK(status)) {
+ if (open_was_deferred(smb1req->sconn, smb1req->mid)) {
+ return req;
+ }
+ tevent_req_nterror(req, status);
+ return tevent_req_post(req, ev);
+ }
+ op = result->op;
}
+ /*
+ * here we have op == result->op
+ */
+
+ DEBUG(10, ("smbd_smb2_create_send: "
+ "response construction phase\n"));
+
if (mxac) {
NTTIME last_write_time;
status = smbd_calculate_access_mask(smb1req->conn,
result->fsp_name,
+ false,
SEC_FLAG_MAXIMUM_ALLOWED,
&max_access_granted);
}
}
+ if (durable_requested &&
+ BATCH_OPLOCK_TYPE(result->oplock_type))
+ {
+ status = SMB_VFS_DURABLE_COOKIE(result,
+ op,
+ &op->global->backend_cookie);
+ if (!NT_STATUS_IS_OK(status)) {
+ op->global->backend_cookie = data_blob_null;
+ }
+ }
+ if (op->global->backend_cookie.length > 0) {
+ update_open = true;
+
+ op->global->durable = true;
+ op->global->durable_timeout_msec = durable_timeout_msec;
+ }
+
+ if (update_open) {
+ op->global->create_guid = create_guid;
+
+ status = smbXsrv_open_update(op);
+ DEBUG(10, ("smb2_create_send: smbXsrv_open_update "
+ "returned %s\n",
+ nt_errstr(status)));
+ if (!NT_STATUS_IS_OK(status)) {
+ tevent_req_nterror(req, status);
+ return tevent_req_post(req, ev);
+ }
+ }
+
+ if (dhnq && op->global->durable) {
+ uint8_t p[8] = { 0, };
+ DATA_BLOB blob = data_blob_const(p, sizeof(p));
+
+ status = smb2_create_blob_add(state,
+ &out_context_blobs,
+ SMB2_CREATE_TAG_DHNQ,
+ blob);
+ if (!NT_STATUS_IS_OK(status)) {
+ tevent_req_nterror(req, status);
+ return tevent_req_post(req, ev);
+ }
+ }
+
+ if (dh2q && op->global->durable) {
+ uint8_t p[8] = { 0, };
+ DATA_BLOB blob = data_blob_const(p, sizeof(p));
+ uint32_t durable_v2_response_flags = 0;
+
+ SIVAL(p, 0, op->global->durable_timeout_msec);
+ SIVAL(p, 4, durable_v2_response_flags);
+
+ status = smb2_create_blob_add(state, &out_context_blobs,
+ SMB2_CREATE_TAG_DH2Q,
+ blob);
+ if (!NT_STATUS_IS_OK(status)) {
+ tevent_req_nterror(req, status);
+ return tevent_req_post(req, ev);
+ }
+ }
+
if (qfid) {
uint8_t p[32];
uint64_t file_index = get_FileIndex(result->conn,
if (state->out_file_attributes == 0) {
state->out_file_attributes = FILE_ATTRIBUTE_NORMAL;
}
- state->out_file_id_persistent = fsp_persistent_id(result);
- state->out_file_id_volatile = result->fnum;
+ state->out_file_id_persistent = result->op->global->open_persistent_id;
+ state->out_file_id_volatile = result->op->global->open_volatile_id;
state->out_context_blobs = out_context_blobs;
DEBUG(10,("smbd_smb2_create_send: %s - %s\n",
if (!smb2req) {
return false;
}
- if (smb2req->async_te == NULL) {
- return false;
- }
req = smb2req->subreq;
if (!req) {
return false;
if (!state) {
return false;
}
+ if (!state->open_was_deferred) {
+ return false;
+ }
if (p_request_time) {
*p_request_time = state->request_time;
}
return false;
}
/* It's not in progress if there's no timeout event. */
- if (!state->te) {
+ if (!state->open_was_deferred) {
return false;
}
"mid %llu\n",
(unsigned long long)mid ));
+ state->open_was_deferred = false;
/* Ensure we don't have any outstanding timer event. */
TALLOC_FREE(state->te);
/* Ensure we don't have any outstanding immediate event. */
}
}
-void schedule_deferred_open_message_smb2(
+bool schedule_deferred_open_message_smb2(
struct smbd_server_connection *sconn, uint64_t mid)
{
struct smbd_smb2_create_state *state = NULL;
DEBUG(10,("schedule_deferred_open_message_smb2: "
"can't find mid %llu\n",
(unsigned long long)mid ));
- return;
+ return false;
}
if (!smb2req->subreq) {
- return;
+ return false;
}
if (!tevent_req_is_in_progress(smb2req->subreq)) {
- return;
+ return false;
}
state = tevent_req_data(smb2req->subreq,
struct smbd_smb2_create_state);
if (!state) {
- return;
+ return false;
}
/* Ensure we don't have any outstanding timer event. */
if (!state->im) {
smbd_server_connection_terminate(smb2req->sconn,
nt_errstr(NT_STATUS_NO_MEMORY));
- return;
+ return false;
}
DEBUG(10,("schedule_deferred_open_message_smb2: "
smb2req->sconn->ev_ctx,
smbd_smb2_create_request_dispatch_immediate,
smb2req);
-}
-
-/*********************************************************
- Re-process this call.
-*********************************************************/
-
-static void smb2_deferred_open_timer(struct event_context *ev,
- struct timed_event *te,
- struct timeval _tval,
- void *private_data)
-{
- NTSTATUS status;
- struct smbd_smb2_create_state *state = NULL;
- struct smbd_smb2_request *smb2req = talloc_get_type(private_data,
- struct smbd_smb2_request);
-
- DEBUG(10,("smb2_deferred_open_timer: [idx=%d], %s\n",
- smb2req->current_idx,
- tevent_req_default_print(smb2req->subreq, talloc_tos()) ));
-
- state = tevent_req_data(smb2req->subreq,
- struct smbd_smb2_create_state);
- if (!state) {
- return;
- }
- /*
- * Null this out, don't talloc_free. It will
- * be talloc_free'd by the tevent library when
- * this returns.
- */
- state->te = NULL;
- /* Ensure we don't have any outstanding immediate event. */
- TALLOC_FREE(state->im);
- /*
- * This is subtle. We must null out the callback
- * before rescheduling, else the first call to
- * tevent_req_nterror() causes the _receive()
- * function to be called, this causing tevent_req_post()
- * to crash.
- */
- tevent_req_set_callback(smb2req->subreq, NULL, NULL);
-
- status = smbd_smb2_request_dispatch(smb2req);
-
- if (!NT_STATUS_IS_OK(status)) {
- smbd_server_connection_terminate(smb2req->sconn,
- nt_errstr(status));
- }
+ return true;
}
static bool smbd_smb2_create_cancel(struct tevent_req *req)
smb2req = state->smb2req;
mid = get_mid_from_smb2req(smb2req);
- remove_deferred_open_entry(state->id, mid,
- messaging_server_id(smb2req->sconn->msg_ctx));
+ if (is_deferred_open_async(state->private_data.data)) {
+ /* Can't cancel an async create. */
+ return false;
+ }
+
remove_deferred_open_message_smb2_internal(smb2req, mid);
- smb2req->cancelled = true;
- tevent_req_done(req);
+ tevent_req_defer_callback(req, smb2req->sconn->ev_ctx);
+ tevent_req_nterror(req, NT_STATUS_CANCELLED);
return true;
}
&end_time,
true) ));
- state->te = tevent_add_timer(smb2req->sconn->ev_ctx,
- state,
- end_time,
- smb2_deferred_open_timer,
- smb2req);
- if (!state->te) {
- return false;
- }
+ state->open_was_deferred = true;
/* allow this request to be canceled */
tevent_req_set_cancel_fn(req, smbd_smb2_create_cancel);
git.samba.org / obnox / samba / samba-obnox.git / blobdiff