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
|
/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- */
/*
* Copyright (C) 2000-2003, Ximian, Inc.
*/
#ifndef SOUP_SOCKET_H
#define SOUP_SOCKET_H 1
#include <libsoup/soup-types.h>
#define SOUP_TYPE_SOCKET (soup_socket_get_type ())
#define SOUP_SOCKET(obj) (G_TYPE_CHECK_INSTANCE_CAST ((obj), SOUP_TYPE_SOCKET, SoupSocket))
#define SOUP_SOCKET_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST ((klass), SOUP_TYPE_SOCKET, SoupSocketClass))
#define SOUP_IS_SOCKET(obj) (G_TYPE_CHECK_INSTANCE_TYPE ((obj), SOUP_TYPE_SOCKET))
#define SOUP_IS_SOCKET_CLASS(klass) (G_TYPE_CHECK_CLASS_TYPE ((obj), SOUP_TYPE_SOCKET))
#define SOUP_SOCKET_GET_CLASS(obj) (G_TYPE_INSTANCE_GET_CLASS ((obj), SOUP_TYPE_SOCKET, SoupSocketClass))
struct SoupSocket {
GObject parent;
};
typedef struct {
GObjectClass parent_class;
/* signals */
void (*connect_result) (SoupSocket *, guint);
void (*readable) (SoupSocket *);
void (*writable) (SoupSocket *);
void (*disconnected) (SoupSocket *);
void (*new_connection) (SoupSocket *, SoupSocket *);
} SoupSocketClass;
#define SOUP_SOCKET_FLAG_NONBLOCKING "non-blocking"
#define SOUP_SOCKET_FLAG_NODELAY "nodelay"
#define SOUP_SOCKET_FLAG_REUSEADDR "reuseaddr"
#define SOUP_SOCKET_FLAG_CLOEXEC "cloexec"
#define SOUP_SOCKET_IS_SERVER "is-server"
#define SOUP_SOCKET_SSL_CREDENTIALS "ssl-creds"
/**
* SoupSocketCallback:
* @sock: the #SoupSocket
* @status: an HTTP status code indicating success or failure
* @user_data: the data passed to soup_socket_client_new_async()
*
* The callback function passed to soup_socket_client_new_async().
**/
typedef void (*SoupSocketCallback) (SoupSocket *sock,
guint status,
gpointer user_data);
/**
* SoupSocketListenerCallback:
* @listener: the listening #SoupSocket
* @sock: the newly-received #SoupSocket
* @user_data: the data passed to soup_socket_server_new().
*
* The callback function passed to soup_socket_server_new(), which
* receives new connections.
**/
typedef void (*SoupSocketListenerCallback) (SoupSocket *listener,
SoupSocket *sock,
gpointer user_data);
GType soup_socket_get_type (void);
SoupSocket *soup_socket_new (const char *optname1,
...) G_GNUC_NULL_TERMINATED;
guint soup_socket_connect (SoupSocket *sock,
SoupAddress *remote_addr);
gboolean soup_socket_listen (SoupSocket *sock,
SoupAddress *local_addr);
gboolean soup_socket_start_ssl (SoupSocket *sock);
gboolean soup_socket_start_proxy_ssl (SoupSocket *sock,
const char *ssl_host);
void soup_socket_disconnect (SoupSocket *sock);
gboolean soup_socket_is_connected (SoupSocket *sock);
SoupSocket *soup_socket_client_new_async (const char *hostname,
guint port,
gpointer ssl_creds,
SoupSocketCallback callback,
gpointer user_data);
SoupSocket *soup_socket_client_new_sync (const char *hostname,
guint port,
gpointer ssl_creds,
guint *status_ret);
SoupSocket *soup_socket_server_new (SoupAddress *local_addr,
gpointer ssl_creds,
SoupSocketListenerCallback callback,
gpointer user_data);
SoupAddress *soup_socket_get_local_address (SoupSocket *sock);
SoupAddress *soup_socket_get_remote_address (SoupSocket *sock);
/**
* SoupSocketIOStatus:
* @SOUP_SOCKET_OK: Success
* @SOUP_SOCKET_WOULD_BLOCK: Cannot read/write any more at this time
* @SOUP_SOCKET_EOF: End of file
* @SOUP_SOCKET_ERROR: Other error
*
* Return value from the #SoupSocket IO methods.
**/
typedef enum {
SOUP_SOCKET_OK,
SOUP_SOCKET_WOULD_BLOCK,
SOUP_SOCKET_EOF,
SOUP_SOCKET_ERROR
} SoupSocketIOStatus;
SoupSocketIOStatus soup_socket_read (SoupSocket *sock,
gpointer buffer,
gsize len,
gsize *nread);
SoupSocketIOStatus soup_socket_read_until (SoupSocket *sock,
gpointer buffer,
gsize len,
gconstpointer boundary,
gsize boundary_len,
gsize *nread,
gboolean *got_boundary);
SoupSocketIOStatus soup_socket_write (SoupSocket *sock,
gconstpointer buffer,
gsize len,
gsize *nwrote);
#endif /* SOUP_SOCKET_H */
|
