One Level Up Top Level

src/core/ngx_data.c - nginx-1.31.4 nginx/ @ 8d9666701

Global variables defined

Functions defined

Source code


  2. /*
  3. * Copyright (C) Nginx, Inc.
  4. */


  7. #include <ngx_config.h>
  8. #include <ngx_core.h>


  11. ‌static size_t  ngx_data_sizes[] = {
  12.     sizeof(ngx_data_obj_t),            /* NGX_DATA_OBJECT_TYPE */
  13.     sizeof(ngx_data_obj_t),            /* NGX_DATA_LIST_TYPE */
  14.     sizeof(ngx_str_t),                 /* NGX_DATA_STRING_TYPE */
  15.     sizeof(int64_t),                   /* NGX_DATA_INTEGER_TYPE */
  16.     sizeof(ngx_uint_t),                /* NGX_DATA_BOOLEAN_TYPE */
  17.     0,                                 /* NGX_DATA_NULL_TYPE */
  18. };


  21. ngx_data_item_t *
  22. ‌ngx_data_new_item(ngx_pool_t *pool, ngx_uint_t type)
  23. {
  24.     ngx_data_item_t  *item;

  26.     item = ngx_pcalloc(pool, offsetof(ngx_data_item_t, data)
  27.                              + ngx_data_sizes[type]);
  28.     if (item == NULL) {
  29.         return NULL;
  30.     }

  32.     item->type = type;

  34.     return item;
  35. }


  38. void
  39. ‌ngx_data_add_item(ngx_data_item_t *obj, ngx_str_t *name, ngx_data_item_t *item)
  40. {
  41.     ngx_data_obj_t  *object;

  43.     if (obj->type != NGX_DATA_OBJECT_TYPE && obj->type != NGX_DATA_LIST_TYPE) {
  44.         return;
  45.     }

  47.     object = &obj->data.object;

  49.     if (name) {
  50.         item->name = *name;
  51.     }

  53.     if (object->next == NULL) {
  54.         object->next = &object->item;
  55.     }

  57.     *object->next = item;
  58.     object->next = &item->next;
  59. }


  62. ngx_data_item_t *
  63. ‌ngx_data_obj_handler(uintptr_t data, ngx_pool_t *pool, void *ctx)
  64. {
  65.     ngx_data_item_t  *obj, *item;
  66.     ngx_data_decl_t  *decl;

  68.     obj = ngx_data_new_object(pool);
  69.     if (obj == NULL) {
  70.         return NULL;
  71.     }

  73.     decl = (ngx_data_decl_t *) data;

  75.     while (decl->name.len) {

  77.         item = decl->handler(decl->data, pool, ctx);
  78.         if (item == NULL) {
  79.             return NULL;
  80.         }

  82.         if (item != NGX_DATA_DECLINE) {
  83.             ngx_data_add_item(obj, &decl->name, item);
  84.         }

  86.         decl++;
  87.     }

  89.     return obj;
  90. }


  93. ngx_data_item_t *
  94. ‌ngx_data_obj_fields_handler(uintptr_t data, ngx_pool_t *pool, void *ctx,
  95.     ngx_array_t *fields)
  96. {
  97.     ngx_str_t        *value;
  98.     ngx_uint_t        i;
  99.     ngx_data_item_t  *obj, *item;
  100.     ngx_data_decl_t  *decl;

  102.     obj = ngx_data_new_object(pool);
  103.     if (obj == NULL) {
  104.         return NULL;
  105.     }

  107.     decl = (ngx_data_decl_t *) data;

  109.     while (decl->name.len) {

  111.         if (fields) {
  112.             value = fields->elts;

  114.             for (i = 0; i < fields->nelts; i++) {

  116.                 if (decl->name.len == value[i].len
  117.                     && ngx_strncmp(decl->name.data, value[i].data,
  118.                                    value[i].len)
  119.                     == 0)
  120.                 {
  121.                     goto found;
  122.                 }
  123.             }

  125.             decl++;
  126.             continue;
  127.         }

  129. found:

  131.         item = decl->handler(decl->data, pool, ctx);
  132.         if (item == NULL) {
  133.             return NULL;
  134.         }

  136.         if (item != NGX_DATA_DECLINE) {
  137.             ngx_data_add_item(obj, &decl->name, item);
  138.         }

  140.         decl++;
  141.     }

  143.     return obj;
  144. }


  147. ngx_data_item_t *
  148. ‌ngx_data_number_handler(uintptr_t data, ngx_pool_t *pool, void *ctx)
  149. {
  150.     ngx_data_item_t  *item;

  152.     item = ngx_data_new_integer(pool);
  153.     if (item == NULL) {
  154.         return NULL;
  155.     }

  157.     item->data.integer = data;

  159.     return item;
  160. }


  163. ngx_data_item_t *
  164. ‌ngx_data_string_handler(uintptr_t data, ngx_pool_t *pool, void *ctx)
  165. {
  166.     ngx_str_t        *value, *src;
  167.     ngx_data_item_t  *item;

  169.     item = ngx_data_new_string(pool);
  170.     if (item == NULL) {
  171.         return NULL;
  172.     }

  174.     value = &item->data.string;

  176.     src = (ngx_str_t *) data;

  178.     value->len = src->len;

  180.     value->data = ngx_pstrdup(pool, src);
  181.     if (value->data == NULL) {
  182.         return NULL;
  183.     }

  185.     return item;
  186. }


  189. ngx_data_item_t *
  190. ‌ngx_data_boolean_handler(uintptr_t data, ngx_pool_t *pool, void *ctx)
  191. {
  192.     ngx_data_item_t  *item;

  194.     item = ngx_data_new_boolean(pool);
  195.     if (item == NULL) {
  196.         return NULL;
  197.     }

  199.     item->data.boolean = data;

  201.     return item;
  202. }


  205. ngx_data_item_t *
  206. ‌ngx_data_time_handler(uintptr_t data, ngx_pool_t *pool, void *ctx)
  207. {
  208.     u_char      *p;
  209.     ngx_tm_t     tm;
  210.     ngx_str_t    src;
  211.     ngx_time_t  *tp;
  212.     u_char       iso8601[sizeof("1974-01-19T13:00:00.000Z") - 1];

  214.     tp = (ngx_time_t *) data;

  216.     ngx_gmtime(tp->sec, &tm);

  218.     p = ngx_sprintf(iso8601, "%4d-%02d-%02dT%02d:%02d:%02d",
  219.                     tm.ngx_tm_year, tm.ngx_tm_mon, tm.ngx_tm_mday,
  220.                     tm.ngx_tm_hour, tm.ngx_tm_min, tm.ngx_tm_sec);

  222.     if (tp->msec) {
  223.         p = ngx_sprintf(p, ".%03ui", tp->msec);
  224.     }

  226.     *p++ = 'Z';

  228.     src.data = iso8601;
  229.     src.len = p - iso8601;

  231.     return ngx_data_string_handler((uintptr_t) &src, pool, NULL);
  232. }


  235. ngx_data_item_t *
  236. ‌ngx_data_struct_int64_handler(uintptr_t data, ngx_pool_t *pool, void *ctx)
  237. {
  238.     ngx_data_item_t  *item;

  240.     item = ngx_data_new_integer(pool);
  241.     if (item == NULL) {
  242.         return NULL;
  243.     }

  245.     item->data.integer = *(int64_t *) ((u_char *) ctx + data);

  247.     return item;
  248. }


  251. ngx_data_item_t *
  252. ‌ngx_data_struct_int_handler(uintptr_t data, ngx_pool_t *pool, void *ctx)
  253. {
  254.     ngx_int_t  value;

  256.     value = *(ngx_int_t *) ((u_char *) ctx + data);

  258.     return ngx_data_number_handler(value, pool, NULL);
  259. }


  262. ngx_data_item_t *
  263. ‌ngx_data_struct_atomic_handler(uintptr_t data, ngx_pool_t *pool, void *ctx)
  264. {
  265.     ngx_data_item_t  *item;

  267.     item = ngx_data_new_integer(pool);
  268.     if (item == NULL) {
  269.         return NULL;
  270.     }

  272.     item->data.integer = *(ngx_atomic_uint_t *) ((u_char *) ctx + data);

  274.     return item;
  275. }


  278. ngx_data_item_t *
  279. ‌ngx_data_struct_str_handler(uintptr_t data, ngx_pool_t *pool, void *ctx)
  280. {
  281.     ngx_str_t        *value, *src;
  282.     ngx_data_item_t  *item;

  284.     item = ngx_data_new_string(pool);
  285.     if (item == NULL) {
  286.         return NULL;
  287.     }

  289.     value = &item->data.string;

  291.     src = (ngx_str_t *) ((u_char *) ctx + data);

  293.     value->len = src->len;

  295.     value->data = ngx_pstrdup(pool, src);
  296.     if (value->data == NULL) {
  297.         return NULL;
  298.     }

  300.     return item;
  301. }


  304. ngx_data_item_t *
  305. ‌ngx_data_struct_boolean_handler(uintptr_t data, ngx_pool_t *pool, void *ctx)
  306. {
  307.     ngx_uint_t  value;

  309.     value = *(ngx_uint_t *) ((u_char *) ctx + data);

  311.     return ngx_data_boolean_handler(value, pool, NULL);
  312. }

One Level Up Top Level