Applied nxt_pointer_to() and nxt_value_at() where possible.

src/nginext/nxt_go_array.c

@@ -57,7 +57,7 @@ nxt_go_array_add(nxt_array_t *array)
         array->nalloc = new_alloc;
     }
 
-    p = (char *) array->elts + array->size * array->nelts;
+    p = nxt_pointer_to(array->elts, array->size * array->nelts);
     array->nelts++;
 
     return p;

src/nginext/nxt_go_array.h

@@ -30,7 +30,7 @@ nxt_go_array_zero_add(nxt_array_t *array)
 
 #define                                                                       \
 nxt_go_array_at(array, n)                                                     \
-    ((void *) ((char *) (array)->elts + (array)->size * (n)))
+    nxt_pointer_to((array)->elts, (array)->size * (n))
 
 
 #endif /* _NXT_GO_ARRAY_H_INCLUDED_ */

src/nginext/nxt_go_run_ctx.c

@@ -96,8 +96,7 @@ nxt_go_ctx_init_msg(nxt_go_msg_t *msg, nxt_port_msg_t *port_msg,
 
     if (nxt_fast_path(port_msg->mmap != 0)) {
         msg->mmap_msg = (nxt_port_mmap_msg_t *) (port_msg + 1);
-        msg->end = (nxt_port_mmap_msg_t *) ( (char *) msg->mmap_msg +
+        msg->end = nxt_pointer_to(msg->mmap_msg, payload_size);
-                                              payload_size );
 
         mmap_msg = msg->mmap_msg;
         while(mmap_msg < msg->end) {

src/nxt_array.c

@@ -18,7 +18,7 @@ nxt_array_create(nxt_mp_t *mp, nxt_uint_t n, size_t size)
         return NULL;
     }
 
-    array->elts = (char *) array + sizeof(nxt_array_t);
+    array->elts = nxt_pointer_to(array, sizeof(nxt_array_t));
     array->nelts = 0;
     array->size = size;
     array->nalloc = n;
@@ -61,7 +61,7 @@ nxt_array_add(nxt_array_t *array)
         array->nalloc = new_alloc;
     }
 
-    p = (char *) array->elts + array->size * array->nelts;
+    p = nxt_pointer_to(array->elts, array->size * array->nelts);
     array->nelts++;
 
     return p;

src/nxt_array.h

@@ -27,7 +27,7 @@ NXT_EXPORT void nxt_array_remove(nxt_array_t *array, void *elt);
 
 #define                                                                       \
 nxt_array_last(array)                                                         \
-    ((void *) ((char *) (array)->elts + (array)->size * ((array)->nelts - 1)))
+    nxt_pointer_to((array)->elts, (array)->size * ((array)->nelts - 1))
 
 
 #define                                                                       \
@@ -44,7 +44,7 @@ nxt_inline void *
 nxt_array_remove_last(nxt_array_t *array)
 {
     array->nelts--;
-    return (char *) array->elts + array->size * array->nelts;
+    return nxt_pointer_to(array->elts, array->size * array->nelts);
 }
 
 

src/nxt_buf.c

@@ -18,7 +18,7 @@ nxt_buf_mem_init(nxt_buf_t *b, void *start, size_t size)
     b->mem.start = start;
     b->mem.pos = start;
     b->mem.free = start;
-    b->mem.end = (u_char *) start + size;
+    b->mem.end = nxt_pointer_to(start, size);
 }
 
 

src/nxt_conn_proxy.c

@@ -782,14 +782,7 @@ nxt_conn_proxy_write_timeout(nxt_task_t *task, void *obj, void *data)
 static nxt_msec_t
 nxt_conn_proxy_timeout_value(nxt_conn_t *c, uintptr_t data)
 {
-    nxt_msec_t        *timer;
+    return nxt_value_at(nxt_msec_t, c->socket.data, data);
-    nxt_conn_proxy_t  *p;
-
-    p = c->socket.data;
-
-    timer = (nxt_msec_t *) ((char *) p + data);
-
-    return *timer;
 }
 
 

src/nxt_errno.c

@@ -107,7 +107,7 @@ nxt_strerror_start(void)
         return NXT_ERROR;
     }
 
-    p = (u_char *) nxt_sys_errlist + n;
+    p = nxt_pointer_to(nxt_sys_errlist, n);
 
     for (err = 0; err < nxt_sys_nerr; err++) {
         msg = strerror((int) err);

src/nxt_http_parse.c

@@ -746,7 +746,7 @@ nxt_http_fields_hash_create(nxt_http_fields_hash_entry_t *entries,
                 break;
             }
 
-            elt = (nxt_http_fields_hash_elt_t *) ((u_char *) elt + size);
+            elt = nxt_pointer_to(elt, size);
         }
     }
 

src/nxt_list.h

@@ -43,7 +43,7 @@ nxt_list_part(list)                                                           \
 
 #define                                                                       \
 nxt_list_data(part)                                                           \
-    ((char *) (part) + sizeof(nxt_list_part_t))
+    nxt_pointer_to(part, sizeof(nxt_list_part_t))
 
 
 #define                                                                       \

src/nxt_mem_zone.c

