blob_srv.h

Go to the documentation of this file.

/*
 * Copyright (c) 2020 Nordic Semiconductor ASA
 *
 * SPDX-License-Identifier: Apache-2.0
 */

 
#ifndef ZEPHYR_INCLUDE_BLUETOOTH_MESH_BLOB_SRV_H_
#define ZEPHYR_INCLUDE_BLUETOOTH_MESH_BLOB_SRV_H_
 
#include <zephyr/bluetooth/mesh/access.h>
#include <zephyr/bluetooth/mesh/blob.h>
 
#ifdef __cplusplus
extern "C" {
#endif

 
struct bt_mesh_blob_srv;

#if defined(CONFIG_BT_MESH_BLOB_SRV)
#define BT_MESH_BLOB_BLOCKS_MAX                                                \
        (DIV_ROUND_UP(CONFIG_BT_MESH_BLOB_SIZE_MAX,                        \
                          CONFIG_BT_MESH_BLOB_BLOCK_SIZE_MIN))
#else
#define BT_MESH_BLOB_BLOCKS_MAX 1
#endif

#define BT_MESH_MODEL_BLOB_SRV(_srv)                                           \
        BT_MESH_MODEL_CB(BT_MESH_MODEL_ID_BLOB_SRV, _bt_mesh_blob_srv_op,      \
                         NULL, _srv, &_bt_mesh_blob_srv_cb)

struct bt_mesh_blob_srv_cb {
        int (*start)(struct bt_mesh_blob_srv *srv, struct bt_mesh_msg_ctx *ctx,
                     struct bt_mesh_blob_xfer *xfer);

        void (*end)(struct bt_mesh_blob_srv *srv, uint64_t id, bool success);

        void (*suspended)(struct bt_mesh_blob_srv *srv);

        void (*resume)(struct bt_mesh_blob_srv *srv);

        int (*recover)(struct bt_mesh_blob_srv *srv,
                       struct bt_mesh_blob_xfer *xfer,
                       const struct bt_mesh_blob_io **io);
};

struct bt_mesh_blob_srv {
        const struct bt_mesh_blob_srv_cb *cb;
 
        /* Runtime state: */
        const struct bt_mesh_blob_io *io;
        struct k_work_delayable rx_timeout;
        struct bt_mesh_blob_block block;
        const struct bt_mesh_model *mod;
        enum bt_mesh_blob_xfer_phase phase;
 
        struct bt_mesh_blob_srv_state {
                struct bt_mesh_blob_xfer xfer;
                uint16_t cli;
                uint16_t app_idx;
                uint16_t timeout_base;
                uint16_t mtu_size;
                uint8_t ttl;
 
                /* Bitfield of pending blocks. */
                ATOMIC_DEFINE(blocks, BT_MESH_BLOB_BLOCKS_MAX);
        } state;
 
        /* Pull mode (Pull BLOB Transfer Mode) behavior. */
        struct {
                uint16_t chunk_idx;
                struct k_work_delayable report;
        } pull;
};

int bt_mesh_blob_srv_recv(struct bt_mesh_blob_srv *srv, uint64_t id,
                          const struct bt_mesh_blob_io *io, uint8_t ttl,
                          uint16_t timeout_base);

int bt_mesh_blob_srv_cancel(struct bt_mesh_blob_srv *srv);

bool bt_mesh_blob_srv_is_busy(const struct bt_mesh_blob_srv *srv);

uint8_t bt_mesh_blob_srv_progress(const struct bt_mesh_blob_srv *srv);

extern const struct bt_mesh_model_op _bt_mesh_blob_srv_op[];
extern const struct bt_mesh_model_cb _bt_mesh_blob_srv_cb;

 
#ifdef __cplusplus
}
#endif
 
#endif /* ZEPHYR_INCLUDE_BLUETOOTH_MESH_BLOB_SRV_H_ */