Add clear version of commit 72f30ad
.
This commit is contained in:
parent
e12077513f
commit
6178865cc6
16 changed files with 1044 additions and 0 deletions
22
examples/ds18b20_broadcaster/LICENSE
Normal file
22
examples/ds18b20_broadcaster/LICENSE
Normal file
|
@ -0,0 +1,22 @@
|
|||
The MIT License (MIT)
|
||||
|
||||
Copyright (c) 2016 Grzegorz Hetman : ghetman@gmail.com
|
||||
|
||||
Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
of this software and associated documentation files (the "Software"), to deal
|
||||
in the Software without restriction, including without limitation the rights
|
||||
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
||||
copies of the Software, and to permit persons to whom the Software is
|
||||
furnished to do so, subject to the following conditions:
|
||||
|
||||
The above copyright notice and this permission notice shall be included in all
|
||||
copies or substantial portions of the Software.
|
||||
|
||||
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
||||
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
||||
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
||||
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
||||
SOFTWARE.
|
||||
|
3
examples/ds18b20_broadcaster/Makefile
Normal file
3
examples/ds18b20_broadcaster/Makefile
Normal file
|
@ -0,0 +1,3 @@
|
|||
PROGRAM=ds18b20_broadcaster
|
||||
EXTRA_COMPONENTS = extras/onewire extras/ds18b20
|
||||
include ../../common.mk
|
20
examples/ds18b20_broadcaster/README.md
Normal file
20
examples/ds18b20_broadcaster/README.md
Normal file
|
@ -0,0 +1,20 @@
|
|||
# DS19B20 Broadcaster
|
||||
|
||||
>In this example you can see how to get data from multiple
|
||||
>ds18b20 sensor and emit result over udb broadcaster address.
|
||||
|
||||
As a client server, you can use this simple udp receiver, writen in python:
|
||||
|
||||
```
|
||||
import select, socket
|
||||
|
||||
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
|
||||
s.bind(('<broadcast>', 8005))
|
||||
s.setblocking(0)
|
||||
|
||||
while True:
|
||||
result = select.select([s],[],[])
|
||||
msg = result[0][0].recv(1024)
|
||||
print msg.strip()
|
||||
|
||||
```
|
118
examples/ds18b20_broadcaster/ds18b20_broadcaster.c
Normal file
118
examples/ds18b20_broadcaster/ds18b20_broadcaster.c
Normal file
|
@ -0,0 +1,118 @@
|
|||
#include <string.h>
|
||||
|
||||
#include "espressif/esp_common.h"
|
||||
#include "esp/uart.h"
|
||||
#include "FreeRTOS.h"
|
||||
#include "task.h"
|
||||
#include "timers.h"
|
||||
#include "queue.h"
|
||||
#include "lwip/api.h"
|
||||
#include "ssid_config.h"
|
||||
|
||||
// DS18B20 driver
|
||||
#include "ds18b20/ds18b20.h"
|
||||
// Onewire init
|
||||
#include "onewire/onewire.h"
|
||||
|
||||
void broadcast_temperature(void *pvParameters)
|
||||
{
|
||||
|
||||
uint8_t amount = 0;
|
||||
uint8_t sensors = 2;
|
||||
ds_sensor_t t[sensors];
|
||||
|
||||
// Use GPIO 13 as one wire pin.
|
||||
uint8_t GPIO_FOR_ONE_WIRE = 13;
|
||||
|
||||
char msg[100];
|
||||
|
||||
// Broadcaster part
|
||||
err_t err;
|
||||
// Initialize one wire bus.
|
||||
onewire_init(GPIO_FOR_ONE_WIRE);
|
||||
|
||||
while(1) {
|
||||
|
||||
// Send out some UDP data
|
||||
struct netconn* conn;
|
||||
|
||||
// Create UDP connection
|
||||
conn = netconn_new(NETCONN_UDP);
|
||||
|
||||
// Connect to local port
|
||||
err = netconn_bind(conn, IP_ADDR_ANY, 8004);
|
||||
|
||||
if (err != ERR_OK) {
|
||||
netconn_delete(conn);
|
||||
printf("%s : Could not bind! (%s)\n", __FUNCTION__, lwip_strerr(err));
|
||||
continue;
|
||||
}
|
||||
|
||||
err = netconn_connect(conn, IP_ADDR_BROADCAST, 8005);
|
||||
|
||||
if (err != ERR_OK) {
|
||||
netconn_delete(conn);
|
||||
printf("%s : Could not connect! (%s)\n", __FUNCTION__, lwip_strerr(err));
|
||||
continue;
|
||||
}
|
||||
|
||||
for(;;) {
|
||||
// Search all DS18B20, return its amount and feed 't' structure with result data.
|
||||
amount = readDS18B20(GPIO_FOR_ONE_WIRE, t);
|
||||
|
||||
if (amount < sensors){
|
||||
printf("Something is wrong, I expect to see %d sensors \nbut just %d was detected!\n", sensors, amount);
|
||||
}
|
||||
|
||||
for (int i = 0; i < amount; ++i)
|
||||
{
|
||||
// Multiple "" here is just to satisfy compiler and don`t raise 'hex escape sequence out of range' warning.
|
||||
sprintf(msg, "Sensor %d report: %d.%d ""\xC2""\xB0""C\n",t[i].id, t[i].major, t[i].minor);
|
||||
printf("%s", msg);
|
||||
|
||||
struct netbuf* buf = netbuf_new();
|
||||
void* data = netbuf_alloc(buf, strlen(msg));
|
||||
|
||||
memcpy (data, msg, strlen(msg));
|
||||
err = netconn_send(conn, buf);
|
||||
|
||||
if (err != ERR_OK) {
|
||||
printf("%s : Could not send data!!! (%s)\n", __FUNCTION__, lwip_strerr(err));
|
||||
continue;
|
||||
}
|
||||
netbuf_delete(buf); // De-allocate packet buffer
|
||||
}
|
||||
vTaskDelay(1000/portTICK_RATE_MS);
|
||||
}
|
||||
|
||||
err = netconn_disconnect(conn);
|
||||
printf("%s : Disconnected from IP_ADDR_BROADCAST port 12346 (%s)\n", __FUNCTION__, lwip_strerr(err));
|
||||
|
||||
err = netconn_delete(conn);
|
||||
printf("%s : Deleted connection (%s)\n", __FUNCTION__, lwip_strerr(err));
|
||||
|
||||
vTaskDelay(1000/portTICK_RATE_MS);
|
||||
}
|
||||
}
|
||||
|
||||
void user_init(void)
|
||||
{
|
||||
uart_set_baud(0, 115200);
|
||||
|
||||
printf("SDK version:%s\n", sdk_system_get_sdk_version());
|
||||
|
||||
// Set led to indicate wifi status.
|
||||
sdk_wifi_status_led_install(2, PERIPHS_IO_MUX_GPIO2_U, FUNC_GPIO2);
|
||||
|
||||
struct sdk_station_config config = {
|
||||
.ssid = WIFI_SSID,
|
||||
.password = WIFI_PASS,
|
||||
};
|
||||
|
||||
// Required to call wifi_set_opmode before station_set_config.
|
||||
sdk_wifi_set_opmode(STATION_MODE);
|
||||
sdk_wifi_station_set_config(&config);
|
||||
|
||||
xTaskCreate(&broadcast_temperature, (signed char *)"broadcast_temperature", 256, NULL, 2, NULL);
|
||||
}
|
||||
|
Loading…
Add table
Add a link
Reference in a new issue