return nWritten;
}
-static inline void socketAcceptEnableForEpoll(CO_epoll_gtw_t *epGtw) {
+static inline void
- socetAcceptEnableForEpoll(CO_epoll_gtw_t* epGtw) {
++socketAcceptEnableForEpoll(CO_epoll_gtw_t* epGtw) {
struct epoll_event ev = {0};
int ret;
}
if (fail) {
- socetAcceptEnableForEpoll(epGtw);
+ socketAcceptEnableForEpoll(epGtw);
}
ep->epoll_new = false;
- }
- else if ((ep->ev.events & EPOLLIN) != 0
- && ep->ev.data.fd == epGtw->gtwa_fd
- ) {
+ } else if ((ep->ev.events & EPOLLIN) != 0 && ep->ev.data.fd == epGtw->gtwa_fd) {
char buf[CO_CONFIG_GTWA_COMM_BUF_SIZE];
- size_t space = co->nodeIdUnconfigured ?
- CO_CONFIG_GTWA_COMM_BUF_SIZE :
- CO_GTWA_write_getSpace(co->gtwa);
+ size_t space = co->nodeIdUnconfigured ? CO_CONFIG_GTWA_COMM_BUF_SIZE : CO_GTWA_write_getSpace(co->gtwa);
ssize_t s = read(epGtw->gtwa_fd, buf, space);
log_printf(LOG_CRIT, DBG_ERRNO, "close(gtwa_fd)");
}
epGtw->gtwa_fd = -1;
- socetAcceptEnableForEpoll(epGtw);
+ socketAcceptEnableForEpoll(epGtw);
- }
- else {
+ } else {
CO_GTWA_write(co->gtwa, buf, s);
}
}
log_printf(LOG_CRIT, DBG_ERRNO, "close(gtwa_fd), tmo");
}
epGtw->gtwa_fd = -1;
- socetAcceptEnableForEpoll(epGtw);
+ socketAcceptEnableForEpoll(epGtw);
- }
- else {
+ } else {
epGtw->socketTimeoutTmr_us += ep->timeDifference_us;
}
}