void Event(const ReadEvent &event) {
LogDebug("Get signal information");
- if(sizeof(struct signalfd_siginfo) != event.rawBuffer.size()) {
+ if (sizeof(struct signalfd_siginfo) != event.rawBuffer.size()) {
LogError("Wrong size of signalfd_siginfo struct. Expected: "
<< sizeof(signalfd_siginfo) << " Get: "
<< event.rawBuffer.size());
serviceMap.insert(m_socketDescriptionVector[i].service);
// Time to destroy all services.
- for(auto it = serviceMap.begin(); it != serviceMap.end(); ++it) {
+ for (auto it = serviceMap.begin(); it != serviceMap.end(); ++it) {
LogDebug("delete " << (void*)(*it));
(*it)->Stop();
delete *it;
desc.service->Event(event);
} else if (size == -1) {
int err = errno;
- switch(err) {
+ switch (err) {
case EAGAIN:
case EINTR:
break;
if (result == -1) {
int err = errno;
- switch(err) {
+ switch (err) {
case EAGAIN:
case EINTR:
break;
ssize_t result = write(sock, &desc.rawBuffer[0], size);
if (result == -1) {
int err = errno;
- switch(err) {
+ switch (err) {
case EAGAIN:
case EINTR:
// select will trigger write once again, nothing to do
sd_notify(0, "READY=1");
m_working = true;
- while(m_working) {
+ while (m_working) {
fd_set readSet = m_readSet;
fd_set writeSet = m_writeSet;
// I need to extract timeout from priority_queue.
// Timeout in priority_queue may be deprecated.
// I need to find some actual one.
- while(!m_timeoutQueue.empty()) {
+ while (!m_timeoutQueue.empty()) {
auto &top = m_timeoutQueue.top();
auto &desc = m_socketDescriptionVector[top.sock];
}
if (-1 == ret) {
- switch(errno) {
+ switch (errno) {
case EINTR:
LogDebug("EINTR in select");
break;
}
continue;
}
- for(int i = 0; i<m_maxDesc+1 && ret; ++i) {
+ for (int i = 0; i < m_maxDesc+1 && ret; ++i) {
if (FD_ISSET(i, &readSet)) {
ReadyForRead(i);
--ret;
ThrowMsg(Exception::InitFailed, "Error in sd_listend_fds");
}
- for(fd = SD_LISTEN_FDS_START; fd < SD_LISTEN_FDS_START+n; ++fd) {
+ for (fd = SD_LISTEN_FDS_START; fd < SD_LISTEN_FDS_START+n; ++fd) {
if (0 < sd_is_socket_unix(fd, SOCK_STREAM, 1,
desc.serviceHandlerPath.c_str(), 0))
{
{
int sockfd;
- if(desc.serviceHandlerPath.size() >= sizeof(static_cast<sockaddr_un*>(0)->sun_path) /
+ if (desc.serviceHandlerPath.size() >= sizeof(static_cast<sockaddr_un*>(0)->sun_path) /
sizeof(decltype(desc.serviceHandlerPath)::value_type)) {
LogError("Service handler path too long: " << desc.serviceHandlerPath.size());
ThrowMsg(Exception::InitFailed,
Try {
for (auto iter = serviceVector.begin(); iter != serviceVector.end(); ++iter)
CreateDomainSocket(service, *iter);
- } Catch (Exception::Base) {
+ } Catch(Exception::Base) {
for (int i =0; i < (int)m_socketDescriptionVector.size(); ++i)
{
auto &desc = m_socketDescriptionVector[i];
FD_SET(buffer.connectionID.sock, &m_writeSet);
}
- while(!m_writeDataQueue.empty()) {
+ while (!m_writeDataQueue.empty()) {
data = m_writeDataQueue.front();
m_writeDataQueue.pop();
desc.service = NULL;
desc.interfaceID = -1;
desc.rawBuffer.clear();
- while(!desc.sendMsgDataQueue.empty())
+ while (!desc.sendMsgDataQueue.empty())
desc.sendMsgDataQueue.pop();
if (service)