hydrar/mistserver
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Updated controller to make use of new HTTP capabilities.

Browse source
This commit is contained in:
Thulinma 2013-08-29 15:13:07 +02:00
parent f937af0502
commit 90436e100d
1 changed files with 2 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/controller/controller.cpp
View file

@ -342,7 +342,7 @@ int main(int argc, char ** argv){
Converter::Converter myConverter; Converter::Converter myConverter;
while (API_Socket.connected() && conf.is_active){ while (API_Socket.connected() && conf.is_active){
usleep(10000); //sleep for 10 ms - prevents 100% CPU time Util::sleep(10);//sleep for 10 ms - prevents 100% CPU time
if (Util::epoch() - processchecker > 10){ if (Util::epoch() - processchecker > 10){
processchecker = Util::epoch(); processchecker = Util::epoch();
@ -470,17 +470,7 @@ int main(int argc, char ** argv){
break; break;
} }
if (it->C.spool() || it->C.Received().size()){ if (it->C.spool() || it->C.Received().size()){
if ( *(it->C.Received().get().rbegin()) != '\n'){ if (it->H.Read(it->C)){
std::string tmp = it->C.Received().get();
it->C.Received().get().clear();
if (it->C.Received().size()){
it->C.Received().get().insert(0, tmp);
}else{
it->C.Received().append(tmp);
}
continue;
}
if (it->H.Read(it->C.Received().get())){
Response.null(); //make sure no data leaks from previous requests Response.null(); //make sure no data leaks from previous requests
if (it->clientMode){ if (it->clientMode){
// In clientMode, requests are reversed. These are connections we initiated to GearBox. // In clientMode, requests are reversed. These are connections we initiated to GearBox.