@@ -764,7 +764,7 @@ nxt_mem_zone_find_free_block(nxt_mem_zone_t *zone, nxt_rbtree_node_t *node,
 
         } else {  /* pages < block->size */
             aligned += pages << zone->page_size_shift;
-            end = (u_char *) block + (block->size << zone->page_size_shift);
+            end = nxt_pointer_to(block, block->size << zone->page_size_shift);
 
             if (aligned <= end) {
                 return block;

src/nxt_sockaddr.c

@@ -189,7 +189,7 @@ nxt_sockaddr_text(nxt_sockaddr_t *sa)
     u_char    *p, *start, *end, *octet;
     uint32_t  port;
 
-    end = (u_char *) sa + sa->sockaddr_size;
+    end = nxt_pointer_to(sa, sa->sockaddr_size);
 
     switch (sa->u.sockaddr.sa_family) {
 
@@ -199,7 +199,7 @@ nxt_sockaddr_text(nxt_sockaddr_t *sa)
         sa->start = offset;
         sa->address_start = offset;
 
-        start = (u_char *) sa + offset;
+        start = nxt_pointer_to(sa, offset);
         octet = (u_char *) &sa->u.sockaddr_in.sin_addr;
 
         p = nxt_sprintf(start, end, "%ud.%ud.%ud.%ud",
@@ -220,7 +220,7 @@ nxt_sockaddr_text(nxt_sockaddr_t *sa)
         sa->start = offset;
         sa->address_start = offset;
 
-        start = (u_char *) sa + offset;
+        start = nxt_pointer_to(sa, offset);
         p = start;
 
         *p++ = '[';
@@ -247,7 +247,7 @@ nxt_sockaddr_text(nxt_sockaddr_t *sa)
         sa->start = offset;
         sa->address_start = offset;
 
-        start = (u_char *) sa + offset;
+        start = nxt_pointer_to(sa, offset);
         p = start;
 
 #if (NXT_LINUX)

src/nxt_sockaddr.h

@@ -102,9 +102,9 @@ NXT_EXPORT nxt_int_t nxt_inet6_addr(struct in6_addr *in6_addr, u_char *buf,
     (sizeof("[ffff:ffff:ffff:ffff:ffff:ffff:ffff:ffff]:65535") - 1)
 
 
-#define nxt_sockaddr_start(sa)    ((u_char *) (sa) + (sa)->start)
+#define nxt_sockaddr_start(sa)    nxt_pointer_to(sa, (sa)->start)
-#define nxt_sockaddr_address(sa)  ((u_char *) (sa) + (sa)->address_start)
+#define nxt_sockaddr_address(sa)  nxt_pointer_to(sa, (sa)->address_start)
-#define nxt_sockaddr_port(sa)     ((u_char *) (sa) + (sa)->port_start)
+#define nxt_sockaddr_port(sa)     nxt_pointer_to(sa, (sa)->port_start)
 #define nxt_sockaddr_length(sa)   ((sa)->length - (sa)->port_start)
 
 

src/nxt_string.c

@@ -17,7 +17,7 @@ nxt_str_alloc(nxt_mp_t *mp, size_t length)
 
     if (nxt_fast_path(s != NULL)) {
         s->length = length;
-        s->start = (u_char *) s + sizeof(nxt_str_t);
+        s->start = nxt_pointer_to(s, sizeof(nxt_str_t));
     }
 
     return s;

src/nxt_vector.c

@@ -16,7 +16,7 @@ nxt_vector_create(nxt_uint_t items, size_t item_size,
     vector = proto->alloc(pool, sizeof(nxt_vector_t) + items * item_size);
 
     if (nxt_fast_path(vector != NULL)) {
-        vector->start = (char *) vector + sizeof(nxt_vector_t);
+        vector->start = nxt_pointer_to(vector, sizeof(nxt_vector_t));
         vector->items = 0;
         vector->item_size = item_size;
         vector->avalaible = items;
@@ -112,7 +112,7 @@ nxt_vector_add(nxt_vector_t *vector, const nxt_mem_proto_t *proto, void *pool)
         }
     }
 
-    item = (char *) vector->start + vector->item_size * vector->items;
+    item = nxt_pointer_to(vector->start, vector->item_size * vector->items);
 
     vector->items++;
 
@@ -143,11 +143,11 @@ nxt_vector_remove(nxt_vector_t *vector, void *item)
     uint32_t  item_size;
 
     item_size = vector->item_size;
-    end = (u_char *) vector->start + item_size * vector->items;
+    end = nxt_pointer_to(vector->start, item_size * vector->items);
     last = end - item_size;
 
     if (item != last) {
-        next = (u_char *) item + item_size;
+        next = nxt_pointer_to(item, item_size);
 
         nxt_memmove(item, next, end - next);
     }

src/nxt_vector.h

@@ -43,9 +43,8 @@ NXT_EXPORT void nxt_vector_remove(nxt_vector_t *vector, void *item);
 
 #define                                                                       \
 nxt_vector_last(vector)                                                       \
-    ((void *)                                                                 \
+    nxt_pointer_to((vector)->start,                                           \
-        ((char *) (vector)->start                                             \
+                   (vector)->item_size * ((vector)->items - 1))
-                      + (vector)->item_size * ((vector)->items - 1)))
 
 
 #define                                                                       \
@@ -62,7 +61,7 @@ nxt_inline void *
 nxt_vector_remove_last(nxt_vector_t *vector)
 {
     vector->items--;
-    return (char *) vector->start + vector->item_size * vector->items;
+    return nxt_pointer_to(vector->start, vector->item_size * vector->items);
 }