【发布时间】：2014-10-09 11:39:27
【问题描述】：
我正在尝试通过蓝牙发送我的测量数据（温度、湿度和压力），它必须是连续的，所以我为此使用线程，但这对我来说太复杂了。
蓝牙客户端代码如下：
#include "defines.h"
void L2CAP_client(char *b_addr, float *temp, float *humi, float *pressure)
{
struct sockaddr_l2 addr = { 0 };
struct Measurement_Data *Thread_Data = malloc(sizeof(struct Measurement_Data));
int s, status;
char dest[18];
pthread_t Measurement_data_thread = 0;
int iret = 0;
pthread_t Thread_id;
strncpy(dest, b_addr, 18);
// allocate a socket
s = socket(AF_BLUETOOTH, SOCK_SEQPACKET, BTPROTO_L2CAP);
Thread_Data->s_ptr = s;
// set the connection parameters (who to connect to)
addr.l2_family = AF_BLUETOOTH;
addr.l2_psm = htobs(0x1001);
str2ba( dest, &addr.l2_bdaddr );
// connect to server
status = connect(s, (struct sockaddr *)&addr, sizeof(addr));
Thread_Data->temp = *temp;
Thread_Data->humi = *humi;
Thread_Data->pressure = *pressure;
// send a message
if( status == 0 ) {
iret = pthread_create(&Measurement_data_thread, NULL, &Thread_Function, (void*) &Thread_Data);
if(iret != 0){
perror("Thread creation failed\n");
}
Thread_id = pthread_self();
printf("ID of Temp_thread is: %u\n", (unsigned int)Thread_id);
}
if( status < 0 ) perror("uh oh");
printf("Thread 1 returns: %d\n",iret);
pthread_join(Measurement_data_thread, NULL);
close(s);
}
void *Thread_Function(void* Measurement_Data)
{
int s = 0;
struct Measurement_Data *Thread_Data = (struct Measurement_Data*) Measurement_Data;
s = Thread_Data->s_ptr;
send(s, &Thread_Data, sizeof(Thread_Data), 0);
free(Thread_Data);
//return 0;
}
这是蓝牙服务器代码：
#include "defines.h"
struct Measurement_Data *L2CAP_server(void)
{
struct sockaddr_l2 loc_addr = { 0 }, rem_addr = { 0 };
char buf[256] = { 0 };
int s, client, bytes_read;
int opt = sizeof(rem_addr);
static struct Measurement_Data Data;
struct Measurement_Data *Thread_Data = malloc(sizeof(struct Measurement_Data));
pthread_t Measurement_data_thread = 0;
int iret = 0;
pthread_t Thread_id;
// allocate socket
s = socket(AF_BLUETOOTH, SOCK_SEQPACKET, BTPROTO_L2CAP);
// bind socket to port 0x1001 of the first available
// bluetooth adapter
loc_addr.l2_family = AF_BLUETOOTH;
loc_addr.l2_bdaddr = *BDADDR_ANY;
loc_addr.l2_psm = htobs(0x1001);
bind(s, (struct sockaddr *)&loc_addr, sizeof(loc_addr));
// put socket into listening mode
listen(s, 1);
// accept one connection
client = accept(s, (struct sockaddr *)&rem_addr, &opt);
Thread_Data->c_ptr = client;
ba2str( &rem_addr.l2_bdaddr, buf );
fprintf(stderr, "accepted connection from %s\n", buf);
memset(buf, 0, sizeof(buf));
iret = pthread_create(&Measurement_data_thread, NULL, &Thread_Function, (void*) &Thread_Data);
if(iret != 0){
perror("Thread creation failed\n");
}
Thread_id = pthread_self();
printf("ID of Temp_thread is: %u\n", (unsigned int)Thread_id);
printf("Thread 1 returns: %d\n",iret);
pthread_join(Measurement_data_thread, NULL);
// close connection
close(client);
close(s);
return (&Data);
}
void *Thread_Function(void* Measurement_Data)
{
int c = 0;
struct Measurement_Data *Thread_Data = (struct Measurement_Data*) Measurement_Data;
c = Thread_Data->c_ptr;
recv(c, &Thread_Data, sizeof(Thread_Data), 0);
printf("Temp: %0.1f\n", Thread_Data->temp);
printf("Humi: %0.1f\n", Thread_Data->humi);
printf("Pres: %0.1f\n", Thread_Data->pressure);
free(Thread_Data);
//return 0;
}
它只发送零，我也收到此错误：* glibc detected * ./anturi_luku: munmap_chunk(): invalid pointer: 0xbef48738 ***
我需要使用互斥锁来锁定数据是对的吗？
【问题讨论】：
标签： bluetooth pthreads continuous