protofusion-esp32-template Changeset - 48d2337d76c2

Changeset - 48d2337d76c2

Parent rev.

Child rev.

[Not reviewed]

default

0 4 0

Ethan Zonca - 8 months ago 2024-09-29 12:16:50
ez@ethanzonca.com

Functional OSC TX and RX

4 files changed with 69 insertions and 40 deletions:

components/esp-osc/esp_osc.c

main/main.c

main/osc_control.c

main/wifi.c

0 comments (0 inline, 0 general)

components/esp-osc/esp_osc.c

➞

Show inline comments

 #include <stdio.h>
 #include <stdarg.h>
 #include <esp_log.h>
 #include "esp_osc.h"
 #define TAG "esp-osc"
 bool esp_osc_init(esp_osc_client_t *client, uint16_t buf_len, uint16_t port) {
   // free existing memory
@@ @@ -76,12 +75,15 @@ bool esp_osc_send_v(esp_osc_client_t *cl @@
   // send message
   if (sendto(client->socket, client->sbuf, length, 0, (struct sockaddr *)&target->addr, sizeof(target->addr)) < 0) {
     ESP_LOGE(TAG, "failed to send message (%d)", errno);
     return false;
+  }
   else{
     ESP_LOGI(TAG, "sent message OK");
+  }
   return true;
+}
 bool esp_osc_receive(esp_osc_client_t *client, esp_osc_callback_t callback) {
   // prepare values

main/main.c

➞

Show inline comments

@@ @@ -45,17 +45,17 @@ void app_main(void) @@
     // Connect to wifi
     wifi_init();
     ledstrip_init();
     squeeze_init();
     // Initialize OSC
     osc_init();
     squeeze_init();
     // Initialize canbus
     //can_init();
     // Start tasks
     xTaskCreatePinnedToCore(ledstrip_refresh,    "ledstrip_refresh", 4096, NULL, 10, NULL, 1);

main/osc_control.c

➞

Show inline comments

@@ @@ -3,41 +3,38 @@ @@
 #include <esp_event.h>
 #include <esp_log.h>
 #include <esp_wifi.h>
 #include "display.h"
 #include <esp_osc.h>
 #include "ledstrip.h"
 #include "squeeze.h"
 #define WIFI_SSID ""
 #define WIFI_PASS ""
 #define OSC_ADDRESS ""
 #define OSC_PORT 0
 static const char *TAG = "osc_control";
 esp_osc_client_t client;
 #define FLAMESPEWER_IP "192.168.1.25"
 static esp_osc_client_t client;
 static void sender()
+{
   // select targets
   esp_osc_target_t targets[2] = {
       esp_osc_target("127.0.0.1", 9000),
       esp_osc_target(OSC_ADDRESS, OSC_PORT),
   };
 // static void sender()
 // {
 //   // select targets
 //   esp_osc_target_t targets[2] = {
 //       esp_osc_target("127.0.0.1", 9000),
 //   };
   for(;;) {
     // delay
     vTaskDelay(1000 / portTICK_PERIOD_MS);
 //   for(;;) {
 //     // delay
 //     vTaskDelay(1000 / portTICK_PERIOD_MS);
     // send messages
     for (size_t i = 0; i < 2; i++) {
       esp_osc_send(&client, &targets[i], "test", "ihfdsb", 42, (int64_t)84, 3.14f, 6.28, "foo", 3, "bar");
+    }
+  }
+}
 //     // send messages
 //     for (size_t i = 0; i < 2; i++) {
 //       esp_osc_send(&client, &targets[i], "test", "ihfdsb", 42, (int64_t)84, 3.14f, 6.28, "foo", 3, "bar");
 //     }
 //   }
 // }
 static uint8_t r_man = 0;
 static uint8_t g_man = 0;
 static uint8_t b_man = 0;
@@ @@ -114,40 +111,67 @@ static bool callback(const char *topic, @@
+      {
         ESP_LOGI(TAG, "==> b: %.*s (%d)", values[i].bl, values[i].b, values[i].bl);
         break;
+      }
+    }
+  }
   display_update_text(out);
   return true;
+}
 static void receiver() {
 #define FLAMESPEWER_IP "192.168.1.204"
 static void osc_process()
+{
   for (;;) {
     // receive messages
     esp_osc_receive(&client, callback);
+  }
+}
 static void restarter() {
   for (;;) {
     // delay
     vTaskDelay(5000 / portTICK_PERIOD_MS);
     // restart client
     esp_osc_init(&client, 1024, 9000);
     // vTaskDelay(pdMS_TO_TICKS(100));
     vTaskDelay(pdMS_TO_TICKS(100));
+  }
+}
 //#define pdTICKSTOMS( xTicks ) ( ( ( TickTypet ) ( xTicks ) * 1000u ) / configTICKRATE_HZ )
 static void osc_send()
+{
   ESP_LOGI(TAG, "begin task osc_send");
   // // Really need this to wait for wifi connect
   esp_osc_target_t target = esp_osc_target("192.168.1.25", 5005);
     vTaskDelay(pdMS_TO_TICKS(2000));
   uint32_t last_tx = 0;
   for (;;) {
     if(squeeze_triggered())
+    {
       ESP_LOGI(TAG, "trig that squeeze");
       esp_osc_send(&client, &target, "/squeeze_trig", "i", 1);
+    }
     if(xTaskGetTickCount()*portTICK_PERIOD_MS - last_tx > 150)
+    {
       last_tx = xTaskGetTickCount() * portTICK_PERIOD_MS;
       esp_osc_send(&client, &target, "/squeeze_value", "f", squeeze_value());
+    }
     vTaskDelay(pdMS_TO_TICKS(10));
+  }
+}
 void osc_init() {
   // prepare client
   esp_osc_init(&client, 1024, 5005);
   // create tasks
   //xTaskCreatePinnedToCore(sender, "sender", 4096, NULL, 10, NULL, 1);
   xTaskCreatePinnedToCore(receiver, "receiver", 4096, NULL, 10, NULL, 1);
   //xTaskCreatePinnedToCore(restarter, "restarter", 4096, NULL, 10, NULL, 1);
   xTaskCreatePinnedToCore(osc_process, "osc_process", 1024*8, NULL, 10, NULL, 1);
   xTaskCreatePinnedToCore(osc_send, "osc_send", 1024*4, NULL, 10, NULL, 1);
+}
@@ \ No newline at end of file @@

main/wifi.c

➞

Show inline comments

@@ @@ -70,12 +70,15 @@ void wifi_init(void) @@
     ESP_ERROR_CHECK(esp_event_loop_create_default());
     esp_netif_create_default_wifi_sta();
     wifi_init_config_t cfg = WIFI_INIT_CONFIG_DEFAULT();
     ESP_ERROR_CHECK(esp_wifi_init(&cfg));
     // EMZ new
     ESP_ERROR_CHECK(esp_wifi_set_storage(WIFI_STORAGE_RAM));
     esp_event_handler_instance_t instance_any_id;
     esp_event_handler_instance_t instance_got_ip;
     ESP_ERROR_CHECK(esp_event_handler_instance_register(WIFI_EVENT,
                                                         ESP_EVENT_ANY_ID,
                                                         &__event_handler,
                                                         NULL,

0 comments (0 inline, 0 general)