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

update sasl for scram

Browse Source
This commit is contained in:
wzlsuccess
2021-06-22 17:11:23 +08:00
committed by xiehan
parent d5a8137f32
commit b3654ec285
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/protocol/KafkaMessage.cc
+5 -3
View File
@@ -3787,11 +3787,11 @@ int KafkaResponse::handle_sasl_continue()
{
int ret;
std::vector<struct iovec> iovecs(2);
if (this->encode(iovecs.data(), 2) > 0)
if (this->encode(iovecs.data(), 2) >= 0)
{
for (auto vec : iovecs)
{
ret = this->feedback((const char *)vec.iov_base, vec.iov_len);
ret = this->feedback(vec.iov_base, vec.iov_len);
if (ret != (int)vec.iov_len)
{
if (ret > 0)
@@ -3800,6 +3800,8 @@ int KafkaResponse::handle_sasl_continue()
}
}
}
else
return -1;
return 0;
}
@@ -3829,7 +3831,7 @@ int KafkaResponse::append(const void *buf, size_t *size)
}
}
else
return -1;
ret = -1;
}
return ret;