Locks added, rnd logic for ALIVE changed, CONN_ACK bug fixed

[stg.git] / projects / stargazer / plugins / configuration / sgconfig / rsconf.cpp

diff --git a/projects/stargazer/plugins/configuration/sgconfig/rsconf.cpp b/projects/stargazer/plugins/configuration/sgconfig/rsconf.cpp
index a3957f361f6123c3cf53ca4a5739be4dfb17aea7..479a135703f24edbdaff610732da870e5393e299 100644 (file)
--- a/projects/stargazer/plugins/configuration/sgconfig/rsconf.cpp
+++ b/projects/stargazer/plugins/configuration/sgconfig/rsconf.cpp
@@ -26,12 +26,14 @@
 *
 *******************************************************************/
 
 *
 *******************************************************************/
 

+#include <unistd.h> // cloase, usleep
+

 #include <cerrno>
 #include <csignal>
 #include <cstdio> // snprintf
 
 #include <cerrno>
 #include <csignal>
 #include <cstdio> // snprintf
 

+#include "stg/blowfish.h"

 #include "configproto.h"
 #include "configproto.h"

-#include "blowfish.h"

 
 #ifndef ENODATA
 // FreeBSD 4.* - suxx
 
 #ifndef ENODATA
 // FreeBSD 4.* - suxx


@@ -338,7 +340,7 @@ if (admins->FindAdmin(login, &currAdmin))
     state = confHdr;
     return ENODATA;
     }
     state = confHdr;
     return ENODATA;
     }

-currAdmin.SetAdminIP(adminIP);
+currAdmin->SetIP(adminIP);

 adminLogin = login;
 state = confLoginCipher;
 return 0;
 adminLogin = login;
 state = confLoginCipher;
 return 0;


@@ -383,13 +385,13 @@ while (total < ADM_LOGIN_LEN)
     total += ret;
     }
 
     total += ret;
     }
 

-if (currAdmin.GetLogin() == "")
+if (currAdmin->GetLogin() == "")

     {
     state = confHdr;
     return ENODATA;
     }
 
     {
     state = confHdr;
     return ENODATA;
     }
 

-EnDecodeInit(currAdmin.GetPassword().c_str(), ADM_PASSWD_LEN, &ctx);
+EnDecodeInit(currAdmin->GetPassword().c_str(), ADM_PASSWD_LEN, &ctx);

 
 for (int i = 0; i < ADM_LOGIN_LEN/8; i++)
     {
 
 for (int i = 0; i < ADM_LOGIN_LEN/8; i++)
     {


@@ -403,7 +405,7 @@ if (currAdmin == admins->GetNoAdmin())
     return 0;
     }
 
     return 0;
     }
 

-if (strncmp(currAdmin.GetLogin().c_str(), login, ADM_LOGIN_LEN) != 0)
+if (strncmp(currAdmin->GetLogin().c_str(), login, ADM_LOGIN_LEN) != 0)

     {
     state = confHdr;
     return ENODATA;
     {
     state = confHdr;
     return ENODATA;


@@ -449,7 +451,7 @@ buffer[8] = 0;
 requestList.clear();
 BLOWFISH_CTX ctx;
 
 requestList.clear();
 BLOWFISH_CTX ctx;
 

-EnDecodeInit(currAdmin.GetPassword().c_str(), ADM_PASSWD_LEN, &ctx);
+EnDecodeInit(currAdmin->GetPassword().c_str(), ADM_PASSWD_LEN, &ctx);

 
 while (1)
     {
 
 while (1)
     {


@@ -506,7 +508,7 @@ int n = 0;
 int k = 0;
 int ret = 0;
 
 int k = 0;
 int ret = 0;
 

-EnDecodeInit(currAdmin.GetPassword().c_str(), ADM_PASSWD_LEN, &ctx);
+EnDecodeInit(currAdmin->GetPassword().c_str(), ADM_PASSWD_LEN, &ctx);

 
 while (li != answerList.end())
     {
 
 while (li != answerList.end())
     {


@@ -527,7 +529,7 @@ while (li != answerList.end())
             }
         }
     k = 0;// new node
             }
         }
     k = 0;// new node

-    li++;
+    ++li;

     }
 
 if (answerList.empty()) {
     }
 
 if (answerList.empty()) {