ConnectionID connectionID;
};
- struct ErrorEvent : public GenericEvent {
- ConnectionID connectionID;
- };
-
virtual void SetSocketManager(GenericSocketManager *manager) {
m_serviceManager = manager;
}
virtual void Event(const WriteEvent &event) = 0;
virtual void Event(const ReadEvent &event) = 0;
virtual void Event(const CloseEvent &event) = 0;
- virtual void Event(const ErrorEvent &event) = 0;
GenericSocketService() : m_serviceManager(NULL) {}
virtual ~GenericSocketService(){}
void Event(const WriteEvent &event) { (void)event; }
void Event(const ReadEvent &event) { (void)event; }
void Event(const CloseEvent &event) { (void)event; }
- void Event(const ErrorEvent &event) { (void)event; }
};
struct SignalService : public GenericSocketService {
void Event(const AcceptEvent &event) { (void)event; } // not supported
void Event(const WriteEvent &event) { (void)event; } // not supported
void Event(const CloseEvent &event) { (void)event; } // not supported
- void Event(const ErrorEvent &event) { (void)event; } // not supported
void Event(const ReadEvent &event) {
LogDebug("Get signal information");
m_messageBufferMap.erase(event.connectionID.counter);
}
-void AppPermissionsService::error(const ErrorEvent &event) {
- LogDebug("ErrorEvent. ConnectionID: " << event.connectionID.sock);
- m_serviceManager->Close(event.connectionID);
-}
-
bool AppPermissionsService::readOne(const ConnectionID &conn, MessageBuffer &buffer)
{
LogDebug("Iteration begin");
DECLARE_THREAD_EVENT(WriteEvent, write)
DECLARE_THREAD_EVENT(ReadEvent, read)
DECLARE_THREAD_EVENT(CloseEvent, close)
- DECLARE_THREAD_EVENT(ErrorEvent, error)
void accept(const AcceptEvent &event);
void write(const WriteEvent &event);
void read(const ReadEvent &event);
void close(const CloseEvent &event);
- void error(const ErrorEvent &event);
private:
bool readOne(const ConnectionID &conn, MessageBuffer &buffer);
m_socketInfoMap.erase(event.connectionID.counter);
}
-void CookieService::error(const ErrorEvent &event) {
- LogDebug("ErrorEvent. ConnectionID: " << event.connectionID.sock);
- m_serviceManager->Close(event.connectionID);
-}
-
bool CookieService::readOne(const ConnectionID &conn, MessageBuffer &buffer, int interfaceID)
{
LogDebug("Iteration begin");
DECLARE_THREAD_EVENT(WriteEvent, write)
DECLARE_THREAD_EVENT(ReadEvent, read)
DECLARE_THREAD_EVENT(CloseEvent, close)
- DECLARE_THREAD_EVENT(ErrorEvent, error)
void accept(const AcceptEvent &event);
void write(const WriteEvent &event);
void read(const ReadEvent &event);
void close(const CloseEvent &event);
- void error(const ErrorEvent &event);
private:
bool readOne(const ConnectionID &conn, MessageBuffer &buffer, int interfaceID);
m_messageBufferMap.erase(event.connectionID.counter);
}
-void SharedMemoryService::error(const ErrorEvent &event) {
- LogDebug("ErrorEvent. ConnectionID: " << event.connectionID.sock);
- m_serviceManager->Close(event.connectionID);
-}
-
} // namespace SecurityServer
DECLARE_THREAD_EVENT(WriteEvent, write)
DECLARE_THREAD_EVENT(ReadEvent, read)
DECLARE_THREAD_EVENT(CloseEvent, close)
- DECLARE_THREAD_EVENT(ErrorEvent, error)
void accept(const AcceptEvent &event);
void write(const WriteEvent &event);
void read(const ReadEvent &event);
void close(const CloseEvent &event);
- void error(const ErrorEvent &event);
private:
bool readOne(const ConnectionID &conn, MessageBuffer &buffer);
LogDebug("CloseEvent. ConnectionID: " << event.connectionID.sock);
}
-void EchoService::error(const ErrorEvent &event) {
- LogDebug("ErrorEvent. ConnectionID: " << event.connectionID.sock);
- m_serviceManager->Close(event.connectionID);
-}
-
} // namespace SecurityServer
DECLARE_THREAD_EVENT(WriteEvent, write)
DECLARE_THREAD_EVENT(ReadEvent, read)
DECLARE_THREAD_EVENT(CloseEvent, close)
- DECLARE_THREAD_EVENT(ErrorEvent, error)
void accept(const AcceptEvent &event);
void write(const WriteEvent &event);
void read(const ReadEvent &event);
void close(const CloseEvent &event);
- void error(const ErrorEvent &event);
};
} // namespace SecurityServer
m_messageBufferMap.erase(event.connectionID.counter);
}
-void ExecPathService::error(const ErrorEvent &event) {
- LogDebug("ErrorEvent. ConnectionID: " << event.connectionID.sock);
- m_serviceManager->Close(event.connectionID);
-}
-
} // namespace SecurityServer
DECLARE_THREAD_EVENT(WriteEvent, write)
DECLARE_THREAD_EVENT(ReadEvent, read)
DECLARE_THREAD_EVENT(CloseEvent, close)
- DECLARE_THREAD_EVENT(ErrorEvent, error)
void accept(const AcceptEvent &event);
void write(const WriteEvent &event);
void read(const ReadEvent &event);
void close(const CloseEvent &event);
- void error(const ErrorEvent &event);
private:
bool processOne(const ConnectionID &conn, MessageBuffer &buffer);
MessageBufferMap m_messageBufferMap;
m_messageBufferMap.erase(event.connectionID.counter);
}
-void GetGidService::error(const ErrorEvent &event) {
- LogDebug("ErrorEvent. ConnectionID: " << event.connectionID.sock);
- m_serviceManager->Close(event.connectionID);
-}
-
} // namespace SecurityServer
DECLARE_THREAD_EVENT(WriteEvent, write)
DECLARE_THREAD_EVENT(ReadEvent, read)
DECLARE_THREAD_EVENT(CloseEvent, close)
- DECLARE_THREAD_EVENT(ErrorEvent, error)
void accept(const AcceptEvent &event);
void write(const WriteEvent &event);
void read(const ReadEvent &event);
void close(const CloseEvent &event);
- void error(const ErrorEvent &event);
private:
gid_t m_gid;
bool readOne(const ConnectionID &conn, MessageBuffer &buffer);
m_messageBufferMap.erase(event.connectionID.counter);
}
-void GetObjectNameService::error(const ErrorEvent &event) {
- LogError("ErrorEvent. ConnectionID: " << event.connectionID.sock);
- m_serviceManager->Close(event.connectionID);
-}
-
} // namespace SecurityServer
DECLARE_THREAD_EVENT(WriteEvent, write)
DECLARE_THREAD_EVENT(ReadEvent, read)
DECLARE_THREAD_EVENT(CloseEvent, close)
- DECLARE_THREAD_EVENT(ErrorEvent, error)
void accept(const AcceptEvent &event);
void write(const WriteEvent &event);
void read(const ReadEvent &event);
void close(const CloseEvent &event);
- void error(const ErrorEvent &event);
private:
std::string m_name;
m_messageBufferMap.erase(event.connectionID.counter);
}
-void PrivilegeByPidService::error(const ErrorEvent &event) {
- LogDebug("ErrorEvent. ConnectionID: " << event.connectionID.sock);
- m_serviceManager->Close(event.connectionID);
-}
-
} // namespace SecurityServer
DECLARE_THREAD_EVENT(WriteEvent, write)
DECLARE_THREAD_EVENT(ReadEvent, read)
DECLARE_THREAD_EVENT(CloseEvent, close)
- DECLARE_THREAD_EVENT(ErrorEvent, error)
void accept(const AcceptEvent &event);
void write(const WriteEvent &event);
void read(const ReadEvent &event);
void close(const CloseEvent &event);
- void error(const ErrorEvent &event);
private:
bool readOne(const ConnectionID &conn, MessageBuffer &buffer);