#include <iostream> #include "libmodbus/modbus.h" #include <stdexcept> class ModbusTCPServer { public: ModbusTCPServer(int port) { ctx = modbus_new_tcp(NULL, port); if (!ctx) { throw std::runtime_error("Failed to create Modbus TCP server."); } } ~ModbusTCPServer() { modbus_close(ctx); modbus_free(ctx); } void listen(int max_connections) { modbus_tcp_listen(ctx, max_connections); } void accept(modbus_t* slave_ctx) { modbus_tcp_accept(ctx, &slave_ctx); } void close() { modbus_tcp_close(ctx); } private: modbus_t* ctx; };错误
时间: 2024-02-22 18:57:37 浏览: 119
这段代码中存在一个错误:在`accept`函数中,`&slave_ctx`应该改为`slave_ctx`,即:
```
void accept(modbus_t* slave_ctx) {
modbus_tcp_accept(ctx, slave_ctx);
}
```
因为`modbus_tcp_accept`函数的第二个参数是一个`modbus_t**`类型的指针,而`slave_ctx`已经是一个指向`modbus_t`类型的指针,不需要再取其地址。
另外,建议在`listen`函数和`accept`函数中添加错误检查,以确保这些函数执行成功。
修改后的代码如下:
```
#include <iostream>
#include "libmodbus/modbus.h"
#include <stdexcept>
class ModbusTCPServer {
public:
ModbusTCPServer(int port) {
ctx = modbus_new_tcp(NULL, port);
if (!ctx) {
throw std::runtime_error("Failed to create Modbus TCP server.");
}
}
~ModbusTCPServer() {
modbus_close(ctx);
modbus_free(ctx);
}
void listen(int max_connections) {
if (modbus_tcp_listen(ctx, max_connections) == -1) {
throw std::runtime_error("Failed to listen for Modbus TCP connections.");
}
}
void accept(modbus_t* slave_ctx) {
if (modbus_tcp_accept(ctx, slave_ctx) == -1) {
throw std::runtime_error("Failed to accept Modbus TCP connection.");
}
}
void close() {
modbus_tcp_close(ctx);
}
private:
modbus_t* ctx;
};
```
这样就能保证代码能够正确地运行,并在发生错误时抛出异常。
阅读全文