diff options
| author | Mike Buland <eichlan@xagasoft.com> | 2011-01-20 18:09:04 +0000 |
|---|---|---|
| committer | Mike Buland <eichlan@xagasoft.com> | 2011-01-20 18:09:04 +0000 |
| commit | 393f1b414746a7f1977971dd7659dd2b47092b11 (patch) | |
| tree | 81d0ca1ee70ab86a7d79c1991abe5c387b655fb2 /src/itoserver.cpp | |
| parent | c259f95bd0e58b247940a339bb9b4b401b4e9438 (diff) | |
| parent | 7e25a863325dc3e9762397e700030969e093b087 (diff) | |
| download | libbu++-393f1b414746a7f1977971dd7659dd2b47092b11.tar.gz libbu++-393f1b414746a7f1977971dd7659dd2b47092b11.tar.bz2 libbu++-393f1b414746a7f1977971dd7659dd2b47092b11.tar.xz libbu++-393f1b414746a7f1977971dd7659dd2b47092b11.zip | |
Wow! Merged the branch, streams are updated, and there's no more FString, run
the fixstrings.sh script in the support directory to (hopefully) automatically
update your projects.
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 | } |
