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

s3:libsmb: abstract the incoming dispatch function via a function pointer

Browse Source 
This will allow handling of SMB2 in future.

metze
This commit is contained in:
Stefan Metzmacher 2011-08-12 14:50:09 +02:00
parent 58003b5a77
commit c485df9530
2 changed files with 17 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
source3/include/client.h
View File

@ -128,6 +128,17 @@ struct cli_state {
struct tevent_req *read_smb_req;
struct tevent_queue *outgoing;
struct tevent_req **pending;
/*
* The incoming dispatch function should return:
* - NT_STATUS_RETRY, if more incoming PDUs are expected.
* - NT_STATUS_OK, if no more processing is desired, e.g.
* the dispatch function called
* tevent_req_done().
* - All other return values disconnect the connection.
*/
NTSTATUS (*dispatch_incoming)(struct cli_state *cli,
TALLOC_CTX *frame,
uint8_t *inbuf);
} conn;
struct {

11
source3/libsmb/async_smb.c
View File

@ -228,6 +228,9 @@ bool cli_smb_req_set_pending(struct tevent_req *req)
}
static void cli_smb_received(struct tevent_req *subreq);
static NTSTATUS cli_state_dispatch_smb1(struct cli_state *cli,
TALLOC_CTX *frame,
uint8_t *inbuf);
static bool cli_state_receive_next(struct cli_state *cli)
{
@ -246,6 +249,8 @@ static bool cli_state_receive_next(struct cli_state *cli)
req = cli->conn.pending[0];
state = tevent_req_data(req, struct cli_smb_state);
cli->conn.dispatch_incoming = cli_state_dispatch_smb1;
/*
* We're the first ones, add the read_smb request that waits for the
* answer from the server
@ -579,10 +584,6 @@ static void cli_smb_sent(struct tevent_req *subreq)
}
}
static NTSTATUS cli_state_dispatch_smb1(struct cli_state *cli,
TALLOC_CTX *frame,
uint8_t *inbuf);
static void cli_smb_received(struct tevent_req *subreq)
{
struct cli_state *cli = tevent_req_callback_data(
@ -612,7 +613,7 @@ static void cli_smb_received(struct tevent_req *subreq)
return;
}
status = cli_state_dispatch_smb1(cli, frame, inbuf);
status = cli->conn.dispatch_incoming(cli, frame, inbuf);
TALLOC_FREE(frame);
if (NT_STATUS_IS_OK(status)) {
/*