diff options
| author | Daniel Stenberg <daniel@haxx.se> | 2023-02-27 10:02:22 +0100 |
|---|---|---|
| committer | Daniel Stenberg <daniel@haxx.se> | 2023-02-28 08:11:55 +0100 |
| commit | 252fce70b13d3620bd22ea4e3614649dd0067b42 (patch) | |
| tree | 5e3c5b61f537b98f668116f46da8ff08e1e2d771 /lib/mqtt.c | |
| parent | 3b23dbeec1e235f1c9af7c8c2660ca7e53ef6204 (diff) | |
| download | curl-252fce70b13d3620bd22ea4e3614649dd0067b42.tar.gz | |
mqtt: on send error, return error
Reported-by: Maciej Domanski
Closes #10623
Diffstat (limited to 'lib/mqtt.c')
| -rw-r--r-- | lib/mqtt.c | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/lib/mqtt.c b/lib/mqtt.c index 0b54bc0f8..47af36914 100644 --- a/lib/mqtt.c +++ b/lib/mqtt.c @@ -122,8 +122,9 @@ static CURLcode mqtt_send(struct Curl_easy *data, struct MQTT *mq = data->req.p.mqtt; ssize_t n; result = Curl_write(data, sockfd, buf, len, &n); - if(!result) - Curl_debug(data, CURLINFO_HEADER_OUT, buf, (size_t)n); + if(result) + return result; + Curl_debug(data, CURLINFO_HEADER_OUT, buf, (size_t)n); if(len != (size_t)n) { size_t nsend = len - n; char *sendleftovers = Curl_memdup(&buf[n], nsend); |