Changeset 906 for box/chris/merge/lib/server/SocketStream.cpp
- Timestamp:
- 01/09/2006 00:31:38 (6 years ago)
- File:
-
- 1 edited
-
box/chris/merge/lib/server/SocketStream.cpp (modified) (13 diffs)
Legend:
- Unmodified
- Added
- Removed
-
box/chris/merge/lib/server/SocketStream.cpp
r905 r906 37 37 // -------------------------------------------------------------------------- 38 38 SocketStream::SocketStream() 39 : mSocketHandle( -1),39 : mSocketHandle(INVALID_SOCKET_VALUE), 40 40 mReadClosed(false), 41 41 mWriteClosed(false), … … 86 86 THROW_EXCEPTION(ServerException, BadSocketHandle); 87 87 } 88 if(mSocketHandle == -1)88 if(mSocketHandle == INVALID_SOCKET_VALUE) 89 89 { 90 90 THROW_EXCEPTION(ServerException, DupError); … … 102 102 SocketStream::~SocketStream() 103 103 { 104 if(mSocketHandle != -1)104 if(mSocketHandle != INVALID_SOCKET_VALUE) 105 105 { 106 106 Close(); … … 118 118 void SocketStream::Attach(int socket) 119 119 { 120 if(mSocketHandle != -1) {THROW_EXCEPTION(ServerException, SocketAlreadyOpen)} 120 if(mSocketHandle != INVALID_SOCKET_VALUE) 121 { 122 THROW_EXCEPTION(ServerException, SocketAlreadyOpen) 123 } 121 124 122 125 mSocketHandle = socket; … … 135 138 void SocketStream::Open(int Type, const char *Name, int Port) 136 139 { 137 if(mSocketHandle != -1) {THROW_EXCEPTION(ServerException, SocketAlreadyOpen)} 140 if(mSocketHandle != INVALID_SOCKET_VALUE) 141 { 142 THROW_EXCEPTION(ServerException, SocketAlreadyOpen) 143 } 138 144 139 145 // Setup parameters based on type, looking up names if required … … 145 151 // Create the socket 146 152 mSocketHandle = ::socket(sockDomain, SOCK_STREAM, 0 /* let OS choose protocol */); 147 if(mSocketHandle == -1)153 if(mSocketHandle == INVALID_SOCKET_VALUE) 148 154 { 149 155 THROW_EXCEPTION(ServerException, SocketOpenError) … … 159 165 ::close(mSocketHandle); 160 166 #endif 161 mSocketHandle = -1;167 mSocketHandle = INVALID_SOCKET_VALUE; 162 168 THROW_EXCEPTION(ConnectionException, Conn_SocketConnectError) 163 169 } … … 175 181 int SocketStream::Read(void *pBuffer, int NBytes, int Timeout) 176 182 { 177 if(mSocketHandle == -1) {THROW_EXCEPTION(ServerException, BadSocketHandle)} 183 if(mSocketHandle == INVALID_SOCKET_VALUE) 184 { 185 THROW_EXCEPTION(ServerException, BadSocketHandle) 186 } 178 187 179 188 if(Timeout != IOStream::TimeOutInfinite) … … 248 257 void SocketStream::Write(const void *pBuffer, int NBytes) 249 258 { 250 if(mSocketHandle == -1) {THROW_EXCEPTION(ServerException, BadSocketHandle)} 259 if(mSocketHandle == INVALID_SOCKET_VALUE) 260 { 261 THROW_EXCEPTION(ServerException, BadSocketHandle) 262 } 251 263 252 264 // Buffer in byte sized type. … … 312 324 void SocketStream::Close() 313 325 { 314 if(mSocketHandle == -1) {THROW_EXCEPTION(ServerException, BadSocketHandle)} 326 if(mSocketHandle == INVALID_SOCKET_VALUE) 327 { 328 THROW_EXCEPTION(ServerException, BadSocketHandle) 329 } 315 330 #ifdef WIN32 316 331 if(::closesocket(mSocketHandle) == -1) … … 321 336 THROW_EXCEPTION(ServerException, SocketCloseError) 322 337 } 323 mSocketHandle = -1;338 mSocketHandle = INVALID_SOCKET_VALUE; 324 339 } 325 340 … … 334 349 void SocketStream::Shutdown(bool Read, bool Write) 335 350 { 336 if(mSocketHandle == -1) {THROW_EXCEPTION(ServerException, BadSocketHandle)} 351 if(mSocketHandle == INVALID_SOCKET_VALUE) 352 { 353 THROW_EXCEPTION(ServerException, BadSocketHandle) 354 } 337 355 338 356 // Do anything? … … 389 407 tOSSocketHandle SocketStream::GetSocketHandle() 390 408 { 391 if(mSocketHandle == -1) {THROW_EXCEPTION(ServerException, BadSocketHandle)} 409 if(mSocketHandle == INVALID_SOCKET_VALUE) 410 { 411 THROW_EXCEPTION(ServerException, BadSocketHandle) 412 } 392 413 return mSocketHandle; 393 414 }
Note: See TracChangeset
for help on using the changeset viewer.
