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
|
/*
* Copyright 2006 Serge van den Boom <svdb@stack.nl>
*
* 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 LIBS_NETWORK_CONNECT_CONNECT_H_
#define LIBS_NETWORK_CONNECT_CONNECT_H_
typedef struct ConnectFlags ConnectFlags;
typedef struct ConnectError ConnectError;
typedef struct ConnectState ConnectState;
typedef enum {
Connect_closed,
Connect_resolving,
Connect_connecting
} ConnectStateState;
#include "../netmanager/netmanager.h"
#include "../socket/socket.h"
#include "resolve.h"
// For connectHost()
struct ConnectFlags {
ProtocolFamily familyDemand;
// Only accept a protocol family of this type.
// One of PF_inet, PF_inet6, or PF_unspec.
ProtocolFamily familyPrefer;
// Prefer a protocol family of this type.
// One of PF_inet, PF_inet6, or PF_unspec.
int timeout;
/* Number of milliseconds before timing out a connection attempt.
* Note that if a host has multiple addresses, a connect to that
* host will have this timeout *per address*. */
int retryDelayMs;
/* Retry connecting this many ms after connecting to the last
* address for the specified host fails. Set to Connect_noRetry
* to give up after one try. */
#define Connect_noRetry -1
};
struct ConnectError {
ConnectStateState state;
// State where the error occured.
int err;
// errno value. Not relevant if state == resolving unless
// gaiRes == EAI_SYSTEM.
const ResolveError *resolveError;
// Only relevant if state == resolving.
};
typedef void (*ConnectConnectCallback)(ConnectState *connectState,
NetDescriptor *nd, const struct sockaddr *addr, socklen_t addrLen);
typedef void (*ConnectErrorCallback)(ConnectState *connectState,
const ConnectError *error);
#ifdef CONNECT_INTERNAL
#include "libs/alarm.h"
struct ConnectState {
RefCount refCount;
ConnectStateState state;
ConnectFlags flags;
ConnectConnectCallback connectCallback;
ConnectErrorCallback errorCallback;
void *extra;
struct addrinfo *info;
struct addrinfo *infoPtr;
ResolveState *resolveState;
NetDescriptor *nd;
Alarm *alarm;
// Used for both the timeout for a connection attempt
// and to retry after all addresses have been tried.
};
#endif /* CONNECT_INTERNAL */
ConnectState *connectHostByName(const char *host, const char *service,
Protocol proto, const ConnectFlags *flags,
ConnectConnectCallback connectCallback,
ConnectErrorCallback errorCallback, void *extra);
void ConnectState_incRef(ConnectState *connectState);
bool ConnectState_decRef(ConnectState *connectState);
void ConnectState_close(ConnectState *connectState);
void ConnectState_setExtra(ConnectState *connectState, void *extra);
void *ConnectState_getExtra(ConnectState *connectState);
#endif /* LIBS_NETWORK_CONNECT_CONNECT_H_ */
|
