mainscnt/mains-frequency-counter-rpi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

some fixes

Browse Source
This commit is contained in:
Wolfgang Hottgenroth
2021-03-04 17:36:18 +01:00
parent 7d60c537f9
commit 7e80a6d160
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/sinkSender.c
View File

@ -19,8 +19,8 @@ const char SINKSERVER_KEY[] = "sinkServer";
const char DEFAULT_SINKSERVER[] = "sink.hottis.de"; const char DEFAULT_SINKSERVER[] = "sink.hottis.de";
const char *sinkServer; const char *sinkServer;
const char SINKPORT_KEY[] = "sinkPort"; const char SINKPORT_KEY[] = "sinkPort";
const uint16_t DEFAULT_SINKPORT = 20169; const int DEFAULT_SINKPORT = 20169;
uint16_t sinkPort; int sinkPort;
const char DEVICE_ID_KEY[] = "deviceId"; const char DEVICE_ID_KEY[] = "deviceId";
const char DEFAULT_DEVICE_ID[] = "mainscnt00"; const char DEFAULT_DEVICE_ID[] = "mainscnt00";
const char *deviceId; const char *deviceId;
@ -90,8 +90,9 @@ void sinkSenderPut(uint32_t seconds, uint32_t frequency) {
struct hostent *hptr = gethostbyname(sinkServer); struct hostent *hptr = gethostbyname(sinkServer);
if (hptr) { if (hptr) {
if (hptr->h_addrtype == AF_INET) { if (hptr->h_addrtype == AF_INET) {
uint8_t *sinkAddr = hptr->h_addr_list[0]; char *sinkAddr = hptr->h_addr_list[0];
logmsg(LOG_DEBUG, "sink addr: %d.%d.%d.%d", sinkAddr[0], sinkAddr[1], sinkAddr[2], sinkAddr[3]); logmsg(LOG_DEBUG, "sink addr: %d.%d.%d.%d",
sinkAddr[0], sinkAddr[1], sinkAddr[2], sinkAddr[3]);
int sockfd = socket(AF_INET, SOCK_DGRAM, 0); int sockfd = socket(AF_INET, SOCK_DGRAM, 0);
if (sockfd != -1) { if (sockfd != -1) {
@ -101,7 +102,9 @@ void sinkSenderPut(uint32_t seconds, uint32_t frequency) {
servaddr.sin_port = htons(sinkPort); servaddr.sin_port = htons(sinkPort);
memcpy(&servaddr.sin_addr.s_addr, sinkAddr, 4); memcpy(&servaddr.sin_addr.s_addr, sinkAddr, 4);
ssize_t res = sendto(sockfd, minuteBuffer.b, sizeof(minuteBuffer.b), 0, &servaddr, sizeof(servaddr)); ssize_t res = sendto(sockfd, minuteBuffer.b, sizeof(minuteBuffer.b),
0, (struct sockaddr*)&servaddr,
sizeof(servaddr));
logmsg(LOG_DEBUG, "%d octets sent", res); logmsg(LOG_DEBUG, "%d octets sent", res);
} else { } else {
logmsg(LOG_ERR, "unable to get socket: %s", strerror(errno)); logmsg(LOG_ERR, "unable to get socket: %s", strerror(errno));