5cfcdb4af567854b798d4b01731f652c2d661f39
[reactos.git] / reactos / lib / drivers / oskittcp / oskittcp / sleep.c
1 #include <oskittcp.h>
2 #include <sys/callout.h>
3 #include <oskitfreebsd.h>
4 #include <oskitdebug.h>
5
6 /* clock_init */
7 int ncallout = 256;
8 struct callout *callout;
9
10 void init_freebsd_sched() {
11 }
12
13 int tsleep( void *token, int priority, char *wmesg, int tmio ) {
14 if( !OtcpEvent.Sleep ) panic("no sleep");
15 return
16 OtcpEvent.Sleep( OtcpEvent.ClientData, token, priority, wmesg, tmio );
17 }
18
19 void wakeup( struct socket *so, void *token ) {
20 OSK_UINT flags = 0;
21
22 OS_DbgPrint
23 (OSK_MID_TRACE,("XXX Bytes to receive: %d state %x\n",
24 so->so_rcv.sb_cc, so->so_state));
25
26 if( so->so_state & SS_ISCONNECTED ) {
27 OS_DbgPrint(OSK_MID_TRACE,("Socket connected!\n"));
28 flags |= SEL_CONNECT;
29 }
30 if( so->so_q ) {
31 OS_DbgPrint(OSK_MID_TRACE,("Socket accepting q\n"));
32 flags |= SEL_ACCEPT;
33 }
34 if( so->so_rcv.sb_cc > 0 ) {
35 OS_DbgPrint(OSK_MID_TRACE,("Socket readable\n"));
36 flags |= SEL_READ;
37 }
38 if( 0 < sbspace(&so->so_snd) ) {
39 OS_DbgPrint(OSK_MID_TRACE,("Socket writeable\n"));
40 flags |= SEL_WRITE;
41 }
42 if (!so->so_pcb) {
43 OS_DbgPrint(OSK_MID_TRACE,("Socket dying\n"));
44 flags |= SEL_FIN;
45 }
46
47 OS_DbgPrint(OSK_MID_TRACE,("Wakeup %x (socket %x, state %x)!\n",
48 token, so,
49 so->so_state));
50
51 if( OtcpEvent.SocketState )
52 OtcpEvent.SocketState( OtcpEvent.ClientData,
53 so,
54 so ? so->so_connection : 0,
55 flags );
56
57 if( OtcpEvent.Wakeup )
58 OtcpEvent.Wakeup( OtcpEvent.ClientData, token );
59
60 OS_DbgPrint(OSK_MID_TRACE,("Wakeup done %x\n", token));
61 }
62
63 /* ---------------------------------------------------------------------- */
64
65
66 static void
67 timeout_init(void)
68 {
69 int i;
70
71 callout = (struct callout *)
72 malloc(sizeof(struct callout) * ncallout, M_FREE, M_WAITOK);
73 if (!callout)
74 panic("can't allocate callout queue!\n");
75
76 /*
77 * Initialize callouts
78 */
79 callfree = callout;
80 for (i = 1; i < ncallout; i++)
81 callout[i-1].c_next = &callout[i];
82
83 }
84
85 /* get clock up and running */
86 void clock_init()
87 {
88 timeout_init();
89 /* inittodr(0); // what does this do? */
90 /* boottime = kern_time; */
91 /* Start a clock we can use for timeouts */
92 }
93
94
95 extern unsigned bio_imask; /* group of interrupts masked with splbio() */
96 extern unsigned cpl; /* current priority level mask */
97 extern volatile unsigned idelayed; /* interrupts to become pending */
98 extern volatile unsigned ipending; /* active interrupts masked by cpl */
99 extern unsigned net_imask; /* group of interrupts masked with splimp() */
100 extern unsigned stat_imask; /* interrupts masked with splstatclock() */
101 extern unsigned tty_imask; /* group of interrupts masked with spltty() */
102
103 /*
104 * ipending has to be volatile so that it is read every time it is accessed
105 * in splx() and spl0(), but we don't want it to be read nonatomically when
106 * it is changed. Pretending that ipending is a plain int happens to give
107 * suitable atomic code for "ipending |= constant;".
108 */
109 #define setdelayed() (*(unsigned *)&ipending |= loadandclear(&idelayed))
110 #define setsoftast() (*(unsigned *)&ipending |= SWI_AST_PENDING)
111 #define setsoftclock() (*(unsigned *)&ipending |= SWI_CLOCK_PENDING)
112 #define setsoftnet() (*(unsigned *)&ipending |= SWI_NET_PENDING)
113 #define setsofttty() (*(unsigned *)&ipending |= SWI_TTY_PENDING)
114
115 #define schedsofttty() (*(unsigned *)&idelayed |= SWI_TTY_PENDING)
116
117 #define GENSPL(name, set_cpl) \
118 static __inline int name(void) \
119 { \
120 unsigned x; \
121 \
122 __asm __volatile("" : : : "memory"); \
123 x = cpl; \
124 set_cpl; \
125 return (x); \
126 }
127
128 void splz(void) {
129 OS_DbgPrint(OSK_MID_TRACE,("Called SPLZ\n"));
130 }
131
132 /*
133 * functions to save and restore the current cpl
134 */
135 void save_cpl(unsigned *x)
136 {
137 *x = cpl;
138 }
139
140 void restore_cpl(unsigned x)
141 {
142 cpl = x;
143 }