1
9
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
35
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
111
112
118
119
120
121
122
123
124
125
126
127
130
131
134
135
136
137
138
142
143
144
145
146
147
148
153
160
161
162
166
167
168
169
170
171
172
177
184
185
186
187
188
189
190
191
192
193
198
199
200
201
202
203
204
205
206
207
211
212
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
252
253
254
255
256
257
258
259
260
261
262
263
264
268
269
270
271
272
273
274
275
280
281
282
283
284
285
286
287
/* ... */
#include <string.h>
#include "esp_log.h"
#include "esp_err.h"
#include "freertos/FreeRTOS.h"
#include "freertos/task.h"
#include "driver/spi_master.h"
#include "esp_serial_slave_link/essl_spi.h"7 includes
#define GPIO_MOSI 11
#define GPIO_MISO 13
#define GPIO_SCLK 12
#define GPIO_CS 10
#define MASTER_HOST SPI2_HOST
#define DMA_CHAN SPI_DMA_CH_AUTO
#define TX_SIZE_MIN 40
/* ... */
#define SLAVE_READY_FLAG_REG 0
#define SLAVE_READY_FLAG 0xEE
#define SLAVE_MAX_TX_BUF_LEN_REG 4
#define SLAVE_MAX_RX_BUF_LEN_REG 8
General Settings
#define SLAVE_TX_READY_BUF_SIZE_REG 12
#define SLAVE_RX_READY_BUF_NUM_REG 1613 defines
static const char TAG[] = "SEG_MASTER";
static void get_spi_bus_default_config(spi_bus_config_t *bus_cfg)
{
memset(bus_cfg, 0x0, sizeof(spi_bus_config_t));
bus_cfg->mosi_io_num = GPIO_MOSI;
bus_cfg->miso_io_num = GPIO_MISO;
bus_cfg->sclk_io_num = GPIO_SCLK;
bus_cfg->quadwp_io_num = -1;
bus_cfg->quadhd_io_num = -1;
bus_cfg->max_transfer_sz = 14000;
bus_cfg->flags = 0;
bus_cfg->intr_flags = 0;
}{ ... }
static void get_spi_device_default_config(spi_device_interface_config_t *dev_cfg)
{
memset(dev_cfg, 0x0, sizeof(spi_device_interface_config_t));
dev_cfg->clock_speed_hz = 10 * 1000 * 1000;
dev_cfg->mode = 0;
dev_cfg->spics_io_num = GPIO_CS;
dev_cfg->cs_ena_pretrans = 0;
dev_cfg->cs_ena_posttrans = 0;
dev_cfg->command_bits = 8;
dev_cfg->address_bits = 8;
dev_cfg->dummy_bits = 8;
dev_cfg->queue_size = 16;
dev_cfg->flags = SPI_DEVICE_HALFDUPLEX;
dev_cfg->duty_cycle_pos = 0;
dev_cfg->input_delay_ns = 0;
dev_cfg->pre_cb = NULL;
dev_cfg->post_cb = NULL;
}{ ... }
static void init_master_hd(spi_device_handle_t* out_spi)
{
spi_bus_config_t bus_cfg = {};
get_spi_bus_default_config(&bus_cfg);
ESP_ERROR_CHECK(spi_bus_initialize(MASTER_HOST, &bus_cfg, DMA_CHAN));
spi_device_interface_config_t dev_cfg = {};
get_spi_device_default_config(&dev_cfg);
ESP_ERROR_CHECK(spi_bus_add_device(MASTER_HOST, &dev_cfg, out_spi));
}{ ... }
static esp_err_t wait_for_slave_ready(spi_device_handle_t spi)
{
esp_err_t ret;
uint32_t slave_ready_flag;
while (1) {
ret = essl_spi_rdbuf(spi, (uint8_t *)&slave_ready_flag, SLAVE_READY_FLAG_REG, 4, 0);
if (ret != ESP_OK) {
return ret;
}{...}
if (slave_ready_flag != SLAVE_READY_FLAG) {
printf("Waiting for Slave to be ready...\n");
vTaskDelay(1000 / portTICK_PERIOD_MS);
}{...} else if (slave_ready_flag == SLAVE_READY_FLAG) {
return ESP_OK;
}{...}
}{...}
}{ ... }
static esp_err_t get_slave_max_buf_size(spi_device_handle_t spi, uint32_t *out_send_size, uint32_t *out_recv_size)
{
esp_err_t ret;
ret = essl_spi_rdbuf(spi, (uint8_t *)out_send_size, SLAVE_MAX_TX_BUF_LEN_REG, 4, 0);
if (ret != ESP_OK) {
return ret;
}{...}
ret = essl_spi_rdbuf(spi, (uint8_t *)out_recv_size, SLAVE_MAX_RX_BUF_LEN_REG, 4, 0);
if (ret != ESP_OK) {
return ret;
}{...}
return ret;
}{ ... }
/* ... */
static uint32_t get_slave_tx_buf_size(spi_device_handle_t spi)
{
uint32_t updated_size;
uint32_t temp;
ESP_ERROR_CHECK(essl_spi_rdbuf_polling(spi, (uint8_t *)&temp, SLAVE_TX_READY_BUF_SIZE_REG, 4, 0));
/* ... */
while (1) {
ESP_ERROR_CHECK(essl_spi_rdbuf_polling(spi, (uint8_t *)&updated_size, SLAVE_TX_READY_BUF_SIZE_REG, 4, 0));
if (updated_size == temp) {
return updated_size;
}{...}
temp = updated_size;
}{...}
}{ ... }
/* ... */
static uint32_t get_slave_rx_buf_num(spi_device_handle_t spi)
{
uint32_t updated_num;
uint32_t temp;
ESP_ERROR_CHECK(essl_spi_rdbuf_polling(spi, (uint8_t *)&temp, SLAVE_RX_READY_BUF_NUM_REG, 4, 0));
/* ... */
while (1) {
ESP_ERROR_CHECK(essl_spi_rdbuf_polling(spi, (uint8_t *)&updated_num, SLAVE_RX_READY_BUF_NUM_REG, 4, 0));
if (updated_num == temp) {
return updated_num;
}{...}
temp = updated_num;
}{...}
}{ ... }
void app_main(void)
{
spi_device_handle_t spi;
init_master_hd(&spi);
ESP_ERROR_CHECK(wait_for_slave_ready(spi));
/* ... */
uint32_t slave_max_tx_buf_size;
uint32_t slave_max_rx_buf_size;
ESP_ERROR_CHECK(get_slave_max_buf_size(spi, &slave_max_tx_buf_size, &slave_max_rx_buf_size));
uint32_t rx_buf_size = slave_max_tx_buf_size;
printf("\n\n---------SLAVE INFO---------\n\n");
printf("Slave MAX Send Buffer Size: %"PRIu32"\n", slave_max_tx_buf_size);
printf("Slave MAX Receive Buffer Size: %"PRIu32"\n", slave_max_rx_buf_size);
uint8_t *recv_buf = spi_bus_dma_memory_alloc(MASTER_HOST, rx_buf_size, 0);
if (!recv_buf) {
ESP_LOGE(TAG, "No enough memory!");
abort();
}{...}
uint8_t *send_buf = spi_bus_dma_memory_alloc(MASTER_HOST, slave_max_rx_buf_size, 0);
if (!send_buf) {
ESP_LOGE(TAG, "No enough memory!");
abort();
}{...}
uint32_t size_has_read = 0;
uint32_t size_to_read = 0;
uint32_t num_has_sent = 0;
uint32_t tx_trans_id = 0;
srand(30);
while (1) {
ESP_LOGI(TAG, "RECEIVING......");
/* ... */
uint32_t size_can_be_read = get_slave_tx_buf_size(spi) - size_has_read;
if (size_can_be_read > rx_buf_size) {
ESP_LOGW(TAG, "Slave is going to send buffer(%"PRIu32" Bytes) larger than pre-negotiated MAX size", size_can_be_read);
/* ... */
size_to_read = rx_buf_size;
}{...} else {
size_to_read = size_can_be_read;
}{...}
if (size_to_read) {
ESP_ERROR_CHECK(essl_spi_rddma(spi, recv_buf, size_to_read, -1, 0));
size_has_read += size_can_be_read;
printf("%s\n", recv_buf);
memset(recv_buf, 0x0, rx_buf_size);
}{...}
ESP_LOGI(TAG, "SENDING......");
/* ... */
uint32_t num_to_send = get_slave_rx_buf_num(spi) - num_has_sent;
uint32_t actual_tx_size = (rand() % (slave_max_rx_buf_size - TX_SIZE_MIN + 1)) + TX_SIZE_MIN;
snprintf((char *)send_buf, slave_max_rx_buf_size, "this is master's transaction %"PRIu32, tx_trans_id);
for (int i = 0; i < num_to_send; i++) {
ESP_ERROR_CHECK(essl_spi_wrdma(spi, send_buf, actual_tx_size, -1, 0));
num_has_sent++;
tx_trans_id++;
}{...}
}{...}
free(recv_buf);
free(send_buf);
spi_bus_remove_device(spi);
spi_bus_free(MASTER_HOST);
}{ ... }