Fixed a couple of nasty CLI bugs which were triggered on long or multi-part
outputs. It took a whole evening to hunt them down, but now the CLI seems to work fine. Now I run three BGP connections with several thousand routes!
This commit is contained in:
parent
54896cbdba
commit
f75e3bbc01
3 changed files with 9 additions and 9 deletions
11
nest/cli.c
11
nest/cli.c
|
@ -29,13 +29,13 @@ cli_alloc_out(cli *c, int size)
|
|||
c->tx_write->next = o;
|
||||
else
|
||||
c->tx_buf = o;
|
||||
o->next = NULL;
|
||||
o->wpos = o->outpos = o->buf;
|
||||
o->end = o->buf + CLI_TX_BUF_SIZE;
|
||||
}
|
||||
c->tx_write = o;
|
||||
if (!c->tx_pos)
|
||||
c->tx_pos = o;
|
||||
o->next = NULL;
|
||||
}
|
||||
o->wpos += size;
|
||||
return o->wpos - size;
|
||||
|
@ -123,7 +123,6 @@ cli_free_out(cli *c)
|
|||
|
||||
if (o = c->tx_buf)
|
||||
{
|
||||
c->tx_write = c->tx_pos = NULL;
|
||||
o->wpos = o->outpos = o->buf;
|
||||
while (p = o->next)
|
||||
{
|
||||
|
@ -131,6 +130,7 @@ cli_free_out(cli *c)
|
|||
mb_free(p);
|
||||
}
|
||||
}
|
||||
c->tx_write = c->tx_pos = NULL;
|
||||
c->async_msg_size = 0;
|
||||
}
|
||||
|
||||
|
@ -175,7 +175,7 @@ cli_command(struct cli *c)
|
|||
cli_printf(c, 9001, f.err_msg);
|
||||
}
|
||||
|
||||
static int
|
||||
static void
|
||||
cli_event(void *data)
|
||||
{
|
||||
cli *c = data;
|
||||
|
@ -193,7 +193,7 @@ cli_event(void *data)
|
|||
{
|
||||
err = cli_get_command(c);
|
||||
if (!err)
|
||||
return 0;
|
||||
return;
|
||||
if (err < 0)
|
||||
cli_printf(c, 9000, "Command too long");
|
||||
else
|
||||
|
@ -202,9 +202,8 @@ cli_event(void *data)
|
|||
if (cli_write(c))
|
||||
{
|
||||
cli_free_out(c);
|
||||
return 1;
|
||||
ev_schedule(c->event);
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
|
||||
cli *
|
||||
|
|
|
@ -870,7 +870,7 @@ sk_write(sock *s)
|
|||
case SK_DELETED:
|
||||
return;
|
||||
default:
|
||||
while (s->ttx != s->tbuf && sk_maybe_write(s) > 0)
|
||||
while (s->ttx != s->tpos && sk_maybe_write(s) > 0)
|
||||
s->tx_hook(s);
|
||||
}
|
||||
}
|
||||
|
|
|
@ -179,9 +179,10 @@ cli_write(cli *c)
|
|||
struct cli_out *o = c->tx_pos;
|
||||
c->tx_pos = o->next;
|
||||
s->tbuf = o->outpos;
|
||||
return sk_send(s, o->wpos - o->outpos);
|
||||
if (sk_send(s, o->wpos - o->outpos) > 0)
|
||||
ev_schedule(c->event);
|
||||
}
|
||||
return 1;
|
||||
return !c->tx_pos;
|
||||
}
|
||||
|
||||
int
|
||||
|
|
Loading…
Reference in a new issue