diff options
author | Loek Le Blansch <loek@pipeframe.xyz> | 2024-06-24 15:05:59 +0200 |
---|---|---|
committer | Loek Le Blansch <loek@pipeframe.xyz> | 2024-06-24 15:05:59 +0200 |
commit | e75fe1a5cce9bbdc1e1c0024b3820e22456fc1c5 (patch) | |
tree | 6265f07e76bcb4f57de61e093e1dd3f9e3331e46 /main/i2c.c | |
parent | a7271f52ef235c9035849c310bf341fe84f2815a (diff) |
fix Thomas' stupid broken code
Diffstat (limited to 'main/i2c.c')
-rw-r--r-- | main/i2c.c | 32 |
1 files changed, 15 insertions, 17 deletions
@@ -12,7 +12,7 @@ #include "pb-buf.h" #include "pb-send.h" -static pb_global_state_t _global_state = PB_GS_IDLE; +static pb_global_state_t _global_state = PB_GS_IDLE; pb_puzzle_module_t modules[CFG_PB_MOD_MAX]; // stolen from lib/pico-sdk/src/rp2_common/hardware_i2c/i2c.c #define i2c_reserved_addr(addr) (((addr) & 0x78) == 0 || ((addr) & 0x78) == 0x78) @@ -33,17 +33,7 @@ static void bus_scan() { pb_buf_free(&buf); } -static void state_exchange() { - - - for (size_t i = 0; i < modules_size; i++) { - pb_buf_t buf = pb_send_state_req(); - - pb_buf_free(&buf); - } -} - -void update_state() { +static void update_state() { // TODO: Add calculation(?) to get global state // all states idle == idle -> set first address as playingz // all states solved == solved @@ -56,10 +46,10 @@ void update_state() { for (size_t i = 0; i < modules_size; i++) { module_state = modules[i].state; if (module_state != PB_GS_SOLVED) - solved == false; - + solved = false; + if (module_state == PB_GS_PLAYING) - playing == true; + playing = true; } // set state if no further processing is needed @@ -74,7 +64,7 @@ void update_state() { // IF no module playing, get/set next module THAT IS NOT SOLVED to playing // and set mc state to playing // pb_i2c_send(addr, buff.msg, buff.size) - + for (size_t i = 0; i < modules_size; i++) { module_state = modules[i].state; if (module_state == PB_GS_IDLE) { @@ -86,6 +76,14 @@ void update_state() { } } +static void state_exchange() { + update_state(); + pb_buf_t buf = pb_send_state_req(); + for (size_t i = 0; i < modules_size; i++) + pb_i2c_send(modules[i].sender, (uint8_t *) buf.data, buf.size); + pb_buf_free(&buf); +} + void bus_task() { // do a scan of the bus bus_scan(); @@ -120,7 +118,7 @@ void pb_route_cmd_magic_res(pb_msg_t * msg) { void pb_route_cmd_state_res(pb_msg_t * msg) { pb_cmd_state_t * cmd = msg->cmd; i2c_addr_t sender = msg->sender; - + // update sender state for( size_t i = 0; i < modules_size; i++ ) { if (modules[i].sender == sender) { |