You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by di...@apache.org on 2022/06/28 02:48:51 UTC
[rocketmq-client-cpp] branch master updated: avoid possible type conversion compile error (#419)
This is an automated email from the ASF dual-hosted git repository.
dinglei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-cpp.git
The following commit(s) were added to refs/heads/master by this push:
new 5099062 avoid possible type conversion compile error (#419)
5099062 is described below
commit 509906235aa1c43348c827a0898cc722836c4f0e
Author: xiaojin <zt...@163.com>
AuthorDate: Tue Jun 28 10:48:45 2022 +0800
avoid possible type conversion compile error (#419)
* avoid possible type conversion compile error
(cherry picked from commit 5be97e7c7a82afa87a84e959ce326ee33a98beef)
* Update src/transport/TcpTransport.cpp
Co-authored-by: James Yin <yw...@hotmail.com>
Co-authored-by: James Yin <yw...@hotmail.com>
---
src/producer/StringIdMaker.cpp | 10 +++++-----
src/transport/TcpTransport.cpp | 2 +-
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/src/producer/StringIdMaker.cpp b/src/producer/StringIdMaker.cpp
index 13978e3..ecd3653 100644
--- a/src/producer/StringIdMaker.cpp
+++ b/src/producer/StringIdMaker.cpp
@@ -125,11 +125,11 @@ std::string StringIdMaker::createUniqID() {
return std::string(kFixString, 20) + std::string(hex_buf, 12);
}
-void StringIdMaker::hexdump(unsigned char* in, char* out, std::size_t len) {
- for (std::size_t i = 0; i < len; i++) {
- unsigned char v = in[i];
- out[i * 2] = sHexAlphabet[v >> 4];
- out[i * 2 + 1] = sHexAlphabet[v & 0x0FU];
+void StringIdMaker::hexdump(unsigned char* buffer, char* out_buff, std::size_t index) {
+ for (std::size_t i = 0; i < index; i++) {
+ unsigned char v = buffer[i];
+ out_buff[i * 2] = sHexAlphabet[v >> 4];
+ out_buff[i * 2 + 1] = sHexAlphabet[v & 0x0FU];
}
}
diff --git a/src/transport/TcpTransport.cpp b/src/transport/TcpTransport.cpp
index 2942258..d8c23f9 100644
--- a/src/transport/TcpTransport.cpp
+++ b/src/transport/TcpTransport.cpp
@@ -207,7 +207,7 @@ void TcpTransport::eventCallback(BufferEvent* event, short what, TcpTransport* t
// disable Nagle
int val = 1;
- setsockopt(fd, IPPROTO_TCP, TCP_NODELAY, (void*)&val, sizeof(val));
+ setsockopt(fd, IPPROTO_TCP, TCP_NODELAY, static_cast<const char *>(&val), sizeof(val));
transport->setTcpConnectEvent(TCP_CONNECT_STATUS_SUCCESS);
} else if (what & (BEV_EVENT_ERROR | BEV_EVENT_EOF | BEV_EVENT_READING | BEV_EVENT_WRITING)) {
LOG_INFO("eventcb: received error event cb:%x on fd:%d", what, fd);