1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
|
/*
* (c) BayCom GmbH, http://www.baycom.de, info@baycom.de
*
* See the COPYING file for copyright information and
* how to reach the author.
*
*/
#include "headers.h"
static netceiver_info_list_t nc_list;
static pthread_mutex_t nci_lock=PTHREAD_MUTEX_INITIALIZER;
static netceiver_info_t *nci_find_unique (netceiver_info_list_t * ncl, char *uuid)
{
int i;
for (i = 0; i < ncl->nci_num; i++) {
if (!strcmp (ncl->nci[i].uuid, uuid)) {
return ncl->nci + i;
}
}
return NULL;
}
static void nci_free(netceiver_info_t * nc_info)
{
int i, j;
for (i = 0; i < nc_info->sat_list_num; i++) {
satellite_list_t *sat_list = nc_info->sat_list + i;
for (j = 0; j < sat_list->sat_num; j++) {
satellite_info_t *sat = sat_list->sat + j;
free (sat->comp);
}
free (sat_list->sat);
}
free (nc_info->sat_list);
free (nc_info->tuner);
}
static int nci_add_unique (netceiver_info_list_t * ncl, netceiver_info_t * nci)
{
netceiver_info_t *ncf=nci_find_unique (ncl, nci->uuid);
if (!ncf) {
ncl->nci = (netceiver_info_t *) realloc (ncl->nci, sizeof (netceiver_info_t) * (ncl->nci_num + 1));
if (!ncl->nci) {
err ("Cannot get memory for netceiver_info\n");
}
memcpy (ncl->nci + ncl->nci_num, nci, sizeof (netceiver_info_t));
(ncl->nci+ncl->nci_num)->lastseen = time(NULL);
ncl->nci_num++;
return 1;
} else {
nci_free(ncf);
memcpy(ncf, nci, sizeof (netceiver_info_t));
ncf->lastseen = time(NULL);
}
return 0;
}
netceiver_info_list_t *nc_get_list(void)
{
return &nc_list;
}
int nc_lock_list(void)
{
return pthread_mutex_lock (&nci_lock);
}
int nc_unlock_list(void)
{
return pthread_mutex_unlock (&nci_lock);
}
void handle_tca (netceiver_info_t * nc_info)
{
nc_lock_list();
if (nci_add_unique (&nc_list, nc_info)) {
dbg ("New TCA from %s added\n", nc_info->uuid);
}
nc_unlock_list();
}
|
