m_serviceManager->Close(event.connectionID);
}
-void AppPermissionsService::read(const ReadEvent &event) {
+void AppPermissionsService::process(const ReadEvent &event) {
LogDebug("Read event for counter: " << event.connectionID.counter);
auto &buffer = m_messageBufferMap[event.connectionID.counter];
buffer.Push(event.rawBuffer);
// We can get several requests in one package.
// Extract and process them all
- while(readOne(event.connectionID, buffer));
+ while(processOne(event.connectionID, buffer));
}
void AppPermissionsService::close(const CloseEvent &event) {
m_messageBufferMap.erase(event.connectionID.counter);
}
-bool AppPermissionsService::readOne(const ConnectionID &conn, MessageBuffer &buffer)
+bool AppPermissionsService::processOne(const ConnectionID &conn, MessageBuffer &buffer)
{
LogDebug("Iteration begin");
MessageBuffer send, recv;
DECLARE_THREAD_EVENT(AcceptEvent, accept)
DECLARE_THREAD_EVENT(WriteEvent, write)
- DECLARE_THREAD_EVENT(ReadEvent, read)
+ DECLARE_THREAD_EVENT(ReadEvent, process)
DECLARE_THREAD_EVENT(CloseEvent, close)
void accept(const AcceptEvent &event);
void write(const WriteEvent &event);
- void read(const ReadEvent &event);
+ void process(const ReadEvent &event);
void close(const CloseEvent &event);
private:
- bool readOne(const ConnectionID &conn, MessageBuffer &buffer);
+ bool processOne(const ConnectionID &conn, MessageBuffer &buffer);
MessageBufferMap m_messageBufferMap;
};
m_serviceManager->Close(event.connectionID);
}
-void CookieService::read(const ReadEvent &event) {
+void CookieService::process(const ReadEvent &event) {
LogDebug("Read event for counter: " << event.connectionID.counter);
auto &info = m_socketInfoMap[event.connectionID.counter];
info.buffer.Push(event.rawBuffer);
// We can get several requests in one package.
// Extract and process them all
- while(readOne(event.connectionID, info.buffer, info.interfaceID));
+ while(processOne(event.connectionID, info.buffer, info.interfaceID));
}
void CookieService::close(const CloseEvent &event) {
m_socketInfoMap.erase(event.connectionID.counter);
}
-bool CookieService::readOne(const ConnectionID &conn, MessageBuffer &buffer, int interfaceID)
+bool CookieService::processOne(const ConnectionID &conn, MessageBuffer &buffer, int interfaceID)
{
LogDebug("Iteration begin");
MessageBuffer send, recv;
DECLARE_THREAD_EVENT(AcceptEvent, accept)
DECLARE_THREAD_EVENT(WriteEvent, write)
- DECLARE_THREAD_EVENT(ReadEvent, read)
+ DECLARE_THREAD_EVENT(ReadEvent, process)
DECLARE_THREAD_EVENT(CloseEvent, close)
void accept(const AcceptEvent &event);
void write(const WriteEvent &event);
- void read(const ReadEvent &event);
+ void process(const ReadEvent &event);
void close(const CloseEvent &event);
private:
- bool readOne(const ConnectionID &conn, MessageBuffer &buffer, int interfaceID);
+ bool processOne(const ConnectionID &conn, MessageBuffer &buffer, int interfaceID);
bool cookieRequest(MessageBuffer &send, int socket);
m_serviceManager->Close(event.connectionID);
}
-bool SharedMemoryService::readOne(const ConnectionID &conn, MessageBuffer &buffer) {
+bool SharedMemoryService::processOne(const ConnectionID &conn, MessageBuffer &buffer) {
LogDebug("Iteration begin");
static const char * const revoke = "-----";
static const char * const permissions = "rwxat";
return true;
}
-void SharedMemoryService::read(const ReadEvent &event) {
+void SharedMemoryService::process(const ReadEvent &event) {
LogDebug("Read event for counter: " << event.connectionID.counter);
auto &buffer = m_messageBufferMap[event.connectionID.counter];
buffer.Push(event.rawBuffer);
// We can get several requests in one package.
// Extract and process them all
- while(readOne(event.connectionID, buffer));
+ while(processOne(event.connectionID, buffer));
}
void SharedMemoryService::close(const CloseEvent &event) {
DECLARE_THREAD_EVENT(AcceptEvent, accept)
DECLARE_THREAD_EVENT(WriteEvent, write)
- DECLARE_THREAD_EVENT(ReadEvent, read)
+ DECLARE_THREAD_EVENT(ReadEvent, process)
DECLARE_THREAD_EVENT(CloseEvent, close)
void accept(const AcceptEvent &event);
void write(const WriteEvent &event);
- void read(const ReadEvent &event);
+ void process(const ReadEvent &event);
void close(const CloseEvent &event);
private:
- bool readOne(const ConnectionID &conn, MessageBuffer &buffer);
+ bool processOne(const ConnectionID &conn, MessageBuffer &buffer);
MessageBufferMap m_messageBufferMap;
};
m_serviceManager->Close(event.connectionID);
}
-void EchoService::read(const ReadEvent &event) {
+void EchoService::process(const ReadEvent &event) {
LogDebug("ReadEvent. ConnectionID: " << event.connectionID.sock <<
" Buffer size: " << event.rawBuffer.size());
m_serviceManager->Write(event.connectionID, event.rawBuffer);
DECLARE_THREAD_EVENT(AcceptEvent, accept)
DECLARE_THREAD_EVENT(WriteEvent, write)
- DECLARE_THREAD_EVENT(ReadEvent, read)
+ DECLARE_THREAD_EVENT(ReadEvent, process)
DECLARE_THREAD_EVENT(CloseEvent, close)
void accept(const AcceptEvent &event);
void write(const WriteEvent &event);
- void read(const ReadEvent &event);
+ void process(const ReadEvent &event);
void close(const CloseEvent &event);
};
return true;
}
-void ExecPathService::read(const ReadEvent &event) {
+void ExecPathService::process(const ReadEvent &event) {
LogDebug("Read event for counter: " << event.connectionID.counter);
auto &buffer = m_messageBufferMap[event.connectionID.counter];
buffer.Push(event.rawBuffer);
DECLARE_THREAD_EVENT(AcceptEvent, accept)
DECLARE_THREAD_EVENT(WriteEvent, write)
- DECLARE_THREAD_EVENT(ReadEvent, read)
+ DECLARE_THREAD_EVENT(ReadEvent, process)
DECLARE_THREAD_EVENT(CloseEvent, close)
void accept(const AcceptEvent &event);
void write(const WriteEvent &event);
- void read(const ReadEvent &event);
+ void process(const ReadEvent &event);
void close(const CloseEvent &event);
private:
bool processOne(const ConnectionID &conn, MessageBuffer &buffer);
}
-bool GetGidService::readOne(const ConnectionID &conn, MessageBuffer &buffer) {
+bool GetGidService::processOne(const ConnectionID &conn, MessageBuffer &buffer) {
LogDebug("Iteration begin");
std::string objectName;
int retCode = SECURITY_SERVER_API_ERROR_SERVER_ERROR;
return true;
}
-void GetGidService::read(const ReadEvent &event) {
+void GetGidService::process(const ReadEvent &event) {
LogDebug("Read event for counter: " << event.connectionID.counter);
auto &buffer = m_messageBufferMap[event.connectionID.counter];
buffer.Push(event.rawBuffer);
// We can get several requests in one package.
// Extract and process them all
- while(readOne(event.connectionID, buffer));
+ while(processOne(event.connectionID, buffer));
}
void GetGidService::close(const CloseEvent &event) {
DECLARE_THREAD_EVENT(AcceptEvent, accept)
DECLARE_THREAD_EVENT(WriteEvent, write)
- DECLARE_THREAD_EVENT(ReadEvent, read)
+ DECLARE_THREAD_EVENT(ReadEvent, process)
DECLARE_THREAD_EVENT(CloseEvent, close)
void accept(const AcceptEvent &event);
void write(const WriteEvent &event);
- void read(const ReadEvent &event);
+ void process(const ReadEvent &event);
void close(const CloseEvent &event);
private:
gid_t m_gid;
- bool readOne(const ConnectionID &conn, MessageBuffer &buffer);
+ bool processOne(const ConnectionID &conn, MessageBuffer &buffer);
int setGid(std::string& objectName);
MessageBufferMap m_messageBufferMap;
};
}
-bool GetObjectNameService::readOne(const ConnectionID &conn, MessageBuffer &buffer) {
+bool GetObjectNameService::processOne(const ConnectionID &conn, MessageBuffer &buffer) {
LogDebug("Iteration begin");
gid_t gid;
int retCode = SECURITY_SERVER_API_ERROR_SERVER_ERROR;
return true;
}
-void GetObjectNameService::read(const ReadEvent &event) {
+void GetObjectNameService::process(const ReadEvent &event) {
LogDebug("Read event for counter: " << event.connectionID.counter);
auto &buffer = m_messageBufferMap[event.connectionID.counter];
buffer.Push(event.rawBuffer);
// We can get several requests in one package.
// Extract and process them all
- while(readOne(event.connectionID, buffer));
+ while(processOne(event.connectionID, buffer));
}
void GetObjectNameService::close(const CloseEvent &event) {
DECLARE_THREAD_EVENT(AcceptEvent, accept)
DECLARE_THREAD_EVENT(WriteEvent, write)
- DECLARE_THREAD_EVENT(ReadEvent, read)
+ DECLARE_THREAD_EVENT(ReadEvent, process)
DECLARE_THREAD_EVENT(CloseEvent, close)
void accept(const AcceptEvent &event);
void write(const WriteEvent &event);
- void read(const ReadEvent &event);
+ void process(const ReadEvent &event);
void close(const CloseEvent &event);
private:
std::string m_name;
- bool readOne(const ConnectionID &conn, MessageBuffer &buffer);
+ bool processOne(const ConnectionID &conn, MessageBuffer &buffer);
int setName(gid_t gid);
MessageBufferMap m_messageBufferMap;
};
m_serviceManager->Close(event.connectionID);
}
-bool PrivilegeByPidService::readOne(const ConnectionID &conn, MessageBuffer &buffer) {
+bool PrivilegeByPidService::processOne(const ConnectionID &conn, MessageBuffer &buffer) {
LogDebug("Iteration begin");
int retval;
return true;
}
-void PrivilegeByPidService::read(const ReadEvent &event) {
+void PrivilegeByPidService::process(const ReadEvent &event) {
LogDebug("Read event for counter: " << event.connectionID.counter);
auto &buffer = m_messageBufferMap[event.connectionID.counter];
buffer.Push(event.rawBuffer);
// We can get several requests in one package.
// Extract and process them all
- while(readOne(event.connectionID, buffer));
+ while(processOne(event.connectionID, buffer));
}
void PrivilegeByPidService::close(const CloseEvent &event) {
DECLARE_THREAD_EVENT(AcceptEvent, accept)
DECLARE_THREAD_EVENT(WriteEvent, write)
- DECLARE_THREAD_EVENT(ReadEvent, read)
+ DECLARE_THREAD_EVENT(ReadEvent, process)
DECLARE_THREAD_EVENT(CloseEvent, close)
void accept(const AcceptEvent &event);
void write(const WriteEvent &event);
- void read(const ReadEvent &event);
+ void process(const ReadEvent &event);
void close(const CloseEvent &event);
private:
- bool readOne(const ConnectionID &conn, MessageBuffer &buffer);
+ bool processOne(const ConnectionID &conn, MessageBuffer &buffer);
MessageBufferMap m_messageBufferMap;
};