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
|
// -*- c++ -*-
//------------------------------------------------------------------------
// ConUDPSocket.cpp
//------------------------------------------------------------------------------
// Copyright (C) 1999 Vladislav Grinchenko
//
// This library is free software; you can redistribute it and/or
// modify it under the terms of the GNU Library General Public
// License as published by the Free Software Foundation; either
// version 2 of the License, or (at your option) any later version.
//------------------------------------------------------------------------
#ifndef WIN32
#include "assa/ConUDPSocket.h"
#include "assa/UNIXAddress.h"
#include "assa/INETAddress.h"
using namespace ASSA;
bool
ConUDPSocket::
connect (const Address& peer_address_)
{
char self[] = "ConUDPSocket::connect"; trace(self);
if ( ::connect (getHandler(),peer_address_.getAddress(),
peer_address_.getLength()) < 0 ) {
setstate (Socket::failbit);
return false;
}
return true;
}
void
ConUDPSocket::
unconnect()
{
// Ignore errors here. On some systems connect() might return
// EAFNOSUPPORT error, on some might not, but it is OK.
//
char self[] = "ConUDPSocket::unconnect"; trace(self);
if ( getDomain() == AF_INET ) {
INETAddress addr;
SA_IN* addrp = (SA_IN*) addr.getAddress();
addrp->sin_family = AF_UNSPEC;
(void) connect(addr);
}
else { // AF_LOCAL
// I haven't tested whether it works at all.
UNIXAddress addr("");
SA_UN* addrp = (SA_UN*) addr.getAddress();
addrp->sun_family = AF_UNSPEC;
(void) connect(addr);
}
}
int
ConUDPSocket::
read(char* packet_, const unsigned int size_)
{
int len;
len = ::read(getHandler(), packet_, size_);
if (len == -1) {
setstate (Socket::failbit);
}
else if ( len == 0 ) {
setstate (Socket::failbit | Socket::eofbit);
}
return len;
}
int
ConUDPSocket::
write (const char* packet_, const unsigned int size_)
{
return ::write(getHandler(), (const void*) packet_, size_);
}
#endif // WIN32
|
