00001
00002
00003 #include "ace/OS_NS_sys_socket.h"
00004
00005 ACE_RCSID(ace, OS_NS_sys_socket, "$Id: OS_NS_sys_socket.cpp 85460 2009-05-29 13:38:50Z msmit $")
00006
00007 #if !defined (ACE_HAS_INLINED_OSCALLS)
00008 # include "ace/OS_NS_sys_socket.inl"
00009 #endif
00010
00011 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
00012
00013 #if defined (ACE_WIN32)
00014 int ACE_OS::socket_initialized_;
00015 #endif
00016
00017 ACE_HANDLE
00018 ACE_OS::accept (ACE_HANDLE handle,
00019 struct sockaddr *addr,
00020 int *addrlen,
00021 const ACE_Accept_QoS_Params &qos_params)
00022 {
00023 # if defined (ACE_HAS_WINSOCK2) && (ACE_HAS_WINSOCK2 != 0)
00024 ACE_SOCKCALL_RETURN (::WSAAccept ((ACE_SOCKET) handle,
00025 addr,
00026 (ACE_SOCKET_LEN *) addrlen,
00027 (LPCONDITIONPROC) qos_params.qos_condition_callback (),
00028 qos_params.callback_data ()),
00029 ACE_HANDLE,
00030 ACE_INVALID_HANDLE);
00031 # else
00032 ACE_UNUSED_ARG (qos_params);
00033 return ACE_OS::accept (handle,
00034 addr,
00035 addrlen);
00036 # endif
00037 }
00038
00039 int
00040 ACE_OS::connect (ACE_HANDLE handle,
00041 const sockaddr *addr,
00042 int addrlen,
00043 const ACE_QoS_Params &qos_params)
00044 {
00045 ACE_OS_TRACE ("ACE_OS::connect");
00046 # if defined (ACE_HAS_WINSOCK2) && (ACE_HAS_WINSOCK2 != 0)
00047 ACE_SOCKCALL_RETURN (::WSAConnect ((ACE_SOCKET) handle,
00048 (const sockaddr *) addr,
00049 (ACE_SOCKET_LEN) addrlen,
00050 (WSABUF *) qos_params.caller_data (),
00051 (WSABUF *) qos_params.callee_data (),
00052 (QOS *) qos_params.socket_qos (),
00053 (QOS *) qos_params.group_socket_qos ()),
00054 int, -1);
00055 # else
00056 ACE_UNUSED_ARG (qos_params);
00057 return ACE_OS::connect (handle,
00058 const_cast <sockaddr *> (addr),
00059 addrlen);
00060 # endif
00061 }
00062
00063 ACE_HANDLE
00064 ACE_OS::join_leaf (ACE_HANDLE socket,
00065 const sockaddr *name,
00066 int namelen,
00067 const ACE_QoS_Params &qos_params)
00068 {
00069 # if defined (ACE_HAS_WINSOCK2) && (ACE_HAS_WINSOCK2 != 0)
00070
00071 QOS qos;
00072
00073
00074 qos.SendingFlowspec = *(qos_params.socket_qos ()->sending_flowspec ());
00075 qos.ReceivingFlowspec = *(qos_params.socket_qos ()->receiving_flowspec ());
00076 qos.ProviderSpecific = (WSABUF) qos_params.socket_qos ()->provider_specific ();
00077
00078 ACE_SOCKCALL_RETURN (::WSAJoinLeaf ((ACE_SOCKET) socket,
00079 name,
00080 namelen,
00081 (WSABUF *) qos_params.caller_data (),
00082 (WSABUF *) qos_params.callee_data (),
00083 &qos,
00084 (QOS *) qos_params.group_socket_qos (),
00085 qos_params.flags ()),
00086 ACE_HANDLE,
00087 ACE_INVALID_HANDLE);
00088
00089 # else
00090 ACE_UNUSED_ARG (socket);
00091 ACE_UNUSED_ARG (name);
00092 ACE_UNUSED_ARG (namelen);
00093 ACE_UNUSED_ARG (qos_params);
00094 ACE_NOTSUP_RETURN (ACE_INVALID_HANDLE);
00095 # endif
00096 }
00097
00098 int
00099 ACE_OS::socket_init (int version_high, int version_low)
00100 {
00101 # if defined (ACE_WIN32) && !defined(ACE_DONT_INIT_WINSOCK)
00102 if (ACE_OS::socket_initialized_ == 0)
00103 {
00104 WORD version_requested = MAKEWORD (version_high, version_low);
00105 WSADATA wsa_data;
00106 int error = WSAStartup (version_requested, &wsa_data);
00107
00108 if (error != 0)
00109 # if defined (ACE_HAS_WINCE)
00110 {
00111 ACE_TCHAR fmt[] = ACE_TEXT ("%s failed, WSAGetLastError returned %d");
00112 ACE_TCHAR buf[80];
00113 ACE_OS::sprintf (buf, fmt, ACE_TEXT ("WSAStartup"), error);
00114 ::MessageBox (0, buf, ACE_TEXT ("WSAStartup failed!"), MB_OK);
00115 }
00116 # else
00117 ACE_OS::fprintf (stderr,
00118 "ACE_OS::socket_init; WSAStartup failed, "
00119 "WSAGetLastError returned %d\n",
00120 error);
00121 # endif
00122
00123 ACE_OS::socket_initialized_ = 1;
00124 }
00125 # else
00126 ACE_UNUSED_ARG (version_high);
00127 ACE_UNUSED_ARG (version_low);
00128 # endif
00129 return 0;
00130 }
00131
00132 int
00133 ACE_OS::socket_fini (void)
00134 {
00135 # if defined (ACE_WIN32)
00136 if (ACE_OS::socket_initialized_ != 0)
00137 {
00138 if (WSACleanup () != 0)
00139 {
00140 int error = ::WSAGetLastError ();
00141 # if defined (ACE_HAS_WINCE)
00142 ACE_TCHAR fmt[] = ACE_TEXT ("%s failed, WSAGetLastError returned %d");
00143 ACE_TCHAR buf[80];
00144 ACE_OS::sprintf (buf, fmt, ACE_TEXT ("WSACleanup"), error);
00145 ::MessageBox (0, buf , ACE_TEXT ("WSACleanup failed!"), MB_OK);
00146 # else
00147 ACE_OS::fprintf (stderr,
00148 "ACE_OS::socket_fini; WSACleanup failed, "
00149 "WSAGetLastError returned %d\n",
00150 error);
00151 # endif
00152 }
00153 ACE_OS::socket_initialized_ = 0;
00154 }
00155 # endif
00156 return 0;
00157 }
00158
00159 ACE_END_VERSIONED_NAMESPACE_DECL