2 * This program is free software; you can redistribute it and/or modify
3 * it under the terms of the GNU General Public License as published by
4 * the Free Software Foundation; either version 2 of the License, or
5 * (at your option) any later version.
7 * This program is distributed in the hope that it will be useful,
8 * but WITHOUT ANY WARRANTY; without even the implied warranty of
9 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
10 * GNU General Public License for more details.
12 * You should have received a copy of the GNU General Public License
13 * along with this program; if not, write to the Free Software
14 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
18 * Author : Boris Mikhailenko <stg34@stargazer.dp.ua>
23 $Date: 2010/10/07 20:04:48 $
39 #include "stg/os_int.h"
40 #include "stg/store.h"
41 #include "stg/users.h"
43 #include "stg/tariffs.h"
44 #include "stg/logger.h"
45 #include "stg/notifer.h"
46 #include "stg/noncopyable.h"
48 #include "eventloop.h"
49 #include "settings_impl.h"
50 #include "user_impl.h"
52 const int userDeleteDelayTime = 120;
54 typedef std::list<USER_IMPL>::iterator user_iter;
55 typedef std::list<USER_IMPL>::const_iterator const_user_iter;
58 //-----------------------------------------------------------------------------
59 class PROPERTY_NOTIFER_IP_BEFORE: public PROPERTY_NOTIFIER_BASE<uint32_t> {
61 PROPERTY_NOTIFER_IP_BEFORE(USERS_IMPL & us, user_iter u) : users(us), user(u) {}
62 void Notify(const uint32_t & oldValue, const uint32_t & newValue);
63 user_iter GetUser() const { return user; }
68 //-----------------------------------------------------------------------------
69 class PROPERTY_NOTIFER_IP_AFTER: public PROPERTY_NOTIFIER_BASE<uint32_t> {
71 PROPERTY_NOTIFER_IP_AFTER(USERS_IMPL & us, user_iter u) : users(us), user(u) {}
72 void Notify(const uint32_t & oldValue, const uint32_t & newValue);
73 user_iter GetUser() const { return user; }
78 //-----------------------------------------------------------------------------
85 std::list<USER_IMPL>::iterator iter;
88 //-----------------------------------------------------------------------------
89 class USERS_IMPL : private NONCOPYABLE, public USERS {
90 friend class PROPERTY_NOTIFER_IP_BEFORE;
91 friend class PROPERTY_NOTIFER_IP_AFTER;
94 USERS_IMPL(SETTINGS_IMPL * s, STORE * store, TARIFFS * tariffs, const ADMIN * sysAdmin);
95 virtual ~USERS_IMPL();
97 int FindByName(const std::string & login, USER_PTR * user);
99 bool TariffInUse(const std::string & tariffName) const;
101 void AddNotifierUserAdd(NOTIFIER_BASE<USER_PTR> *);
102 void DelNotifierUserAdd(NOTIFIER_BASE<USER_PTR> *);
104 void AddNotifierUserDel(NOTIFIER_BASE<USER_PTR> *);
105 void DelNotifierUserDel(NOTIFIER_BASE<USER_PTR> *);
107 void AddNotifierUserAdd(NOTIFIER_BASE<USER_IMPL_PTR> *);
108 void DelNotifierUserAdd(NOTIFIER_BASE<USER_IMPL_PTR> *);
110 void AddNotifierUserDel(NOTIFIER_BASE<USER_IMPL_PTR> *);
111 void DelNotifierUserDel(NOTIFIER_BASE<USER_IMPL_PTR> *);
113 int Add(const std::string & login, const ADMIN * admin);
114 void Del(const std::string & login, const ADMIN * admin);
117 int GetUserNum() const;
119 int FindByIPIdx(uint32_t ip, USER_PTR * user) const;
120 int FindByIPIdx(uint32_t ip, USER_IMPL ** user) const;
121 bool IsIPInIndex(uint32_t ip) const;
124 int SearchNext(int handler, USER_PTR * user);
125 int SearchNext(int handler, USER_IMPL ** user);
126 int CloseSearch(int handler);
132 void AddToIPIdx(user_iter user);
133 void DelFromIPIdx(uint32_t ip);
135 int FindByNameNonLock(const std::string & login, user_iter * user);
138 void ProcessActions();
140 void SetUserNotifiers(user_iter user);
141 void UnSetUserNotifiers(user_iter user);
143 void AddUserIntoIndexes(user_iter user);
144 void DelUserFromIndexes(user_iter user);
146 static void * Run(void *);
147 void NewMinute(const struct tm & t);
148 void NewDay(const struct tm & t);
149 void DayResetTraff(const struct tm & t);
151 bool TimeToWriteDetailStat(const struct tm & t);
153 std::list<USER_IMPL> users;
154 std::list<USER_TO_DEL> usersToDelete;
155 std::list<PROPERTY_NOTIFER_IP_BEFORE> userIPNotifiersBefore;
156 std::list<PROPERTY_NOTIFER_IP_AFTER> userIPNotifiersAfter;
158 std::map<uint32_t, user_iter> ipIndex;
159 std::map<std::string, user_iter> loginIndex;
161 SETTINGS_IMPL * settings;
164 const ADMIN * sysAdmin;
165 STG_LOGGER & WriteServLog;
170 mutable pthread_mutex_t mutex;
172 mutable unsigned int handle;
174 mutable std::map<int, user_iter> searchDescriptors;
176 std::set<NOTIFIER_BASE<USER_PTR>*> onAddNotifiers;
177 std::set<NOTIFIER_BASE<USER_PTR>*> onDelNotifiers;
178 std::set<NOTIFIER_BASE<USER_IMPL_PTR>*> onAddNotifiersImpl;
179 std::set<NOTIFIER_BASE<USER_IMPL_PTR>*> onDelNotifiersImpl;
181 //-----------------------------------------------------------------------------
183 void PROPERTY_NOTIFER_IP_BEFORE::Notify(const uint32_t & oldValue,
189 //EVENT_LOOP_SINGLETON::GetInstance().Enqueue(users, &USERS::DelFromIPIdx, oldValue);
190 // Using explicit call to assure that index is valid, because fast reconnect with delayed call can result in authorization error
191 users.DelFromIPIdx(oldValue);
193 //-----------------------------------------------------------------------------
195 void PROPERTY_NOTIFER_IP_AFTER::Notify(const uint32_t &,
196 const uint32_t & newValue)
201 //EVENT_LOOP_SINGLETON::GetInstance().Enqueue(users, &USERS::AddToIPIdx, user);
202 // Using explicit call to assure that index is valid, because fast reconnect with delayed call can result in authorization error
203 users.AddToIPIdx(user);
205 //-----------------------------------------------------------------------------