diff options
Diffstat (limited to 'src/itoserver.cpp')
-rw-r--r-- | src/itoserver.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/itoserver.cpp b/src/itoserver.cpp index ea737bf..9f03417 100644 --- a/src/itoserver.cpp +++ b/src/itoserver.cpp | |||
@@ -1,5 +1,5 @@ | |||
1 | /* | 1 | /* |
2 | * Copyright (C) 2007-2010 Xagasoft, All rights reserved. | 2 | * Copyright (C) 2007-2011 Xagasoft, All rights reserved. |
3 | * | 3 | * |
4 | * This file is part of the libbu++ library and is released under the | 4 | * This file is part of the libbu++ library and is released under the |
5 | * terms of the license contained in the file LICENSE. | 5 | * terms of the license contained in the file LICENSE. |
@@ -47,7 +47,7 @@ void Bu::ItoServer::addPort( int nPort, int nPoolSize ) | |||
47 | hServers.insert( nSocket, s ); | 47 | hServers.insert( nSocket, s ); |
48 | } | 48 | } |
49 | 49 | ||
50 | void Bu::ItoServer::addPort( const FString &sAddr, int nPort, int nPoolSize ) | 50 | void Bu::ItoServer::addPort( const String &sAddr, int nPort, int nPoolSize ) |
51 | { | 51 | { |
52 | TcpServerSocket *s = new TcpServerSocket( sAddr, nPort, nPoolSize ); | 52 | TcpServerSocket *s = new TcpServerSocket( sAddr, nPort, nPoolSize ); |
53 | int nSocket = s->getSocket(); | 53 | int nSocket = s->getSocket(); |
@@ -163,7 +163,7 @@ void Bu::ItoServer::ItoClient::run() | |||
163 | while( !qMsg.isEmpty() ) | 163 | while( !qMsg.isEmpty() ) |
164 | { | 164 | { |
165 | imProto.lock(); | 165 | imProto.lock(); |
166 | Bu::FString *pMsg = qMsg.dequeue(); | 166 | Bu::String *pMsg = qMsg.dequeue(); |
167 | pClient->onMessage( *pMsg ); | 167 | pClient->onMessage( *pMsg ); |
168 | delete pMsg; | 168 | delete pMsg; |
169 | pClient->processOutput(); | 169 | pClient->processOutput(); |
@@ -205,7 +205,7 @@ Bu::ItoServer::SrvClientLink::~SrvClientLink() | |||
205 | { | 205 | { |
206 | } | 206 | } |
207 | 207 | ||
208 | void Bu::ItoServer::SrvClientLink::sendMessage( const Bu::FString &sMsg ) | 208 | void Bu::ItoServer::SrvClientLink::sendMessage( const Bu::String &sMsg ) |
209 | { | 209 | { |
210 | if( !pClient->imProto.trylock() ) | 210 | if( !pClient->imProto.trylock() ) |
211 | { | 211 | { |
@@ -215,7 +215,7 @@ void Bu::ItoServer::SrvClientLink::sendMessage( const Bu::FString &sMsg ) | |||
215 | } | 215 | } |
216 | else | 216 | else |
217 | { | 217 | { |
218 | Bu::FString *pMsg = new Bu::FString( sMsg ); | 218 | Bu::String *pMsg = new Bu::String( sMsg ); |
219 | pClient->qMsg.enqueue( pMsg ); | 219 | pClient->qMsg.enqueue( pMsg ); |
220 | } | 220 | } |
221 | } | 221 | } |