1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
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
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
#include "i2c.h"
#include "init.h"
#include "sock.h"
#include "pb/types.h"
#include <stdio.h>
#include <stddef.h>
#include <stdint.h>
#include <string.h>
#include <pico/stdlib.h>
#include <hardware/i2c.h>
#include <lwip/opt.h>
#include <lwip/sys.h>
#include <lwip/api.h>
#include <string.h>
uint8_t found[MAX_SLAVES];
extern struct netconn* current_connection;
void init_i2c() {
i2c_init(I2C_PORT, 100 * 1000); // currently at 100kHz
// Initialize I2C pins - sda(16), scl(17)
gpio_set_function(SDA_PIN, GPIO_FUNC_I2C);
gpio_set_function(SCL_PIN, GPIO_FUNC_I2C);
gpio_pull_up(SDA_PIN);
gpio_pull_up(SCL_PIN);
}
int read_i2c(uint8_t addr, uint8_t *output, size_t len) {
// false - finished with bus
return i2c_read_blocking (I2C_PORT, addr, output, len, false);
}
int write_i2c(uint8_t addr, uint8_t *input, size_t len) {
// true to keep master control of bus
return i2c_write_blocking (I2C_PORT, addr, input, len, true);
}
bool reserved_addr(uint8_t addr) {
return (addr & 0x78) == 0 || (addr & 0x78) == 0x78;
}
void init_addr_array(uint8_t array[], int size) {
for(int i = 0; i < size; i++){
array[i] = 0x00;
}
}
int write_read_i2c(uint8_t addr, uint8_t *input, size_t input_len, uint8_t *output, size_t output_len){
// herhaalde start conditie voor direct lezen na i2c write (?)
int ret = write_i2c(addr, input, input_len);
if (ret < 0) {
printf("Write failure while writing data to bus.\n");
return ret;
}
// wait for response
absolute_time_t start_time = get_absolute_time();
while ( absolute_time_diff_us(start_time, get_absolute_time()) / 1000 < MAX_TIMEOUT_TIME ){
ret = read_i2c(addr, output, output_len);
if( ret > 0 ) {
return ret;
}
sleep_ms(1);
}
printf("Timeout occurred while waiting for slave response.\n");
return -1;
}
// Make sure that current addresses are checked (modules), and invalid addresses are ignore (neotrellis slave)
uint8_t* scan_bus(uint8_t *array) {
int ret;
int i = 0;
uint8_t* rxdata, handshake_data;
init_addr_array(array, MAX_SLAVES);
for(int addr = 1; addr < (1<<7); addr++) {
// fix handshake
ret = read_i2c(addr, rxdata, 1);
if ( ret <= 0 )
continue;
printf("found possible i2c slave on addr: %d\n", addr);
// do handshake
ret = write_read_i2c(addr, (uint8_t*)pb_magic_msg, sizeof(pb_magic_msg), &handshake_data, sizeof(pb_magic_res)); // fix data + length + everything
if ( ret != sizeof(pb_magic_res))
continue;
if ( ret > 0 && (memcmp(handshake_data, pb_magic_res, sizeof(pb_magic_res)) == 0)) {
char buf[80];
size_t s = snprintf(buf, 80,"found i2c puzzle module at address: 0x%02x\n");
netconn_write(current_connection, buf, s, NETCONN_COPY);
array[i] = addr;
i++;
}
}
return array;
}
void bus_task() {
// scan bus for slaves
// send updates at regular intervals
await_init();
scan_bus(found);
while(1) {
// add check if bus is in use
uint8_t data;
for(int i = 0; i < MAX_SLAVES; i++){
if( found[i] == 0x00 )
continue;
read_i2c(found[i], &data, 2);
if(data > 0) {
printf("Data: %d", data);
}
}
sleep_ms(1000); // wait for one second before next loop
}
}
|