#include "uv.h"
#include "internal.h"

Classes
struct	uv__fd_info_s

struct	uv__fd_hash_entry_s

struct	uv__fd_hash_entry_group_s

struct	uv__fd_hash_bucket_s

Macros
#define	UV__FD_HASH_SIZE 256

#define	UV__FD_HASH_GROUP_SIZE 16

#define	FIND_COMMON_VARIABLES

#define	FIND_IN_GROUP_PTR(group_size)

#define	FIND_IN_BUCKET_PTR()

Functions
static INLINE void	uv__fd_hash_init (void)

static INLINE int	uv__fd_hash_get (int fd, struct uv__fd_info_s *info)

static INLINE void	uv__fd_hash_add (int fd, struct uv__fd_info_s *info)

static INLINE int	uv__fd_hash_remove (int fd, struct uv__fd_info_s *info)

Variables
static uv_mutex_t	uv__fd_hash_mutex

static struct uv__fd_hash_entry_group_s	uv__fd_hash_entry_initial [UV__FD_HASH_SIZE *UV__FD_HASH_GROUP_SIZE]

static struct uv__fd_hash_bucket_s	uv__fd_hash [UV__FD_HASH_SIZE]

Macro Definition Documentation

◆ FIND_COMMON_VARIABLES

#define FIND_COMMON_VARIABLES

Value:

  unsigned i;                                                                \
  unsigned bucket = fd % ARRAY_SIZE(uv__fd_hash);                            \
  struct uv__fd_hash_entry_s* entry_ptr = NULL;                              \
  struct uv__fd_hash_entry_group_s* group_ptr;                               \
  struct uv__fd_hash_bucket_s* bucket_ptr = &uv__fd_hash[bucket];

Definition at line 92 of file fs-fd-hash-inl.h.

◆ FIND_IN_BUCKET_PTR

#define FIND_IN_BUCKET_PTR ( )

Value:

  do {                                                                       \
    size_t first_group_size = bucket_ptr->size % UV__FD_HASH_GROUP_SIZE;     \
    if (bucket_ptr->size != 0 && first_group_size == 0)                      \
      first_group_size = UV__FD_HASH_GROUP_SIZE;                             \
    group_ptr = bucket_ptr->data;                                            \
    FIND_IN_GROUP_PTR(first_group_size);                                     \
    for (group_ptr = group_ptr->next;                                        \
         group_ptr != NULL && entry_ptr == NULL;                             \
         group_ptr = group_ptr->next)                                        \
      FIND_IN_GROUP_PTR(UV__FD_HASH_GROUP_SIZE);                             \
  } while (0)

Definition at line 109 of file fs-fd-hash-inl.h.

◆ FIND_IN_GROUP_PTR

#define FIND_IN_GROUP_PTR ( group_size )

Value:

  do {                                                                       \
    for (i = 0; i < group_size; ++i) {                                       \
      if (group_ptr->entries[i].fd == fd) {                                  \
        entry_ptr = &group_ptr->entries[i];                                  \
        break;                                                               \
      }                                                                      \
    }                                                                        \
  } while (0)

Definition at line 99 of file fs-fd-hash-inl.h.

◆ UV__FD_HASH_GROUP_SIZE

#define UV__FD_HASH_GROUP_SIZE 16

Definition at line 43 of file fs-fd-hash-inl.h.

◆ UV__FD_HASH_SIZE

#define UV__FD_HASH_SIZE 256

Definition at line 42 of file fs-fd-hash-inl.h.

Function Documentation

◆ uv__fd_hash_add()

static INLINE void uv__fd_hash_add	(	int	fd,
		struct uv__fd_info_s *	info
	)

static

