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

r11602: added packet_set_serialise() to allow the generic packet layer to

Browse Source 
handle optional request serialisation (this is something that is
commonly needed on stream connections)
(This used to be commit d860eb7956)
This commit is contained in:
Andrew Tridgell 2005-11-09 10:50:39 +00:00 committed by Gerald (Jerry) Carter
parent 1fb2397913
commit a3fcb93df1
2 changed files with 29 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
source4/lib/stream/packet.c
View File

@ -41,6 +41,9 @@ struct packet_context {
struct event_context *ev;
size_t packet_size;
void *private;
struct fd_event *fde;
BOOL serialise;
BOOL processing;
};
/*
@ -115,6 +118,16 @@ void packet_set_event_context(struct packet_context *pc, struct event_context *e
pc->ev = ev;
}
/*
tell the packet layer to serialise requests, so we don't process two requests at once on
one connection. You must have set the event_context
*/
void packet_set_serialise(struct packet_context *pc, struct fd_event *fde)
{
pc->serialise = True;
pc->fde = fde;
}
/*
tell the caller we have an error
@ -167,6 +180,10 @@ void packet_recv(struct packet_context *pc)
size_t nread;
DATA_BLOB blob;
if (pc->processing) {
return;
}
if (pc->packet_size != 0 && pc->num_read >= pc->packet_size) {
goto next_partial;
}
@ -262,8 +279,19 @@ next_partial:
}
pc->num_read -= pc->packet_size;
pc->packet_size = 0;
if (pc->serialise) {
EVENT_FD_NOT_READABLE(pc->fde);
pc->processing = True;
}
status = pc->callback(pc->private, blob);
if (pc->serialise) {
EVENT_FD_READABLE(pc->fde);
pc->processing = False;
}
if (!NT_STATUS_IS_OK(status)) {
packet_error(pc, status);
return;

1
source4/lib/stream/packet.h
View File

@ -38,6 +38,7 @@ void packet_set_full_request(struct packet_context *pc, packet_full_request_fn_t
void packet_set_tls(struct packet_context *pc, struct tls_context *tls);
void packet_set_socket(struct packet_context *pc, struct socket_context *sock);
void packet_set_event_context(struct packet_context *pc, struct event_context *ev);
void packet_set_serialise(struct packet_context *pc, struct fd_event *fde);
void packet_recv(struct packet_context *pc);
/*