AWS IOT

[zzzlll111]

Why does debugging according to the official website's routine always get stuck here

[scaprile]

Please don't paste snapshots, you can do the same pasting a text log.

Maybe because you didn't fill your data or your network does not allow connection, all I seem to see is a connection attempt
Please sniff your network (using Wireshark, for example) and observe the traffic.
If, after your network inspection, you find an actual issue, feel free to open an issue, fill the issue template, and provide us with pertinent information (including useful network capture files; no snapshots, please attach capture files) in order to reproduce and fix the issue. We don't inspect your code for errors, please send the minimum piece of code that can reproduce the issue

[zzzlll111]

Think you This is a code snippet. I always time out on Windows, but on linux, it won't respond after just one connection

static const char *s_url ="a1mp3hdlpio4yf-ats.iot.us-east-2.amazonaws.com";
static const char *s_rx_topic = "d/rx";
static const char *s_tx_topic = "d/tx";
static int s_qos = 1;

static void fn(struct mg_connection *c, int ev, void *ev_data) {
if (ev == MG_EV_OPEN) {
// c->is_hexdumping = 1;
cout<<"On error, log error message"<<endl;
} else if (ev == MG_EV_CONNECT) {
if (mg_url_is_ssl(s_url)) {
cout<<"MG_EV_CONNECT"<<endl;
struct mg_tls_opts opts = {.ca = mg_unpacked("/customer/prm/res/others/AmazonRootCA1.pem"),
.cert = mg_unpacked("/customer/prm/res/others/certificate.pem.crt"),
.key = mg_unpacked("/customer/prm/res/others/key.pem"),
.name = mg_url_host(s_url)};
mg_tls_init(c, &opts);
}
} else if (ev == MG_EV_ERROR) {
// On error, log error message
printf("%p %s", c->fd, (char *) ev_data);
cout<<"On error, log error message"<<endl;
} else if (ev == MG_EV_MQTT_OPEN) {
// MQTT connect is successful
struct mg_str topic = mg_str(s_rx_topic);
printf("Connected to %s", s_url);
printf("Subscribing to %s", s_rx_topic);
cout<<"MQTT connect is successful"<<endl;
struct mg_mqtt_opts sub_opts;
memset(&sub_opts, 0, sizeof(sub_opts));
sub_opts.topic = topic;
sub_opts.qos = s_qos;
mg_mqtt_sub(c, &sub_opts);
c->data[0] = 'X'; // Set a label that we're logged in
} else if (ev == MG_EV_MQTT_MSG) {
cout<<"When we receive MQTT message, print it"<<endl;
// When we receive MQTT message, print it
struct mg_mqtt_message *mm = (struct mg_mqtt_message *) ev_data;
printf("Received on %.*s : %.s", (int) mm->topic.len, mm->topic.buf,
(int) mm->data.len, mm->data.buf);
} else if (ev == MG_EV_POLL && c->data[0] == 'X') {
static unsigned long prev_second;
unsigned long now_second = ((unsigned long *) ev_data) / 1000;
if (now_second != prev_second) {
struct mg_str topic = mg_str(s_tx_topic), data = mg_str("{"a":123}");
printf("Publishing to %s", s_tx_topic);
struct mg_mqtt_opts pub_opts;
memset(&pub_opts, 0, sizeof(pub_opts));
pub_opts.topic = topic;
pub_opts.message = data;
pub_opts.qos = s_qos, pub_opts.retain = false;
mg_mqtt_pub(c, &pub_opts);
prev_second = now_second;
}
}

if (ev == MG_EV_ERROR || ev == MG_EV_CLOSE) {
printf("Got event %d, stopping...", ev);
*(bool *) c->fn_data = true; // Signal that we're done
}
}

//int main(void) {
// struct mg_mgr mgr;
// struct mg_mqtt_opts opts = {.clean = true};
// bool done = false;
// mg_log_set(MG_LL_DEBUG);
// mg_mgr_init(&mgr); // Initialise event manager
// MG_INFO(("Connecting to %s", s_url)); // Inform that we're starting
// mg_mqtt_connect(&mgr, s_url, &opts, fn, &done); // Create client connection
// while (!done) mg_mgr_poll(&mgr, 1000); // Loop until done
// mg_mgr_free(&mgr); // Finished, cleanup
// return 0;
//}

void Wcmn::wMAsyncWorker1_ref_cb(uint16_t code, LvEvent e) {
struct mg_mgr mgr;
struct mg_mqtt_opts opts = {0};
opts.clean = true;
bool done = false;
mg_log_set(MG_LL_DEBUG);
mg_mgr_init(&mgr); // Initialise event manager
printf("Connecting to %s", s_url); // Inform that we're starting
mg_mqtt_connect(&mgr, s_url, &opts, fn, &done); // Create client connection
while (!done) mg_mgr_poll(&mgr, 1000); // Loop until done
mg_mgr_free(&mgr); // Finished, cleanup
// return 0;
}

[scaprile]

I already told you there is a connection attempt and no response, that looks very much like a network problem on your side.

Maybe because you didn't fill your data or your network does not allow connection, all I seem to see is a connection attempt

Please do as requested

Please sniff your network (using Wireshark, for example) and observe the traffic.
If, after your network inspection, you find an actual issue, feel free to open an issue, fill the issue template, and provide us with pertinent information (including useful network capture files; no snapshots, please attach capture files) in order to reproduce and fix the issue. We don't inspect your code for errors, please send the minimum piece of code that can reproduce the issue

Please read the above again, and one more time, and do as requested

In the event that you reduce your code to the minimum, as requested, Please properly format your code
I won't check your code for errors, only post what reproduces your error, but first analyze your traffic and make sure it is a Mongoose issue and not a network connection issue on your side