diff --git a/src/protocol/PackageWrapper.cc b/src/protocol/PackageWrapper.cc index 5810dca6..ce1152aa 100644 --- a/src/protocol/PackageWrapper.cc +++ b/src/protocol/PackageWrapper.cc @@ -39,7 +39,7 @@ int PackageWrapper::encode(struct iovec vectors[], int max) } cnt += ret; - this->message = this->next(this->message); + this->message = this->next_out(this->message); if (!this->message) return cnt; @@ -57,7 +57,7 @@ int PackageWrapper::append(const void *buf, size_t *size) if (ret > 0) { - this->message = this->next(this->message); + this->message = this->next_in(this->message); if (this->message) { this->renew();