]>
Commit | Line | Data |
---|---|---|
05a019a2 DE |
1 | /* ------------------------------------------------------------------------- |
2 | * Project: GSocket (Generic Socket) for WX | |
3 | * Name: gsockpm.c | |
4 | * Purpose: GSocket: PM part | |
65571936 | 5 | * Licence: The wxWindows licence |
05a019a2 DE |
6 | * CVSID: $Id$ |
7 | * ------------------------------------------------------------------------- */ | |
8 | ||
9 | #include "wx/setup.h" | |
10 | ||
11 | #if wxUSE_SOCKETS | |
12 | ||
13 | #include <stdlib.h> | |
14 | #include "wx/unix/gsockunx.h" | |
15 | #include "wx/gsocket.h" | |
16 | ||
17 | extern int wxAppAddSocketHandler(int handle, int mask, | |
18 | void (*callback)(void*), void * gsock); | |
19 | ||
20 | extern void wxAppRemoveSocketHandler(int handle); | |
21 | ||
22 | #define wxSockReadMask 0x01 | |
23 | #define wxSockWriteMask 0x02 | |
24 | ||
25 | static void _GSocket_PM_Input(void *data) | |
26 | { | |
27 | GSocket *socket = (GSocket *) data; | |
a1ad0f6b | 28 | socket->Detected_Read(); |
05a019a2 DE |
29 | } |
30 | ||
31 | static void _GSocket_PM_Output(void *data) | |
32 | { | |
33 | GSocket *socket = (GSocket *) data; | |
a1ad0f6b | 34 | socket->Detected_Write(); |
05a019a2 DE |
35 | } |
36 | ||
a1ad0f6b DE |
37 | bool GSocketGUIFunctionsTableConcrete::CanUseEventLoop() |
38 | { return true; } | |
39 | ||
40 | bool GSocketGUIFunctionsTableConcrete::OnInit(void) | |
05a019a2 DE |
41 | { |
42 | return 1; | |
43 | } | |
44 | ||
a1ad0f6b | 45 | void GSocketGUIFunctionsTableConcrete::OnExit(void) |
05a019a2 DE |
46 | { |
47 | } | |
48 | ||
a1ad0f6b | 49 | bool GSocketGUIFunctionsTableConcrete::Init_Socket(GSocket *socket) |
05a019a2 DE |
50 | { |
51 | int *m_id; | |
52 | socket->m_gui_dependent = (char *)malloc(sizeof(int)*2); | |
53 | m_id = (int *)(socket->m_gui_dependent); | |
54 | ||
55 | m_id[0] = -1; | |
56 | m_id[1] = -1; | |
57 | return TRUE; | |
58 | } | |
59 | ||
a1ad0f6b | 60 | void GSocketGUIFunctionsTableConcrete::Destroy_Socket(GSocket *socket) |
05a019a2 DE |
61 | { |
62 | free(socket->m_gui_dependent); | |
63 | } | |
64 | ||
a1ad0f6b | 65 | void GSocketGUIFunctionsTableConcrete::Install_Callback(GSocket *socket, GSocketEvent event) |
05a019a2 DE |
66 | { |
67 | int *m_id = (int *)(socket->m_gui_dependent); | |
68 | int c; | |
69 | ||
70 | if (socket->m_fd == -1) | |
71 | return; | |
72 | ||
73 | switch (event) | |
74 | { | |
75 | case GSOCK_LOST: /* fall-through */ | |
76 | case GSOCK_INPUT: c = 0; break; | |
77 | case GSOCK_OUTPUT: c = 1; break; | |
78 | case GSOCK_CONNECTION: c = ((socket->m_server) ? 0 : 1); break; | |
79 | default: return; | |
80 | } | |
81 | ||
82 | if (m_id[c] != -1) | |
83 | wxAppRemoveSocketHandler(m_id[c]); | |
84 | ||
85 | if (c == 0) | |
86 | { | |
87 | m_id[0] = wxAppAddSocketHandler(socket->m_fd, wxSockReadMask, | |
88 | _GSocket_PM_Input, (void *)socket); | |
89 | } | |
90 | else | |
91 | { | |
92 | m_id[1] = wxAppAddSocketHandler(socket->m_fd, wxSockWriteMask, | |
93 | _GSocket_PM_Output, (void *)socket); | |
94 | } | |
95 | } | |
96 | ||
a1ad0f6b | 97 | void GSocketGUIFunctionsTableConcrete::Uninstall_Callback(GSocket *socket, GSocketEvent event) |
05a019a2 DE |
98 | { |
99 | int *m_id = (int *)(socket->m_gui_dependent); | |
100 | int c; | |
101 | switch (event) | |
102 | { | |
103 | case GSOCK_LOST: /* fall-through */ | |
104 | case GSOCK_INPUT: c = 0; break; | |
105 | case GSOCK_OUTPUT: c = 1; break; | |
106 | case GSOCK_CONNECTION: c = ((socket->m_server) ? 0 : 1); break; | |
107 | default: return; | |
108 | } | |
109 | if (m_id[c] != -1) | |
110 | wxAppRemoveSocketHandler(m_id[c]); | |
111 | ||
112 | m_id[c] = -1; | |
113 | } | |
114 | ||
a1ad0f6b | 115 | void GSocketGUIFunctionsTableConcrete::Enable_Events(GSocket *socket) |
05a019a2 | 116 | { |
a1ad0f6b DE |
117 | Install_Callback(socket, GSOCK_INPUT); |
118 | Install_Callback(socket, GSOCK_OUTPUT); | |
05a019a2 DE |
119 | } |
120 | ||
a1ad0f6b | 121 | void GSocketGUIFunctionsTableConcrete::Disable_Events(GSocket *socket) |
05a019a2 | 122 | { |
a1ad0f6b DE |
123 | Uninstall_Callback(socket, GSOCK_INPUT); |
124 | Uninstall_Callback(socket, GSOCK_OUTPUT); | |
05a019a2 DE |
125 | } |
126 | ||
127 | #else /* !wxUSE_SOCKETS */ | |
128 | ||
129 | /* some compilers don't like having empty source files */ | |
130 | static int wxDummyGsockVar = 0; | |
131 | ||
132 | #endif /* wxUSE_SOCKETS/!wxUSE_SOCKETS */ |