Fixed bug
This commit is contained in:
parent
bc7887b5df
commit
1198159162
3 changed files with 6 additions and 2 deletions
4
binlog.c
4
binlog.c
|
@ -1030,6 +1030,10 @@ void replay_log_event (void) {
|
|||
struct message *M = message_get (*(long long *)rptr);
|
||||
rptr += 2;
|
||||
assert (M);
|
||||
if (M->flags & FLAG_PENDING) {
|
||||
message_remove_unsent (M);
|
||||
M->flags &= ~FLAG_PENDING;
|
||||
}
|
||||
message_remove_tree (M);
|
||||
message_del_peer (M);
|
||||
M->id = *(rptr ++);
|
||||
|
|
|
@ -562,7 +562,7 @@ void interpreter (char *line UU) {
|
|||
#define GET_PEER \
|
||||
id = next_token_peer (); \
|
||||
if (!cmp_peer_id (id, PEER_NOT_FOUND)) { \
|
||||
printf ("Bad user/char id\n"); \
|
||||
printf ("Bad user/chat id\n"); \
|
||||
RET; \
|
||||
}
|
||||
#define GET_PEER_USER \
|
||||
|
|
|
@ -701,7 +701,7 @@ void fetch_seq (void) {
|
|||
int x = fetch_int ();
|
||||
if (x > seq + 1) {
|
||||
logprintf ("Hole in seq: seq = %d, x = %d\n", seq, x);
|
||||
do_get_difference ();
|
||||
//do_get_difference ();
|
||||
//seq = x;
|
||||
} else if (x == seq + 1) {
|
||||
seq = x;
|
||||
|
|
Loading…
Add table
Reference in a new issue