1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
|
/*
* Sylpheed -- a GTK+ based, lightweight, and fast e-mail client
* Copyright (C) 1999-2005 Hiroyuki Yamamoto
*
* 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., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*/
#ifndef __SESSION_H__
#define __SESSION_H__
#ifdef HAVE_CONFIG_H
# include "config.h"
#endif
#include <glib.h>
#include <time.h>
#include <sys/time.h>
#include <unistd.h>
#include "socket.h"
#define SESSION_BUFFSIZE 4096
typedef struct _Session Session;
#define SESSION(obj) ((Session *)obj)
typedef enum {
SESSION_UNKNOWN,
SESSION_IMAP,
SESSION_NEWS,
SESSION_SMTP,
SESSION_POP3
} SessionType;
typedef enum {
SESSION_READY,
SESSION_SEND,
SESSION_RECV,
SESSION_EOF,
SESSION_TIMEOUT,
SESSION_ERROR,
SESSION_DISCONNECTED
} SessionState;
typedef enum
{
SESSION_MSG_NORMAL,
SESSION_MSG_SEND_DATA,
SESSION_MSG_RECV_DATA,
SESSION_MSG_CONTROL,
SESSION_MSG_ERROR,
SESSION_MSG_UNKNOWN
} SessionMsgType;
typedef gint (*RecvMsgNotify) (Session *session,
const gchar *msg,
gpointer user_data);
typedef gint (*RecvDataProgressiveNotify) (Session *session,
guint cur_len,
guint total_len,
gpointer user_data);
typedef gint (*RecvDataNotify) (Session *session,
guint len,
gpointer user_data);
typedef gint (*SendDataProgressiveNotify) (Session *session,
guint cur_len,
guint total_len,
gpointer user_data);
typedef gint (*SendDataNotify) (Session *session,
guint len,
gpointer user_data);
struct _Session
{
SessionType type;
SockInfo *sock;
gchar *server;
gushort port;
#if USE_SSL
SSLType ssl_type;
#endif
gboolean nonblocking;
SessionState state;
time_t last_access_time;
struct timeval tv_prev;
gint conn_id;
gint io_tag;
gchar read_buf[SESSION_BUFFSIZE];
gchar *read_buf_p;
gint read_buf_len;
GString *read_msg_buf;
GByteArray *read_data_buf;
gchar *read_data_terminator;
/* buffer for short messages */
gchar *write_buf;
gchar *write_buf_p;
gint write_buf_len;
/* buffer for large data */
const guchar *write_data;
const guchar *write_data_p;
gint write_data_len;
guint timeout_tag;
guint timeout_interval;
gpointer data;
/* virtual methods to parse server responses */
gint (*recv_msg) (Session *session,
const gchar *msg);
gint (*send_data_finished) (Session *session,
guint len);
gint (*recv_data_finished) (Session *session,
guchar *data,
guint len);
void (*destroy) (Session *session);
/* notification functions */
RecvMsgNotify recv_msg_notify;
RecvDataProgressiveNotify recv_data_progressive_notify;
RecvDataNotify recv_data_notify;
SendDataProgressiveNotify send_data_progressive_notify;
SendDataNotify send_data_notify;
gpointer recv_msg_notify_data;
gpointer recv_data_progressive_notify_data;
gpointer recv_data_notify_data;
gpointer send_data_progressive_notify_data;
gpointer send_data_notify_data;
};
void session_init (Session *session);
gint session_connect (Session *session,
const gchar *server,
gushort port);
gint session_disconnect (Session *session);
void session_destroy (Session *session);
gboolean session_is_connected (Session *session);
void session_set_access_time (Session *session);
void session_set_timeout (Session *session,
guint interval);
void session_set_recv_message_notify (Session *session,
RecvMsgNotify notify_func,
gpointer data);
void session_set_recv_data_progressive_notify
(Session *session,
RecvDataProgressiveNotify notify_func,
gpointer data);
void session_set_recv_data_notify (Session *session,
RecvDataNotify notify_func,
gpointer data);
void session_set_send_data_progressive_notify
(Session *session,
SendDataProgressiveNotify notify_func,
gpointer data);
void session_set_send_data_notify (Session *session,
SendDataNotify notify_func,
gpointer data);
#if USE_SSL
gint session_start_tls (Session *session);
#endif
gint session_send_msg (Session *session,
SessionMsgType type,
const gchar *msg);
gint session_recv_msg (Session *session);
gint session_send_data (Session *session,
const guchar *data,
guint size);
gint session_recv_data (Session *session,
guint size,
const gchar *terminator);
#endif /* __SESSION_H__ */
|
