MT#55283 convert last_redis_update to int64_t

Change-Id: Id521b8b87ae2366c341e4b9871f253a24e750538
pull/1855/merge
Richard Fuchs 2 weeks ago
parent f35881548d
commit 27ff6e6f57

@ -271,7 +271,7 @@ next:
goto out;
// update every 5 minutes
if (has_srtp && timeval_from_us(rtpe_now).tv_sec - atomic64_get_na(&c->last_redis_update) > 60*5)
if (has_srtp && rtpe_now - atomic64_get_na(&c->last_redis_update_us) > 60*5*1000000LL)
do_update = true;
goto out;

@ -3099,7 +3099,7 @@ void ng_call_stats(ng_command_ctx_t *ctx, call_t *call, const str *fromtag, cons
parser->dict_add_int(ctx->resp, "created_us", call->created % 1000000L);
parser->dict_add_int(ctx->resp, "created_ts", call->created);
parser->dict_add_int(ctx->resp, "last signal", call->last_signal_us / 1000000L);
parser->dict_add_int(ctx->resp, "last redis update", atomic64_get_na(&call->last_redis_update));
parser->dict_add_int(ctx->resp, "last redis update", atomic64_get_na(&call->last_redis_update_us) / 1000000L);
if (call->metadata.s)
parser->dict_add_str(ctx->resp, "metadata", &call->metadata);

@ -697,13 +697,13 @@ static void cli_list_call_info(struct cli_writer *cw, call_t *c) {
"tos: %u\n"
"last_signal: %" PRId64 "\n"
"redis_keyspace: %i\n"
"last redis update: %llu\n"
"last redis update: %" PRId64 "\n"
"foreign: %s\n"
"recording: %s\n"
"\n",
c->callid.s, c->ml_deleted_us ? "yes" : "no", c->created / 1000000, c->created_from,
(unsigned int) c->tos, c->last_signal_us / 1000000L, c->redis_hosted_db,
(unsigned long long) atomic64_get_na(&c->last_redis_update),
atomic64_get_na(&c->last_redis_update_us),
IS_FOREIGN_CALL(c) ? "yes" : "no", c->recording ? "yes" : "no");
for (__auto_type l = c->monologues.head; l; l = l->next) {

@ -2781,7 +2781,7 @@ void redis_update_onekey(call_t *c, struct redis *r) {
if (redis_check_conn(r) == REDIS_STATE_DISCONNECTED)
return;
atomic64_set_na(&c->last_redis_update, timeval_from_us(rtpe_now).tv_sec);
atomic64_set_na(&c->last_redis_update_us, rtpe_now);
rwlock_lock_r(&c->master_lock);

@ -780,7 +780,7 @@ struct call {
endpoint_t dtmf_log_dest;
int redis_hosted_db;
atomic64 last_redis_update;
atomic64 last_redis_update_us;
struct recording *recording;
str metadata;

Loading…
Cancel
Save