GithubStar/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-10-29 11:36:47 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #662 from Barenboim/master

Browse Source 
fix MySQL Message seqid bug
This commit is contained in:
xiehan
2021-12-01 22:49:06 +08:00
committed by GitHub
parent 629e8de508 cd10f368b5
commit f5ed7d7f83
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/protocol/MySQLMessage.cc
+4 -3
View File
@@ -123,6 +123,7 @@ int MySQLMessage::encode(struct iovec vectors[], int max)
const unsigned char *p = (unsigned char *)buf_.c_str();
size_t nleft = buf_.size();
uint8_t seqid_start = seqid_;
uint8_t seqid = seqid_;
unsigned char *head;
uint32_t length;
int i = 0;
@@ -131,9 +132,9 @@ int MySQLMessage::encode(struct iovec vectors[], int max)
{
length = (nleft >= MYSQL_PAYLOAD_MAX ? MYSQL_PAYLOAD_MAX
: (uint32_t)nleft);
head = heads_[seqid_];
head = heads_[seqid];
int3store(head, length);
head[3] = seqid_++;
head[3] = seqid++;
vectors[i].iov_base = head;
vectors[i].iov_len = 4;
i++;
@@ -149,7 +150,7 @@ int MySQLMessage::encode(struct iovec vectors[], int max)
nleft -= MYSQL_PAYLOAD_MAX;
p += length;
} while (seqid_ != seqid_start);
} while (seqid != seqid_start);
errno = EOVERFLOW;
return -1;