publising big MQTT msgs

[MosheSmartAmr]

Hi, 

I have modyfied the MQTT example to, so I can send data to my own AWS account.

I'm trying to publish big packets of data, (> 7K) without luck .

what I have done is :

1. change CONFIG_MQTT_MAX_PACKET_LENGTH to 8500

2. modify client_write, the following way, 

Fullscreen

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

static int client_write(struct mqtt_client *client, const u8_t *data,

u32_t datalen)

{

int err_code=0;

u32_t tmplen=datalen;

u8_t* tmpdata=data;

MQTT_TRC("[%p]: Transport writing %d bytes.", client, datalen);

MQTT_SET_STATE(client, MQTT_STATE_PENDING_WRITE);

do {

if (tmplen > MAX_SEND_SIZE_SCK)

{

err_code += mqtt_transport_write(client, tmpdata, MAX_SEND_SIZE_SCK);

tmplen -= MAX_SEND_SIZE_SCK;

tmpdata += MAX_SEND_SIZE_SCK;

if (err_code) printk("failed with errorcode : %d\n",err_code);

else

printk("all_ok!\n");

}

else

XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX

static int client_write(struct mqtt_client *client, const u8_t *data,
                        u32_t datalen)
{
        int err_code=0;
        u32_t tmplen=datalen;
        u8_t* tmpdata=data;
        MQTT_TRC("[%p]: Transport writing %d bytes.", client, datalen);

        MQTT_SET_STATE(client, MQTT_STATE_PENDING_WRITE);

        do {
        if (tmplen > MAX_SEND_SIZE_SCK)
        {
                err_code += mqtt_transport_write(client, tmpdata, MAX_SEND_SIZE_SCK);
                tmplen -= MAX_SEND_SIZE_SCK;
                tmpdata += MAX_SEND_SIZE_SCK;
                if (err_code) printk("failed with errorcode : %d\n",err_code);
                else
                        printk("all_ok!\n");
        }
        else
        {
                err_code += mqtt_transport_write(client, tmpdata, tmplen);
                break;
        }
        } while (1);
        MQTT_RESET_STATE(client, MQTT_STATE_PENDING_WRITE);

        if (err_code != 0) {
                printk("TCP write failed, errno = %d, "
                         "closing connection\n", errno);
                client_disconnect(client, err_code);
                return -EIO;
        }

        MQTT_TRC("[%p]: Transport write complete.", client);
        client->last_activity = mqtt_sys_tick_in_ms_get();

        return 0;
}

I still get :

TCP write failed, errno = 12, closing connection

any idea why? 

[Martin Lesund]

Hi Moshe,

The TLS output buffer has a size of 2kB, and there is a bug that you do not get a notification that the messages are too big. (this will be fixed)

So the solution is to have shorter messages.

Best Regards,
Martin L.

[MosheSmartAmr]

Hi Martin,

Thanks for your answer,

I am not sure this is the issue I am having  as I am able to send messages of ~4kb.

also if I understand correctly, my code snippet above is suppose to overcome the 2KB TLS output buffer.

[Martin Lesund]

Hi Moshe,

Could you please take a modem trace and share with me so I can see what is going on at your side.