summaryrefslogtreecommitdiff
path: root/code
diff options
context:
space:
mode:
Diffstat (limited to 'code')
-rw-r--r--code/ecp/fe310/transport.c1
-rw-r--r--code/esp32/components/eos/fe310.c6
-rwxr-xr-xcode/esp32/components/eos/transport.c2
-rw-r--r--code/fe310/eos/ecp.c4
-rw-r--r--code/fe310/eos/ecp.h3
-rw-r--r--code/fe310/eos/eos.c2
-rw-r--r--code/fe310/eos/spi.h4
-rw-r--r--code/test/client.c6
8 files changed, 20 insertions, 8 deletions
diff --git a/code/ecp/fe310/transport.c b/code/ecp/fe310/transport.c
index 9ff04ca..99a1b10 100644
--- a/code/ecp/fe310/transport.c
+++ b/code/ecp/fe310/transport.c
@@ -34,6 +34,7 @@ static ssize_t t_send(int *sock, ECPBuffer *packet, size_t msg_size, ECPNetAddr
if (packet && packet->buffer) buf = packet->buffer-addr_len;
} else {
buf = eos_net_alloc();
+ memcpy(buf+addr_len, packet->buffer, msg_size);
}
if (buf == NULL) return ECP_ERR;
memcpy(buf, addr->host, sizeof(addr->host));
diff --git a/code/esp32/components/eos/fe310.c b/code/esp32/components/eos/fe310.c
index 6dceb51..a3552f9 100644
--- a/code/esp32/components/eos/fe310.c
+++ b/code/esp32/components/eos/fe310.c
@@ -23,8 +23,8 @@
static EOSMsgQ send_q;
static EOSMsgItem send_q_array[EOS_FE310_SIZE_Q];
-#define SPI_GPIO_RTS 4
-#define SPI_GPIO_CTS 2
+#define SPI_GPIO_RTS 16
+#define SPI_GPIO_CTS 17
#define SPI_GPIO_MOSI 23
#define SPI_GPIO_MISO 19
#define SPI_GPIO_SCLK 18
@@ -92,7 +92,7 @@ static void worker(void *pvParameters) {
xSemaphoreTake(mutex, portMAX_DELAY);
} else {
- ESP_LOGI(TAG, "FE310 RECV NULL");
+ // ESP_LOGI(TAG, "FE310 RECV NULL");
}
// vTaskDelay(5000 / portTICK_PERIOD_MS);
}
diff --git a/code/esp32/components/eos/transport.c b/code/esp32/components/eos/transport.c
index 162fe86..9a9309c 100755
--- a/code/esp32/components/eos/transport.c
+++ b/code/esp32/components/eos/transport.c
@@ -60,7 +60,7 @@ static int t_open(void) {
memset((char *)&_myaddr, 0, sizeof(_myaddr));
_myaddr.sin_family = AF_INET;
_myaddr.sin_addr.s_addr = htonl(INADDR_ANY);
- _myaddr.sin_port = htons(0);
+ _myaddr.sin_port = htons(3000);
int rv = bind(udp_sock, (struct sockaddr *)&_myaddr, sizeof(_myaddr));
if (rv < 0) {
diff --git a/code/fe310/eos/ecp.c b/code/fe310/eos/ecp.c
index 433e693..190d1f0 100644
--- a/code/fe310/eos/ecp.c
+++ b/code/fe310/eos/ecp.c
@@ -63,4 +63,8 @@ int ecp_init(ECPContext *ctx) {
eos_evtq_set_handler(EOS_EVT_MASK_NET | EOS_NET_CMD_PKT, packet_handler);
return ECP_OK;
+}
+
+void ecp_sock_set(ECPSocket *s) {
+ _sock = s;
} \ No newline at end of file
diff --git a/code/fe310/eos/ecp.h b/code/fe310/eos/ecp.h
index 95aed31..9cc84db 100644
--- a/code/fe310/eos/ecp.h
+++ b/code/fe310/eos/ecp.h
@@ -1,3 +1,4 @@
#include <ecp/core.h>
-int ecp_init(ECPContext *ctx); \ No newline at end of file
+int ecp_init(ECPContext *ctx);
+void ecp_sock_set(ECPSocket *s); \ No newline at end of file
diff --git a/code/fe310/eos/eos.c b/code/fe310/eos/eos.c
index 3ad3b68..8dbfdac 100644
--- a/code/fe310/eos/eos.c
+++ b/code/fe310/eos/eos.c
@@ -13,5 +13,5 @@ void eos_init(void) {
}
void eos_start(void) {
- eos_net_start(15);
+ eos_net_start(255);
} \ No newline at end of file
diff --git a/code/fe310/eos/spi.h b/code/fe310/eos/spi.h
index 88e54bb..7e281b8 100644
--- a/code/fe310/eos/spi.h
+++ b/code/fe310/eos/spi.h
@@ -11,8 +11,8 @@
#define SPI_SIZE_BUF 1500
#define SPI_SIZE_CHUNK 4
#define SPI_SIZE_BUFQ 4
-#define SPI_GPIO_CTS_OFFSET PIN_2_OFFSET
-#define SPI_GPIO_RTS_OFFSET PIN_3_OFFSET
+#define SPI_GPIO_RTS_OFFSET PIN_8_OFFSET
+#define SPI_GPIO_CTS_OFFSET PIN_7_OFFSET
#define SPI_IOF_MASK (((uint32_t)1 << IOF_SPI1_SCK) | ((uint32_t)1 << IOF_SPI1_MOSI) | ((uint32_t)1 << IOF_SPI1_MISO))
typedef struct SPIBuffer {
diff --git a/code/test/client.c b/code/test/client.c
index 03b459f..3ec6eb7 100644
--- a/code/test/client.c
+++ b/code/test/client.c
@@ -36,6 +36,12 @@ ssize_t handle_open_c(ECPConnection *conn, ecp_seq_t sq, unsigned char t, unsign
ssize_t handle_msg_c(ECPConnection *conn, ecp_seq_t sq, unsigned char t, unsigned char *p, ssize_t s, ECP2Buffer *b) {
printf("MSG C:%s size:%ld\n", p, s);
+ char *msg = "PERA JE CAR!";
+ unsigned char buf[1000];
+
+ strcpy((char *)buf, msg);
+ ssize_t _rv = ecp_send(conn, MTYPE_MSG, buf, 1000);
+
return s;
}