mirror of
https://github.com/samba-team/samba.git
synced 2025-06-28 00:49:42 +03:00
5ddf678e01
Up to now the client code has had an async API, and operated asynchronously at the packet level, but was not truly async in that it assumed that it could always write to the socket and when a partial packet came in that it could block waiting for the rest of the packet. This change makes the SMB client library full async, by adding a separate outgoing packet queue, using non-blocking socket IO and having a input buffer that can fill asynchonously until the full packet has arrived. The main complexity was in dealing with the events structure when using the CIFS proxy backend. In that case the same events structure needs to be used in both the client library and the main smbd server, so that when the client library is waiting for a reply that the main server keeps processing packets. This required some changes in the events library code. Next step is to make the generated rpc client code use these new capabilities. (This used to be commit 96bf4da3edc4d64b0f58ef520269f3b385b8da02)
78 lines
2.1 KiB
C
78 lines
2.1 KiB
C
/*
|
|
Unix SMB/CIFS implementation.
|
|
main select loop and event handling
|
|
Copyright (C) Andrew Tridgell 2003
|
|
|
|
This program is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation; either version 2 of the License, or
|
|
(at your option) any later version.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, write to the Free Software
|
|
Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
|
|
*/
|
|
|
|
/*
|
|
please read the comments in events.c before modifying
|
|
*/
|
|
|
|
struct event_context {
|
|
/* list of filedescriptor events */
|
|
struct fd_event {
|
|
struct fd_event *next, *prev;
|
|
int fd;
|
|
uint16_t flags; /* see EVENT_FD_* flags */
|
|
void (*handler)(struct event_context *ev, struct fd_event *fde, time_t t, uint16_t flags);
|
|
void *private;
|
|
int ref_count;
|
|
} *fd_events;
|
|
|
|
/* list of timed events */
|
|
struct timed_event {
|
|
struct timed_event *next, *prev;
|
|
time_t next_event;
|
|
void (*handler)(struct event_context *ev, struct timed_event *te, time_t t);
|
|
void *private;
|
|
int ref_count;
|
|
} *timed_events;
|
|
|
|
/* list of loop events - called on each select() */
|
|
struct loop_event {
|
|
struct loop_event *next, *prev;
|
|
void (*handler)(struct event_context *ev, struct loop_event *le, time_t t);
|
|
void *private;
|
|
int ref_count;
|
|
} *loop_events;
|
|
|
|
/* list of signal events */
|
|
struct signal_event {
|
|
struct signal_event *next, *prev;
|
|
int signum;
|
|
void (*handler)(struct event_context *ev, struct signal_event *se, int signum, void *sigarg);
|
|
void *private;
|
|
int ref_count;
|
|
} *signal_events;
|
|
|
|
/* the maximum file descriptor number in fd_events */
|
|
int maxfd;
|
|
|
|
/* information for exiting from the event loop */
|
|
struct {
|
|
BOOL exit_now;
|
|
int code;
|
|
} exit;
|
|
|
|
int ref_count;
|
|
};
|
|
|
|
|
|
/* bits for fd_event.flags */
|
|
#define EVENT_FD_READ 1
|
|
#define EVENT_FD_WRITE 2
|