github/chiaki
1
0
Fork 0
mirror of https://git.sr.ht/~thestr4ng3r/chiaki synced 2025-08-21 14:03:11 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

Implement Discovery Thread

Browse source
This commit is contained in:
Florian Märkl 2019-06-14 13:18:40 +02:00
commit 13ddd88c89
No known key found for this signature in database
GPG key ID: 125BC8A5A6A1E857
1 changed files with 32 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

33
lib/src/discovery.c
View file

@ -144,8 +144,39 @@ CHIAKI_EXPORT ChiakiErrorCode chiaki_discovery_thread_stop(ChiakiDiscoveryThread
static void *discovery_thread_func(void *user) static void *discovery_thread_func(void *user)
{ {
ChiakiDiscoveryThread *thread = user; ChiakiDiscoveryThread *thread = user;
ChiakiDiscovery *discovery = thread->discovery;
// TODO while(1)
{
ChiakiErrorCode err = chiaki_stop_pipe_select_single(&thread->stop_pipe, discovery->socket, NULL);
if(err == CHIAKI_ERR_CANCELED)
break;
if(err != CHIAKI_ERR_SUCCESS)
{
CHIAKI_LOGE(discovery->log, "Discovery thread failed to select\n");
break;
}
char buf[512];
struct sockaddr client_addr;
socklen_t client_addr_size = sizeof(client_addr);
ssize_t n = recvfrom(discovery->socket, buf, sizeof(buf) - 1, 0, &client_addr, &client_addr_size);
if(n < 0)
{
CHIAKI_LOGE(discovery->log, "Discovery thread failed to read from socket\n");
break;
}
if(n == 0)
continue;
if(n > sizeof(buf) - 1)
n = sizeof(buf) - 1;
buf[n] = '\00';
CHIAKI_LOGD(discovery->log, "Discovery received:\n%s\n", buf);
}
return NULL; return NULL;
} }