api

diff --git a/include/siri/db/series.inline.h b/include/siri/db/series.inline.h
index 5361cbf2dc0485f9c9bfa98f011e34e7ea739e2f..4adbf4d87bcc5f7a00d09c9f33540b105343a6a3 100644 (file)
--- a/include/siri/db/series.inline.h
+++ b/include/siri/db/series.inline.h
@@ -1,7 +1,7 @@
 #include <siri/db/series.h>
 #include <siri/db/shard.h>
 
-static inline size_t siridb_series_duration(siridb_series_t * series)
+static inline uint64_t siridb_series_duration(siridb_series_t * series)
 {
     return series->idx_len ? series->idx->shard->duration : 0;
 }

diff --git a/include/siri/db/shard.h b/include/siri/db/shard.h
index 759af9227b553ac0035621e6f2c61c5fddb1c31e..97e38dab2eb0fdcfa19596b5b1a9be12fe01e103 100644 (file)
--- a/include/siri/db/shard.h
+++ b/include/siri/db/shard.h
@@ -128,7 +128,7 @@ struct siridb_shard_s
     uint64_t id;
     size_t len;         /* size of the shard which is used */
     size_t size;        /* size of shard on disk */
-    size_t duration;    /* based on the interval of series */
+    uint64_t duration;  /* based on the interval of series */
     siri_fp_t * fp;
     char * fn;
     siridb_shard_t * replacing;

diff --git a/src/siri/api.c b/src/siri/api.c
index 21bfdb68b4c4c74972ca663498eaabe276da1c81..3e7d849333e0ddb0c16683d91238f3bdbe811954 100644 (file)
--- a/src/siri/api.c
+++ b/src/siri/api.c
@@ -117,6 +117,7 @@ static void api__alloc_cb(
         size_t UNUSED_sugsz __attribute__((unused)),
         uv_buf_t * buf)
 {
+    LOGC("ALLOC_CB");
     buf->base = malloc(HTTP_MAX_HEADER_SIZE);
     buf->len = buf->base ? HTTP_MAX_HEADER_SIZE-1 : 0;
 }
@@ -126,6 +127,7 @@ static void api__data_cb(
         ssize_t n,
         const uv_buf_t * buf)
 {
+    LOGC("DATA_CB");
     size_t parsed;
     siri_api_request_t * ar = uvstream->data;
 
@@ -202,6 +204,7 @@ static void api__get_siridb(siri_api_request_t * ar, const char * at, size_t n)
 
 static int api__url_cb(http_parser * parser, const char * at, size_t n)
 {
+    LOGC("URL_CB");
     siri_api_request_t * ar = parser->data;
 
     if (api__starts_with(&at, &n, "/query/", strlen("/query/")))
@@ -269,6 +272,7 @@ static int api__url_cb(http_parser * parser, const char * at, size_t n)
 
 static void api__connection_cb(uv_stream_t * server, int status)
 {
+    LOGC("CONNECTION_CB");
     int rc;
     siri_api_request_t * ar;
 
@@ -377,12 +381,14 @@ static int api__on_authorization(siri_api_request_t * ar, const char * at, size_
 }
 static int api__header_value_cb(http_parser * parser, const char * at, size_t n)
 {
+    LOGC("HEADER_VALUE_CB");
     siri_api_request_t * ar = parser->data;
     return ar->on_state ? ar->on_state(ar, at, n) : 0;
 }
 
 static int api__header_field_cb(http_parser * parser, const char * at, size_t n)
 {
+    LOGC("HEADER_FIELD_CB");
     siri_api_request_t * ar = parser->data;
 
     ar->on_state = API__ICMP_WITH(at, n, "content-type")
@@ -395,6 +401,7 @@ static int api__header_field_cb(http_parser * parser, const char * at, size_t n)
 
 static int api__body_cb(http_parser * parser, const char * at, size_t n)
 {
+    LOGC("BODY_CB");
     size_t offset;
     siri_api_request_t * ar = parser->data;
 
@@ -410,6 +417,7 @@ static int api__body_cb(http_parser * parser, const char * at, size_t n)
 
 static void api__write_cb(uv_write_t * req, int status)
 {
+    LOGC("WRITE_CB");
     if (status)
         log_error(
                 "error writing HTTP API response: `%s`",
@@ -659,6 +667,7 @@ static int api__insert_cb(http_parser * parser)
 
 static int api__query_cb(http_parser * parser)
 {
+    LOGC("QUERY_CB");
     api__query_t q;
     siri_api_request_t * ar = parser->data;
 
@@ -782,6 +791,7 @@ static int api__service_cb(http_parser * parser)
 
 static int api__message_complete_cb(http_parser * parser)
 {
+    LOGC("MESSAGE_COMPLETE_CB");
     siri_api_request_t * ar = parser->data;
 
     switch(ar->request_type)
@@ -801,6 +811,7 @@ static int api__message_complete_cb(http_parser * parser)
 
 static void api__write_free_cb(uv_write_t * req, int status)
 {
+    LOGC("FREE_WRITE_CB");
     free(req->data);
     api__write_cb(req, status);
 }
@@ -811,6 +822,7 @@ static int api__close_resp(
         void * data,
         size_t size)
 {
+    LOGC("CLOSE_RESPONSE_CB");
     char header[API__HEADER_MAX_SZ];
     int header_size = 0;