Definition at line 137 of file fs-fd-hash-inl.h.

                                                                        {
   FIND_COMMON_VARIABLES
  
   uv_mutex_lock(&uv__fd_hash_mutex);
  
   FIND_IN_BUCKET_PTR();
  
   if (entry_ptr == NULL) {
     i = bucket_ptr->size % UV__FD_HASH_GROUP_SIZE;
  
     if (bucket_ptr->size != 0 && i == 0) {
       struct uv__fd_hash_entry_group_s* new_group_ptr =
         uv__malloc(sizeof(*new_group_ptr));
       if (new_group_ptr == NULL) {
         uv_fatal_error(ERROR_OUTOFMEMORY, "uv__malloc");
       }
       new_group_ptr->next = bucket_ptr->data;
       bucket_ptr->data = new_group_ptr;
     }
  
     bucket_ptr->size += 1;
     entry_ptr = &bucket_ptr->data->entries[i];
     entry_ptr->fd = fd;
   }
  
   entry_ptr->info = *info;
  
   uv_mutex_unlock(&uv__fd_hash_mutex);
 }

References uv__fd_hash_entry_group_s::entries, fd, uv__fd_hash_entry_s::fd, FIND_COMMON_VARIABLES, FIND_IN_BUCKET_PTR, i, info(), uv__fd_hash_entry_group_s::next, NULL, UV__FD_HASH_GROUP_SIZE, uv__fd_hash_mutex, uv__malloc(), uv_fatal_error(), uv_mutex_lock(), and uv_mutex_unlock().

Referenced by fs__ftruncate(), fs__open(), fs__read_filemap(), and fs__write_filemap().

◆ uv__fd_hash_get()

static INLINE int uv__fd_hash_get	(	int	fd,
		struct uv__fd_info_s *	info
	)

static

Definition at line 122 of file fs-fd-hash-inl.h.

                                                                       {
   FIND_COMMON_VARIABLES
  
   uv_mutex_lock(&uv__fd_hash_mutex);
  
   FIND_IN_BUCKET_PTR();
  
   if (entry_ptr != NULL) {
     *info = entry_ptr->info;
   }
  
   uv_mutex_unlock(&uv__fd_hash_mutex);
   return entry_ptr != NULL;
 }

References FIND_COMMON_VARIABLES, FIND_IN_BUCKET_PTR, info(), NULL, uv__fd_hash_mutex, uv_mutex_lock(), and uv_mutex_unlock().

Referenced by fs__ftruncate(), fs__read(), and fs__write().

◆ uv__fd_hash_init()

static INLINE void uv__fd_hash_init ( void )

static

Definition at line 76 of file fs-fd-hash-inl.h.

                                           {
   size_t i;
   int err;
  
   err = uv_mutex_init(&uv__fd_hash_mutex);
   if (err) {
     uv_fatal_error(err, "uv_mutex_init");
   }
  
   for (i = 0; i < ARRAY_SIZE(uv__fd_hash); ++i) {
     uv__fd_hash[i].size = 0;
     uv__fd_hash[i].data =
         uv__fd_hash_entry_initial + i * UV__FD_HASH_GROUP_SIZE;
   }
 }

References ARRAY_SIZE, uv__fd_hash_bucket_s::data, err, i, uv__fd_hash_bucket_s::size, uv__fd_hash, uv__fd_hash_entry_initial, UV__FD_HASH_GROUP_SIZE, uv__fd_hash_mutex, uv_fatal_error(), and uv_mutex_init().

Referenced by uv_fs_init().

◆ uv__fd_hash_remove()

static INLINE int uv__fd_hash_remove	(	int	fd,
		struct uv__fd_info_s *	info
	)

static

Definition at line 167 of file fs-fd-hash-inl.h.

                                                                          {
   FIND_COMMON_VARIABLES
  
   uv_mutex_lock(&uv__fd_hash_mutex);
  
   FIND_IN_BUCKET_PTR();
  
   if (entry_ptr != NULL) {
     *info = entry_ptr->info;
  
     bucket_ptr->size -= 1;
  
     i = bucket_ptr->size % UV__FD_HASH_GROUP_SIZE;
     if (entry_ptr != &bucket_ptr->data->entries[i]) {
       *entry_ptr = bucket_ptr->data->entries[i];
     }
  
     if (bucket_ptr->size != 0 &&
         bucket_ptr->size % UV__FD_HASH_GROUP_SIZE == 0) {
       struct uv__fd_hash_entry_group_s* old_group_ptr = bucket_ptr->data;
       bucket_ptr->data = old_group_ptr->next;
       uv__free(old_group_ptr);
     }
   }
  
   uv_mutex_unlock(&uv__fd_hash_mutex);
   return entry_ptr != NULL;
 }