misc/cosmopolite
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

More portable random number generation.

Browse Source
This commit is contained in:
Ian Gulliver
2015-06-13 20:56:36 +00:00
parent 33579856c8
commit 2ea3dcee71
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
clients/c/cosmopolite.c
View File

@@ -287,7 +287,7 @@ static void *cosmo_thread_main(void *arg) {
instance->command_queue = json_array(); instance->command_queue = json_array();
instance->next_delay_ms = pow(instance->next_delay_ms, DELAY_EXPONENT); instance->next_delay_ms = pow(instance->next_delay_ms, DELAY_EXPONENT);
instance->next_delay_ms = min(DELAY_MAX_MS, max(DELAY_MIN_MS, instance->next_delay_ms)); instance->next_delay_ms = min(DELAY_MAX_MS, max(DELAY_MIN_MS, instance->next_delay_ms));
instance->next_delay_ms += random() % (instance->next_delay_ms / DELAY_STAGGER_FACTOR); instance->next_delay_ms += rand_r(&instance->seedp) % (instance->next_delay_ms / DELAY_STAGGER_FACTOR);
assert(!pthread_mutex_unlock(&instance->lock)); assert(!pthread_mutex_unlock(&instance->lock));
json_t *to_retry = cosmo_send_rpc(instance, commands); json_t *to_retry = cosmo_send_rpc(instance, commands);
@@ -437,11 +437,12 @@ json_t *cosmo_get_last_message(cosmo *instance, json_t *subject) {
cosmo *cosmo_create(const char *base_url, const char *client_id, const cosmo_callbacks *callbacks, void *passthrough) { cosmo *cosmo_create(const char *base_url, const char *client_id, const cosmo_callbacks *callbacks, void *passthrough) {
curl_global_init(CURL_GLOBAL_DEFAULT); curl_global_init(CURL_GLOBAL_DEFAULT);
srandomdev();
cosmo *instance = malloc(sizeof(cosmo)); cosmo *instance = malloc(sizeof(cosmo));
assert(instance); assert(instance);
instance->seedp = (unsigned int) time(NULL);
strcpy(instance->client_id, client_id); strcpy(instance->client_id, client_id);
cosmo_uuid(instance->instance_id); cosmo_uuid(instance->instance_id);

1
clients/c/cosmopolite.h
View File

@@ -25,6 +25,7 @@ typedef struct {
json_t *command_queue; json_t *command_queue;
json_t *subscriptions; json_t *subscriptions;
uint64_t next_delay_ms; uint64_t next_delay_ms;
unsigned int seedp;
pthread_t thread; pthread_t thread;
CURL *curl; CURL *curl;