coffee/wepoll
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

poll-group: rename _POLL_GROUP_MAX_SIZE to _POLL_GROUP_MAX_GROUP_SIZE

Browse Source
This commit is contained in:
Bert Belder 2018-05-17 00:29:44 -07:00
parent 1e5def7413
commit f00c18e323
No known key found for this signature in database
GPG Key ID: 7A77887B2E2ED461
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/poll-group.c
View File

@ -8,7 +8,7 @@
#include "util.h" #include "util.h"
#include "win.h" #include "win.h"
static const size_t _POLL_GROUP_MAX_SIZE = 32; static const size_t _POLL_GROUP_MAX_GROUP_SIZE = 32;
typedef struct poll_group { typedef struct poll_group {
ep_port_t* port_info; ep_port_t* port_info;
@ -59,12 +59,13 @@ poll_group_t* poll_group_acquire(ep_port_t* port_info) {
? container_of(queue_last(queue), poll_group_t, queue_node) ? container_of(queue_last(queue), poll_group_t, queue_node)
: NULL; : NULL;
if (poll_group == NULL || poll_group->group_size >= _POLL_GROUP_MAX_SIZE) if (poll_group == NULL ||
poll_group->group_size >= _POLL_GROUP_MAX_GROUP_SIZE)
poll_group = _poll_group_new(port_info); poll_group = _poll_group_new(port_info);
if (poll_group == NULL) if (poll_group == NULL)
return NULL; return NULL;
if (++poll_group->group_size == _POLL_GROUP_MAX_SIZE) if (++poll_group->group_size == _POLL_GROUP_MAX_GROUP_SIZE)
queue_move_first(&port_info->poll_group_queue, &poll_group->queue_node); queue_move_first(&port_info->poll_group_queue, &poll_group->queue_node);
return poll_group; return poll_group;
@ -74,7 +75,7 @@ void poll_group_release(poll_group_t* poll_group) {
ep_port_t* port_info = poll_group->port_info; ep_port_t* port_info = poll_group->port_info;
poll_group->group_size--; poll_group->group_size--;
assert(poll_group->group_size < _POLL_GROUP_MAX_SIZE); assert(poll_group->group_size < _POLL_GROUP_MAX_GROUP_SIZE);
queue_move_last(&port_info->poll_group_queue, &poll_group->queue_node); queue_move_last(&port_info->poll_group_queue, &poll_group->queue_node);