} locks;
} smb1;
struct {
- struct tevent_context *event_ctx;
struct tevent_queue *recv_queue;
struct tevent_queue *send_queue;
struct tstream_context *stream;
}
subreq = smbd_smb2_oplock_break_send(req,
- req->sconn->smb2.event_ctx,
+ req->sconn->ev_ctx,
req,
in_oplock_level,
in_file_id_volatile);
}
tsubreq = smbd_smb2_create_send(smb2req,
- smb2req->sconn->smb2.event_ctx,
+ smb2req->sconn->ev_ctx,
smb2req,
in_oplock_level,
in_impersonation_level,
(unsigned long long)mid ));
tevent_schedule_immediate(state->im,
- smb2req->sconn->smb2.event_ctx,
+ smb2req->sconn->ev_ctx,
smbd_smb2_create_request_dispatch_immediate,
smb2req);
}
&end_time,
true) ));
- state->te = event_add_timed(smb2req->sconn->smb2.event_ctx,
+ state->te = tevent_add_timer(smb2req->sconn->ev_ctx,
state,
end_time,
smb2_deferred_open_timer,
}
subreq = smbd_smb2_find_send(req,
- req->sconn->smb2.event_ctx,
+ req->sconn->ev_ctx,
req,
in_file_info_class,
in_flags,
}
subreq = smbd_smb2_flush_send(req,
- req->sconn->smb2.event_ctx,
+ req->sconn->ev_ctx,
req,
in_file_id_volatile);
if (subreq == NULL) {
}
subreq = smbd_smb2_getinfo_send(req,
- req->sconn->smb2.event_ctx,
+ req->sconn->ev_ctx,
req,
in_info_type,
in_file_info_class,
}
subreq = smbd_smb2_ioctl_send(req,
- req->sconn->smb2.event_ctx,
+ req->sconn->ev_ctx,
req,
in_ctl_code,
in_file_id_volatile,
TALLOC_FREE(subreq);
subreq = np_read_send(state->smbreq->conn,
- state->smb2req->sconn->smb2.event_ctx,
+ state->smb2req->sconn->ev_ctx,
state->fsp->fake_file_handle,
state->out_output.data,
state->out_output.length);
}
subreq = smbd_smb2_lock_send(req,
- req->sconn->smb2.event_ctx,
+ req->sconn->ev_ctx,
req,
in_smbpid,
in_file_id_volatile,
}
subreq = smbd_smb2_notify_send(req,
- req->sconn->smb2.event_ctx,
+ req->sconn->ev_ctx,
req,
in_flags,
in_output_buffer_length,
* being arround after calling this function
*/
tevent_schedule_immediate(state->im,
- state->smb2req->sconn->smb2.event_ctx,
+ state->smb2req->sconn->ev_ctx,
smbd_smb2_notify_reply_trigger,
req);
}
}
subreq = smbd_smb2_read_send(req,
- req->sconn->smb2.event_ctx,
+ req->sconn->ev_ctx,
req,
in_smbpid,
in_file_id_volatile,
TALLOC_FREE(sconn->smb1.fde);
- sconn->smb2.event_ctx = sconn->ev_ctx;
-
sconn->smb2.recv_queue = tevent_queue_create(sconn, "smb2 recv queue");
if (sconn->smb2.recv_queue == NULL) {
return NT_STATUS_NO_MEMORY;
print_req_vectors(nreq);
}
nreq->subreq = tstream_writev_queue_send(nreq,
- nreq->sconn->smb2.event_ctx,
+ nreq->sconn->ev_ctx,
nreq->sconn->smb2.stream,
nreq->sconn->smb2.send_queue,
nreq->out.vector,
}
defer_endtime = timeval_current_ofs_usec(defer_time);
- req->async_te = tevent_add_timer(req->sconn->smb2.event_ctx,
+ req->async_te = tevent_add_timer(req->sconn->ev_ctx,
req, defer_endtime,
smbd_smb2_request_pending_timer,
req);
}
subreq = tstream_writev_queue_send(state,
- state->sconn->smb2.event_ctx,
+ state->sconn->ev_ctx,
state->sconn->smb2.stream,
state->sconn->smb2.send_queue,
state->vector,
return NT_STATUS_NO_MEMORY;
}
tevent_schedule_immediate(im,
- req->sconn->smb2.event_ctx,
+ req->sconn->ev_ctx,
smbd_smb2_request_dispatch_immediate,
req);
return NT_STATUS_OK;
}
subreq = tstream_writev_queue_send(req,
- req->sconn->smb2.event_ctx,
+ req->sconn->ev_ctx,
req->sconn->smb2.stream,
req->sconn->smb2.send_queue,
req->out.vector,
SBVAL(body, 0x10, file_id_volatile);
subreq = tstream_writev_queue_send(state,
- sconn->smb2.event_ctx,
+ sconn->ev_ctx,
sconn->smb2.stream,
sconn->smb2.send_queue,
&state->vector, 1);
}
/* ask for the next request */
- subreq = smbd_smb2_request_read_send(sconn, sconn->smb2.event_ctx, sconn);
+ subreq = smbd_smb2_request_read_send(sconn, sconn->ev_ctx, sconn);
if (subreq == NULL) {
return NT_STATUS_NO_MEMORY;
}
}
subreq = smbd_smb2_setinfo_send(req,
- req->sconn->smb2.event_ctx,
+ req->sconn->ev_ctx,
req,
in_info_type,
in_file_info_class,
}
subreq = smbd_smb2_write_send(req,
- req->sconn->smb2.event_ctx,
+ req->sconn->ev_ctx,
req,
in_smbpid,
in_file_id_volatile,