Compare commits
2 Commits
bb7d2d7ae0
...
9899c0c5e2
Author | SHA1 | Date | |
---|---|---|---|
9899c0c5e2 | |||
c50de0b0f0 |
@ -412,7 +412,7 @@ void tf_ssb_ebt_get_progress(tf_ssb_ebt_t* ebt, int* in_pending, int* in_total,
|
|||||||
{
|
{
|
||||||
uv_mutex_lock(&ebt->mutex);
|
uv_mutex_lock(&ebt->mutex);
|
||||||
_ebt_count_messages(ebt, in_pending, out_pending);
|
_ebt_count_messages(ebt, in_pending, out_pending);
|
||||||
*in_total = ebt->max_in;
|
*in_total = tf_max(*in_pending, ebt->max_in);
|
||||||
*out_total = ebt->max_out;
|
*out_total = tf_max(*out_pending, ebt->max_out);
|
||||||
uv_mutex_unlock(&ebt->mutex);
|
uv_mutex_unlock(&ebt->mutex);
|
||||||
}
|
}
|
||||||
|
@ -1009,9 +1009,7 @@ static void _tf_ssb_connection_send_history_stream(
|
|||||||
.end_request = end_request,
|
.end_request = end_request,
|
||||||
};
|
};
|
||||||
snprintf(async->author, sizeof(async->author), "%s", author);
|
snprintf(async->author, sizeof(async->author), "%s", author);
|
||||||
char key[128];
|
tf_ssb_connection_schedule_idle(connection, author, _tf_ssb_connection_send_history_stream_callback, async);
|
||||||
snprintf(key, sizeof(key), "%s:%" PRId64, author, sequence);
|
|
||||||
tf_ssb_connection_schedule_idle(connection, key, _tf_ssb_connection_send_history_stream_callback, async);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user