Commit ef2a95c4 authored by zhaozhao.zz's avatar zhaozhao.zz
Browse files

networking: just move qb_pos instead of sdsrange in processInlineBuffer

parent e623bd22
...@@ -1152,9 +1152,8 @@ int processInlineBuffer(client *c) { ...@@ -1152,9 +1152,8 @@ int processInlineBuffer(client *c) {
if (querylen == 0 && c->flags & CLIENT_SLAVE) if (querylen == 0 && c->flags & CLIENT_SLAVE)
c->repl_ack_time = server.unixtime; c->repl_ack_time = server.unixtime;
/* Leave data after the first line of the query in the buffer */ /* Move querybuffer position to the next query in the buffer. */
sdsrange(c->querybuf,c->qb_pos+querylen+linefeed_chars,-1); c->qb_pos += querylen+linefeed_chars;
c->qb_pos = 0;
/* Setup argv array on client structure */ /* Setup argv array on client structure */
if (argc) { if (argc) {
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment