/Conn_engine_poll.c (264b9b69fcb9dbda1c562316594208c753e4bacd) (2589 bytes) (mode 100644) (type blob)
#include <Conn_config.h>
#ifdef POLL_FOUND
#include <Conn_engine_poll.h>
/*
* Variables
*/
static unsigned long Conn_poll_allocated_slots = 0;
static struct pollfd *Conn_poll_pfds = NULL;
/*
* Functions
*/
/*
* Init the engine
*/
int Conn_poll_init(void)
{
return 0;
}
int Conn_poll_shutdown(void)
{
free(Conn_poll_pfds);
return 0;
}
/*
* Grow the number of slots needed for poll
*/
int Conn_poll_grow(unsigned int alloc)
{
struct pollfd *p, *set;
unsigned int diff, mem;
Log(10, "%s: Trying to grow pollfds from %d to %d.\n",
__FUNCTION__,
Conn_poll_allocated_slots, alloc);
if (alloc <= Conn_poll_allocated_slots)
return 0;
diff = alloc - Conn_poll_allocated_slots;
mem = alloc * sizeof(struct pollfd);
p = (struct pollfd *) realloc(Conn_poll_pfds, mem);
if (p == NULL) {
snprintf(Conn_error, sizeof(Conn_error),
"Cannot alloc %u bytes for pollfds.", mem);
return -1;
}
set = p + Conn_poll_allocated_slots;
memset(set, 0, diff * sizeof(struct pollfd));
Conn_poll_pfds = p;
return 0;
}
/*
* Add a target to the list
*/
int Conn_poll_add_obj(struct Conn *C)
{
Conn_poll_pfds[C->slot].fd = C->fd;
Conn_poll_pfds[C->slot].events = C->events;
return 0;
}
/*
* Remove a target from the list
*/
int Conn_poll_del_obj(struct Conn *C)
{
Conn_poll_pfds[C->slot].fd = -1;
Conn_poll_pfds[C->slot].events = 0;
return 0;
}
/*
* Change event mask
*/
int Conn_poll_chg_obj(struct Conn *C)
{
Conn_poll_pfds[C->slot].events = C->events;
return 0;
}
/*
* Calls a callback for fds with activity
* Returns: -1 on error, 0 nothing to do, n (>0) if some work was done
* timeout is in 1/1000 seconds increments.
*/
int Conn_poll_poll(const int timeout2, void (*cb)(struct Conn *C,
const int revents))
{
int i, events;
again:
events = poll(&Conn_poll_pfds[0], Conn_no, timeout2);
if ((events == -1) && (errno == EINTR))
goto again;
if (events < 0) {
snprintf(Conn_error, sizeof(Conn_error),
"%s: Conn_no=%d [%s]",
__FUNCTION__, Conn_no,
strerror(errno));
return -1;
}
if (events == 0)
return 0;
gettimeofday(&Conn_now, NULL);
/* We do revers scan because of moving Conn objects */
Log(11, "Processing %d event(s)...\n",
events);
i = Conn_no - 1;
do {
if (Conn_poll_pfds[i].revents & POLLNVAL) {
Log(0, "BUG NVAL!\n");
exit(1);
}
cb(&Conns[i], Conn_poll_pfds[i].revents);
i--;
} while (i >= 0);
return events;
}
/*
* Move a slot over an other.
*/
void Conn_poll_move_slot(const unsigned int dst, const unsigned int src)
{
Conn_poll_pfds[dst] = Conn_poll_pfds[src];
}
#endif
Mode |
Type |
Size |
Ref |
File |
100644 |
blob |
70 |
9964a59b5d89f394cc4250ed6d6ce67a5f0cd196 |
.gitignore |
100644 |
blob |
1945 |
fecf0e7a7e8580485101a179685aedc7e00affbb |
Changelog.pre109 |
100644 |
blob |
25504 |
b7e33ed4916a779af85b159240f2db042dcf5749 |
Conn.c |
100644 |
blob |
820 |
77f3d32a7beb5f3d5e00daa043634309d144d016 |
Conn.h |
100644 |
blob |
726 |
64b1bad93a84f87c3e93fc24ac5341db691ea578 |
Conn.spec.in |
100644 |
blob |
66 |
68138d781ca754b15e14c687da91ee261b2c41f3 |
Conn_config.h.in |
100644 |
blob |
19609 |
ff4c1b30c147990867f91566c9ea7ccf5749a0c0 |
Conn_engine_core.c |
100644 |
blob |
8392 |
754f621be0df3227c91d89956acd27b4cb4def23 |
Conn_engine_core.h |
100644 |
blob |
3601 |
bd8a8669bbfbafe3af4b1d3291041ed64577b73a |
Conn_engine_epoll.c |
100644 |
blob |
602 |
b648aaf1ad3c79ac5b6f425989aa5fee9a0d9f30 |
Conn_engine_epoll.h |
100644 |
blob |
2589 |
264b9b69fcb9dbda1c562316594208c753e4bacd |
Conn_engine_poll.c |
100644 |
blob |
589 |
f897f7d70dd5b17256cb51dce4637f0a8cf6291d |
Conn_engine_poll.h |
100644 |
blob |
30 |
d987fa5df957830331139935d517009e2911b0cf |
INSTALL |
100644 |
blob |
25275 |
92b8903ff3fea7f49ef5c041b67a087bca21c5ec |
LICENSE |
100644 |
blob |
1255 |
976d5d795aae2df1b265bb7bb19f9c1761db98e3 |
Makefile.in |
100644 |
blob |
192 |
5b11bdfb23857d8588845465aef993b320596b44 |
README |
100644 |
blob |
1612 |
705e412028cffeccaec7303e23fa81e9e78ae6e5 |
TODO |
100755 |
blob |
23 |
d33bb6c4ecdce1390ce1db3c79ea3b93e22ea755 |
configure |
040000 |
tree |
- |
d4c9c4a69c5cfa2a84316967185f1661b6817779 |
docs |
100755 |
blob |
10344 |
8acd6afdceefbb056b57e9d09a9943857800df8e |
duilder |
100644 |
blob |
276 |
348b1930873b2a9aa3498c76af57a28cd62e79fa |
duilder.conf |
040000 |
tree |
- |
267133ee1eb21f456dd3840596a7941f761bb471 |
examples |
Hints:
Before first commit, do not forget to setup your git environment:
git config --global user.name "your_name_here"
git config --global user.email "your@email_here"
Clone this repository using HTTP(S):
git clone https://rocketgit.com/user/catalinux/Conn
Clone this repository using ssh (do not forget to upload a key first):
git clone ssh://rocketgit@ssh.rocketgit.com/user/catalinux/Conn
Clone this repository using git:
git clone git://git.rocketgit.com/user/catalinux/Conn
You are allowed to anonymously push to this repository.
This means that your pushed commits will automatically be transformed into a
merge request:
... clone the repository ...
... make some changes and some commits ...
git push origin main