#define SIRI_API_H_
#include <lib/http_parser.h>
-#include <uv.h>
#include <siri/db/db.h>
#include <siri/service/request.h>
+#include <stdbool.h>
+#include <uv.h>
typedef enum
{
siri_api_content_t content_type;
siri_api_req_t request_type;
service_request_t service_type;
- _Bool service_authenticated;
+ bool service_authenticated;
http_parser parser;
uv_write_t req;
};
#include <siri/db/series.h>
#include <siri/db/points.h>
#include <unistd.h>
+#include <stdbool.h>
#define MAX_BUFFER_SZ 1048576
siridb_buffer_t * siridb_buffer_new(void);
void siridb_buffer_free(siridb_buffer_t * buffer);
void siridb_buffer_close(siridb_buffer_t * buffer);
-_Bool siridb_buffer_is_valid_size(ssize_t ssize);
+bool siridb_buffer_is_valid_size(ssize_t ssize);
void siridb_buffer_set_path(siridb_buffer_t * buffer, const char * str);
int siridb_buffer_new_series(
siridb_buffer_t * buffer,
int siridb_tee_set_pipe_name(siridb_tee_t * tee, const char * pipe_name);
void siridb_tee_write(siridb_tee_t * tee, sirinet_promise_t * promise);
const char * tee_str(siridb_tee_t * tee);
-static inline _Bool siridb_tee_is_configured(siridb_tee_t * tee);
-static inline _Bool siridb_tee_is_connected(siridb_tee_t * tee);
-static inline _Bool siridb_tee_is_handle(uv_handle_t * handle);
+static inline bool siridb_tee_is_configured(siridb_tee_t * tee);
+static inline bool siridb_tee_is_connected(siridb_tee_t * tee);
+static inline bool siridb_tee_is_handle(uv_handle_t * handle);
struct siridb_tee_s
{
uv_pipe_t pipe;
};
-static inline _Bool siridb_tee_is_configured(siridb_tee_t * tee)
+static inline bool siridb_tee_is_configured(siridb_tee_t * tee)
{
return tee->pipe_name_ != NULL;
};
-static inline _Bool siridb_tee_is_connected(siridb_tee_t * tee)
+static inline bool siridb_tee_is_connected(siridb_tee_t * tee)
{
return tee->flags & SIRIDB_TEE_FLAG_CONNECTED;
}
-static inline _Bool siridb_tee_is_handle(uv_handle_t * handle)
+static inline bool siridb_tee_is_handle(uv_handle_t * handle)
{
return
handle->type == UV_NAMED_PIPE &&
#define SIRI_HEALTH_H_
#include <lib/http_parser.h>
+#include <stdbool.h>
#include <uv.h>
#define SIRIDB_HEALTH_FLAG 1<<30
int siri_health_init(void);
void siri_health_close(siri_health_request_t * web_request);
-static inline _Bool siri_health_is_handle(uv_handle_t * handle);
+static inline bool siri_health_is_handle(uv_handle_t * handle);
struct siri_health_request_s
{
uint32_t flags; /* maps to sirnet_stream_t tp for cleanup */
uint32_t pad0_;
- _Bool is_closed;
+ bool is_closed;
uv_write_t req;
uv_stream_t uvstream;
http_parser parser;
uv_buf_t * response;
};
-static inline _Bool siri_health_is_handle(uv_handle_t * handle)
+static inline bool siri_health_is_handle(uv_handle_t * handle)
{
return
handle->type == UV_TCP &&
#include <qpack/qpack.h>
#include <siri/siri.h>
+#include <stdbool.h>
int siri_service_account_init(siri_t * siri);
void siri_service_account_destroy(siri_t * siri);
qp_obj_t * qp_account,
qp_obj_t * qp_password,
char * err_msg);
-_Bool siri_service_account_check_basic(
+bool siri_service_account_check_basic(
siri_t * siri,
const char * data,
size_t n);
* Note that debian alpha packages should use versions like this:
* 2.0.34-0alpha0
*/
-#define SIRIDB_VERSION_PRE_RELEASE "-alpha-1"
+#define SIRIDB_VERSION_PRE_RELEASE "-alpha-2"
#ifndef NDEBUG
#define SIRIDB_VERSION_BUILD_RELEASE "+debug"
-siridb-connector
+siridb-connector==2.0.5
psutil
requests
pyleri
/*
* api.c
*/
-#include <string.h>
-#include <siri/api.h>
#include <assert.h>
#include <math.h>
+#include <siri/api.h>
+#include <stdbool.h>
+#include <string.h>
#include <siri/siri.h>
#include <siri/db/users.h>
#include <qpjson/qpjson.h>
return len;
}
-static inline _Bool api__istarts_with(
+static inline bool api__istarts_with(
const char ** str,
size_t * strn,
const char * with,
return true;
}
-static inline _Bool api__starts_with(
+static inline bool api__starts_with(
const char ** str,
size_t * strn,
const char * with,
}
}
-_Bool siridb_buffer_is_valid_size(ssize_t ssize)
+bool siridb_buffer_is_valid_size(ssize_t ssize)
{
return ssize >= 512 && (ssize % 512) == 0 && ssize <= MAX_BUFFER_SZ;
}
* since they only run when no other references to the object exist.
*/
#include <assert.h>
+#include <stdbool.h>
#include <stdint.h>
#include <stdio.h>
#include <stdlib.h>
+#include <string.h>
#include <logger/logger.h>
#include <siri/db/buffer.h>
#include <siri/db/db.h>
#include <siri/db/shards.h>
#include <siri/err.h>
#include <siri/siri.h>
-#include <string.h>
#include <xpath/xpath.h>
#define SIRIDB_SERIES_FN "series.dat"
(uint16_t) ((n / 11) % siridb->shard_mask_log) + 600 :
(uint16_t) ((n / 11) % siridb->shard_mask_num);
- if ((_Bool) ((n / 11) % 2))
+ if ((bool) ((n / 11) % 2))
{
series->flags |= SIRIDB_SERIES_IS_SERVER_ONE;
}
{
rc = -1;
break;
- } else {
+ }
+ else
+ {
continue;
}
}
{
rc = -1;
break;
- } else {
+ }
+ else
+ {
continue;
}
}
siridb_series_t * series,
siridb_points_t * points)
{
- _Bool is_num = siridb_series_isnum(series);
+ bool is_num = siridb_series_isnum(series);
siridb_shard_t * shard;
omap_t * shards;
uint64_t duration = siridb_series_duration(series);
else if (user->password[0] == '$')
{
/* this will migrate as soon as a user logs in */
- _Bool is_valid;
+ bool is_valid;
fallback_data.initialized = 0;
fallback_pw = crypt_r(password, user->password, &fallback_data);
is_valid = strcmp(fallback_pw, user->password) == 0;
/*
* siri/evars.c
*/
-
+#include <stdbool.h>
#include <siri/evars.h>
#include <siri/net/tcp.h>
if (!u8str)
return;
- *b = (_Bool) strtoul(u8str, NULL, 10);
+ *b = (bool) strtoul(u8str, NULL, 10);
}
static void evars__u16(const char * evar, uint16_t * u16)
}
-_Bool siri_service_account_check_basic(
+bool siri_service_account_check_basic(
siri_t * siri,
const char * data,
size_t n)
siri_service_account_t * account;
size_t size, nn, end;
char * b64 = base64_decode(data, n, &size);
- _Bool is_valid = false;
+ bool is_valid = false;
char pw[OWCRYPT_SZ];
for (nn = 0, end = size; nn < end; ++nn)
#include <siri/service/request.h>
#include <siri/siri.h>
#include <siri/version.h>
+#include <stdbool.h>
#include <stddef.h>
#include <unistd.h>
#include <uuid/uuid.h>
qp_unpacker_t * qp_unpacker,
char * err_msg)
{
- _Bool ignore_offline;
+ bool ignore_offline;
siridb_t * siridb;
qp_obj_t qp_key, qp_target, qp_ignore_offline;
sirinet_pkg_t * pkg;
#include "../test.h"
#include <siri/db/lookup.h>
+#include <stdbool.h>
/* to at least 42 pools we devide series within 20% off from ideal */
for (n = 0; n < SIRIDB_LOOKUP_SZ; ++n)
{
/* check for SIRIDB_SERIES_IS_SERVER_ONE flag */
- if ((_Bool) ((n / 11) % 2))
+ if ((bool) ((n / 11) % 2))
{
countersa[(*lookup)[n]]++;
}