knet_h->send_to_links_buf = malloc(KNET_DATABUFSIZE);
if (!knet_h->send_to_links_buf) {
savederrno = errno;
- log_err(knet_h, KNET_SUB_HANDLE, "Unable to allocate memory net_fd to link buffer: %s",
+ log_err(knet_h, KNET_SUB_HANDLE, "Unable to allocate memory datafd to link buffer: %s",
strerror(savederrno));
goto exit_fail;
}
knet_h->recv_from_links_buf = malloc(KNET_DATABUFSIZE);
if (!knet_h->recv_from_links_buf) {
savederrno = errno;
- log_err(knet_h, KNET_SUB_HANDLE, "Unable to allocate memory for link to net_fd buffer: %s",
+ log_err(knet_h, KNET_SUB_HANDLE, "Unable to allocate memory for link to datafd buffer: %s",
strerror(savederrno));
goto exit_fail;
}
knet_h->send_to_links_buf_crypt = malloc(KNET_DATABUFSIZE_CRYPT);
if (!knet_h->send_to_links_buf_crypt) {
savederrno = errno;
- log_err(knet_h, KNET_SUB_HANDLE, "Unable to allocate memory for crypto net_fd to link buffer: %s",
+ log_err(knet_h, KNET_SUB_HANDLE, "Unable to allocate memory for crypto datafd to link buffer: %s",
strerror(savederrno));
goto exit_fail;
}
knet_h->recv_from_links_buf_crypt = malloc(KNET_DATABUFSIZE_CRYPT);
if (!knet_h->recv_from_links_buf_crypt) {
savederrno = errno;
- log_err(knet_h, KNET_SUB_CRYPTO, "Unable to allocate memory for crypto link to net_fd buffer: %s",
+ log_err(knet_h, KNET_SUB_CRYPTO, "Unable to allocate memory for crypto link to datafd buffer: %s",
strerror(savederrno));
goto exit_fail;
}
knet_h->send_to_links_epollfd = epoll_create(KNET_EPOLL_MAX_EVENTS);
if (knet_h->send_to_links_epollfd < 0) {
savederrno = errno;
- log_err(knet_h, KNET_SUB_HANDLE, "Unable to create epoll net_fd to link fd: %s",
+ log_err(knet_h, KNET_SUB_HANDLE, "Unable to create epoll datafd to link fd: %s",
strerror(savederrno));
goto exit_fail;
}
knet_h->recv_from_links_epollfd = epoll_create(KNET_EPOLL_MAX_EVENTS);
if (knet_h->recv_from_links_epollfd < 0) {
savederrno = errno;
- log_err(knet_h, KNET_SUB_HANDLE, "Unable to create epoll link to net_fd fd: %s",
+ log_err(knet_h, KNET_SUB_HANDLE, "Unable to create epoll link to datafd fd: %s",
strerror(savederrno));
goto exit_fail;
}
if (_fdset_cloexec(knet_h->send_to_links_epollfd)) {
savederrno = errno;
- log_err(knet_h, KNET_SUB_HANDLE, "Unable to set CLOEXEC on net_fd to link epoll fd: %s",
+ log_err(knet_h, KNET_SUB_HANDLE, "Unable to set CLOEXEC on datafd to link epoll fd: %s",
strerror(savederrno));
goto exit_fail;
}
if (_fdset_cloexec(knet_h->recv_from_links_epollfd)) {
savederrno = errno;
- log_err(knet_h, KNET_SUB_HANDLE, "Unable to set CLOEXEC on link to net_fd epoll fd: %s",
+ log_err(knet_h, KNET_SUB_HANDLE, "Unable to set CLOEXEC on link to datafd epoll fd: %s",
strerror(savederrno));
goto exit_fail;
}
if (epoll_ctl(knet_h->send_to_links_epollfd,
EPOLL_CTL_ADD, knet_h->sockfd, &ev)) {
savederrno = errno;
- log_err(knet_h, KNET_SUB_HANDLE, "Unable to add net_fd to link fd to epoll pool: %s",
+ log_err(knet_h, KNET_SUB_HANDLE, "Unable to add datafd to link fd to epoll pool: %s",
strerror(savederrno));
goto exit_fail;
}
savederrno = pthread_create(&knet_h->send_to_links_thread, 0,
_handle_send_to_links_thread, (void *) knet_h);
if (savederrno) {
- log_err(knet_h, KNET_SUB_HANDLE, "Unable to start net_fd to link thread: %s",
+ log_err(knet_h, KNET_SUB_HANDLE, "Unable to start datafd to link thread: %s",
strerror(savederrno));
goto exit_fail;
}
savederrno = pthread_create(&knet_h->recv_from_links_thread, 0,
_handle_recv_from_links_thread, (void *) knet_h);
if (savederrno) {
- log_err(knet_h, KNET_SUB_HANDLE, "Unable to start link to net_fd thread: %s",
+ log_err(knet_h, KNET_SUB_HANDLE, "Unable to start link to datafd thread: %s",
strerror(savederrno));
goto exit_fail;
}
}
knet_handle_t knet_handle_new(uint16_t host_id,
- int net_fd,
+ int datafd,
int log_fd,
uint8_t default_log_level)
{
* validate incoming request
*/
- if (net_fd <= 0) {
+ if (datafd <= 0) {
errno = EINVAL;
return NULL;
}
*/
knet_h->host_id = host_id;
- knet_h->sockfd = net_fd;
+ knet_h->sockfd = datafd;
knet_h->logfd = log_fd;
if (knet_h->logfd > 0) {
memset(&knet_h->log_levels, default_log_level, KNET_MAX_SUBSYSTEMS);
#define KNET_MAX_LINK 8
/*
- * maximum packet size that should be written to net_fd
+ * maximum packet size that should be written to datafd
* see knet_handle_new for details
*/
* It is user responsibility to check that the value
* is unique, or bad might happen.
*
- * net_fd - read/write file descriptor (must be > 0).
+ * datafd - read/write file descriptor (must be > 0).
* knet will read data here to send to the other hosts
* and will write data received from the network.
* Each data packet can be of max size KNET_MAX_PACKET_SIZE!
*/
knet_handle_t knet_handle_new(uint16_t host_id,
- int net_fd,
+ int datafd,
int log_fd,
uint8_t default_log_level);
*
* dst_host_filter_fn -
* is a callback function that is invoked every time
- * a packet hits net_fd (see knet_handle_new).
+ * a packet hits datafd (see knet_handle_new).
* the function allows users to tell libknet where the
* packet has to be delivered.
*