applications/tg
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Added some debug info

Browse Source
This commit is contained in:
vysheng 2013-10-24 23:48:51 +04:00
parent 79aa30d2cb
commit d8aaf0c804
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
mtproto-client.c
View File

@ -991,6 +991,9 @@ void work_msgs_ack (struct connection *c UU, long long msg_id UU) {
int i; int i;
for (i = 0; i < n; i++) { for (i = 0; i < n; i++) {
long long id = fetch_long (); long long id = fetch_long ();
if (verbosity) {
logprintf ("ack for %lld\n", id);
}
query_ack (id); query_ack (id);
} }
} }

8
queries.c
View File

@ -51,6 +51,7 @@ double get_double_time (void) {
} }
struct query *query_get (long long id) { struct query *query_get (long long id) {
tree_check_query (queries_tree);
return tree_lookup_query (queries_tree, (void *)&id); return tree_lookup_query (queries_tree, (void *)&id);
} }
@ -59,8 +60,9 @@ int alarm_query (struct query *q) {
if (verbosity) { if (verbosity) {
logprintf ("Alarm query %lld\n", q->msg_id); logprintf ("Alarm query %lld\n", q->msg_id);
} }
tree_delete_query (queries_tree, q);
q->ev.timeout = get_double_time () + QUERY_TIMEOUT; q->ev.timeout = get_double_time () + QUERY_TIMEOUT;
insert_event_timer (&q->ev); //insert_event_timer (&q->ev);
return 0; return 0;
} }
@ -80,7 +82,7 @@ struct query *send_query (struct dc *DC, int ints, void *data, struct query_meth
memcpy (q->data, data, 4 * ints); memcpy (q->data, data, 4 * ints);
q->msg_id = encrypt_send_message (DC->sessions[0]->c, data, ints, 1); q->msg_id = encrypt_send_message (DC->sessions[0]->c, data, ints, 1);
if (verbosity) { if (verbosity) {
logprintf ( "Msg_id is %lld\n", q->msg_id); logprintf ( "Msg_id is %lld %p\n", q->msg_id, q);
} }
q->methods = methods; q->methods = methods;
q->DC = DC; q->DC = DC;
@ -103,6 +105,8 @@ struct query *send_query (struct dc *DC, int ints, void *data, struct query_meth
void query_ack (long long id) { void query_ack (long long id) {
struct query *q = query_get (id); struct query *q = query_get (id);
if (q && !(q->flags & QUERY_ACK_RECEIVED)) { if (q && !(q->flags & QUERY_ACK_RECEIVED)) {
tree_check_query (queries_tree);
assert (q->msg_id == id);
q->flags |= QUERY_ACK_RECEIVED; q->flags |= QUERY_ACK_RECEIVED;
remove_event_timer (&q->ev); remove_event_timer (&q->ev);
} }