source: trunk/libtransmission/net.c @ 4404

Last change on this file since 4404 was 4404, checked in by charles, 14 years ago

set copyright info to 2008

  • Property svn:keywords set to Date Rev Author Id
File size: 6.2 KB
Line 
1/******************************************************************************
2 * $Id: net.c 4404 2008-01-01 17:20:20Z charles $
3 *
4 * Copyright (c) 2005-2008 Transmission authors and contributors
5 *
6 * Permission is hereby granted, free of charge, to any person obtaining a
7 * copy of this software and associated documentation files (the "Software"),
8 * to deal in the Software without restriction, including without limitation
9 * the rights to use, copy, modify, merge, publish, distribute, sublicense,
10 * and/or sell copies of the Software, and to permit persons to whom the
11 * Software is furnished to do so, subject to the following conditions:
12 *
13 * The above copyright notice and this permission notice shall be included in
14 * all copies or substantial portions of the Software.
15 *
16 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
19 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
21 * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
22 * DEALINGS IN THE SOFTWARE.
23 *****************************************************************************/
24
25#include <errno.h>
26#include <stdio.h>
27#include <stdlib.h>
28#include <string.h>
29
30#include <sys/types.h>
31
32#include <arpa/inet.h> /* inet_addr */
33
34#ifndef WIN32
35#include <netdb.h>
36#include <fcntl.h>
37#endif
38
39#include <evutil.h>
40
41#include "transmission.h"
42#include "fdlimit.h"
43#include "natpmp.h"
44#include "net.h"
45#include "platform.h"
46#include "utils.h"
47
48
49void
50tr_netInit( void )
51{
52    static int initialized = FALSE;
53    if( !initialized )
54    {
55#ifdef WIN32
56        WSADATA wsaData;
57        WSAStartup(MAKEWORD(2,2), &wsaData);
58#endif
59        initialized = TRUE;
60    }
61}
62
63/***********************************************************************
64 * DNS resolution
65 *
66 * Synchronous "resolution": only works with character strings
67 * representing numbers expressed in the Internet standard `.' notation.
68 * Returns a non-zero value if an error occurs.
69 **********************************************************************/
70int tr_netResolve( const char * address, struct in_addr * addr )
71{
72    addr->s_addr = inet_addr( address );
73    return ( addr->s_addr == 0xFFFFFFFF );
74}
75
76
77/***********************************************************************
78 * TCP/UDP sockets
79 **********************************************************************/
80
81static int
82makeSocketNonBlocking( int fd )
83{
84    if( fd >= 0 )
85    {
86#if defined(__BEOS__)
87        int flags = 1;
88        if( setsockopt( fd, SOL_SOCKET, SO_NONBLOCK,
89                        &flags, sizeof( int ) ) < 0 )
90#else
91        if( evutil_make_socket_nonblocking( fd ) )
92#endif
93        {
94            tr_err( "Couldn't set socket to non-blocking mode (%s)",
95                    strerror( sockerrno ) );
96            tr_netClose( fd );
97            fd = -1;
98        }
99    }
100
101    return fd;
102}
103
104static int
105createSocket( int type, int priority )
106{
107    return makeSocketNonBlocking( tr_fdSocketCreate( type, priority ) );
108}
109
110static int
111tr_netOpen( const struct in_addr * addr, tr_port_t port,
112            int type, int priority )
113{
114    int s;
115    struct sockaddr_in sock;
116
117    if( ( s = createSocket( type, priority ) ) < 0 )
118    {
119        return -1;
120    }
121
122    memset( &sock, 0, sizeof( sock ) );
123    sock.sin_family      = AF_INET;
124    sock.sin_addr.s_addr = addr->s_addr;
125    sock.sin_port        = port;
126
127    if( ( connect( s, (struct sockaddr *) &sock,
128                   sizeof( struct sockaddr_in ) ) < 0 )
129#ifdef WIN32
130        && ( sockerrno != WSAEWOULDBLOCK )
131#endif
132        && ( sockerrno != EINPROGRESS ) )
133    {
134        tr_err( "Couldn't connect socket %d to %s, port %d (errno %d - %s)",
135                s, inet_ntoa(*addr), port,
136                sockerrno, strerror(sockerrno) );
137        tr_netClose( s );
138        s = -1;
139    }
140
141    return s;
142}
143 
144int
145tr_netOpenTCP( const struct in_addr * addr, tr_port_t port, int priority )
146{
147    return tr_netOpen( addr, port, SOCK_STREAM, priority );
148}
149
150static int
151tr_netBind( int port, int type )
152{
153    int s;
154    struct sockaddr_in sock;
155#if defined( SO_REUSEADDR ) || defined( SO_REUSEPORT )
156    int optval;
157#endif
158
159    if( ( s = createSocket( type, 1 ) ) < 0 )
160    {
161        tr_err( "Couldn't create socket of type %d", type );
162        return -1;
163    }
164
165#ifdef SO_REUSEADDR
166    optval = 1;
167    setsockopt( s, SOL_SOCKET, SO_REUSEADDR, (char*)&optval, sizeof( optval ) );
168#endif
169
170    memset( &sock, 0, sizeof( sock ) );
171    sock.sin_family      = AF_INET;
172    sock.sin_addr.s_addr = INADDR_ANY;
173    sock.sin_port        = htons( port );
174
175    if( bind( s, (struct sockaddr *) &sock,
176               sizeof( struct sockaddr_in ) ) )
177    {
178        tr_err( "Couldn't bind port %d: %s", port, strerror(sockerrno) );
179        tr_netClose( s );
180        return -1;
181    }
182     
183    tr_inf( "Bound socket %d to port %d", s, port );
184    return s;
185}
186
187int
188tr_netBindTCP( int port )
189{
190    return tr_netBind( port, SOCK_STREAM );
191}
192
193int
194tr_netAccept( int b, struct in_addr * addr, tr_port_t * port )
195{
196    return makeSocketNonBlocking( tr_fdSocketAccept( b, addr, port ) );
197}
198
199int
200tr_netSend( int s, const void * buf, int size )
201{
202    const int ret = send( s, buf, size, 0 );
203    if( ret >= 0 )
204        return ret;
205
206    if( sockerrno == ENOTCONN || sockerrno == EAGAIN || sockerrno == EWOULDBLOCK )
207        return TR_NET_BLOCK;
208
209    return TR_NET_CLOSE;
210}
211
212int tr_netRecvFrom( int s, uint8_t * buf, int size, struct sockaddr_in * addr )
213{
214    socklen_t len;
215    int       ret;
216
217    len = ( NULL == addr ? 0 : sizeof( *addr ) );
218    ret = recvfrom( s, buf, size, 0, ( struct sockaddr * ) addr, &len );
219    if( ret < 0 )
220    {
221        if( sockerrno == EAGAIN || sockerrno == EWOULDBLOCK )
222        {
223            ret = TR_NET_BLOCK;
224        }
225        else
226        {
227            ret = TR_NET_CLOSE;
228        }
229    }
230    if( !ret )
231    {
232        ret = TR_NET_CLOSE;
233    }
234
235    return ret;
236}
237
238void
239tr_netClose( int s )
240{
241    tr_fdSocketClose( s );
242}
243
244void
245tr_netNtop( const struct in_addr * addr, char * buf, int len )
246{
247    const uint8_t * cast;
248
249    cast = (const uint8_t *)addr;
250    snprintf( buf, len, "%hhu.%hhu.%hhu.%hhu",
251              cast[0], cast[1], cast[2], cast[3] );
252}
Note: See TracBrowser for help on using the repository browser.