sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2025-03-27 22:50:26 +03:00
Code

auth/ntlmssp: prepare update_send/recv for real async processing

Browse Source 
Signed-off-by: Stefan Metzmacher <metze@samba.org>
Reviewed-by: Andreas Schneider <asn@samba.org>
This commit is contained in:
Stefan Metzmacher 2017-06-15 00:34:26 +02:00 committed by Andreas Schneider
parent 79b891a746
commit da3baf64d5
1 changed files with 48 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
auth/ntlmssp/ntlmssp.c
View File

@ -44,6 +44,13 @@ static const struct ntlmssp_callbacks {
NTSTATUS (*sync_fn)(struct gensec_security *gensec_security,
TALLOC_CTX *out_mem_ctx,
DATA_BLOB in, DATA_BLOB *out);
struct tevent_req *(*send_fn)(TALLOC_CTX *mem_ctx,
struct tevent_context *ev,
struct gensec_security *gensec_security,
const DATA_BLOB in);
NTSTATUS (*recv_fn)(struct tevent_req *req,
TALLOC_CTX *out_mem_ctx,
DATA_BLOB *out);
} ntlmssp_callbacks[] = {
{
.role = NTLMSSP_CLIENT,
@ -146,10 +153,13 @@ static NTSTATUS gensec_ntlmssp_update_find(struct gensec_security *gensec_securi
}
struct gensec_ntlmssp_update_state {
const struct ntlmssp_callbacks *cb;
NTSTATUS status;
DATA_BLOB out;
};
static void gensec_ntlmssp_update_done(struct tevent_req *subreq);
static struct tevent_req *gensec_ntlmssp_update_send(TALLOC_CTX *mem_ctx,
struct tevent_context *ev,
struct gensec_security *gensec_security,
@ -176,6 +186,23 @@ static struct tevent_req *gensec_ntlmssp_update_send(TALLOC_CTX *mem_ctx,
return tevent_req_post(req, ev);
}
if (ntlmssp_callbacks[i].send_fn != NULL) {
struct tevent_req *subreq = NULL;
state->cb = &ntlmssp_callbacks[i];
subreq = state->cb->send_fn(state, ev,
gensec_security,
in);
if (tevent_req_nomem(subreq, req)) {
return tevent_req_post(req, ev);
}
tevent_req_set_callback(subreq,
gensec_ntlmssp_update_done,
req);
return req;
}
status = ntlmssp_callbacks[i].sync_fn(gensec_security,
state,
in, &state->out);
@ -192,6 +219,27 @@ static struct tevent_req *gensec_ntlmssp_update_send(TALLOC_CTX *mem_ctx,
return tevent_req_post(req, ev);
}
static void gensec_ntlmssp_update_done(struct tevent_req *subreq)
{
struct tevent_req *req =
tevent_req_callback_data(subreq,
struct tevent_req);
struct gensec_ntlmssp_update_state *state =
tevent_req_data(req,
struct gensec_ntlmssp_update_state);
NTSTATUS status;
status = state->cb->recv_fn(subreq, state, &state->out);
TALLOC_FREE(subreq);
if (GENSEC_UPDATE_IS_NTERROR(status)) {
tevent_req_nterror(req, status);
return;
}
state->status = status;
tevent_req_done(req);
}
static NTSTATUS gensec_ntlmssp_update_recv(struct tevent_req *req,
TALLOC_CTX *out_mem_ctx,
DATA_BLOB *out)