diff --git a/project.txt b/project.txt new file mode 100644 index 0000000000000000000000000000000000000000..6a959813d2734d16bd2b821bd1feb94a914a80a2 --- /dev/null +++ b/project.txt @@ -0,0 +1,212 @@ +#include <wiringPi.h> // wiringPi 라이브러리 사용 +#include <stdio.h> // 표준입출력용 라이브러리 +#include <stdlib.h> // 표준 유틸리티용 라이브러리 +#include <stdint.h> // 정수 자료형 라이브러리 + +#include <fcntl.h> +#include <sys/stat.h> +#include <sys/types.h> +#include <unistd.h> + +#include <string.h> +#include <unistd.h> +#include <arpa/inet.h> +#include <pthread.h> + +#define MAX_TIMINGS 85 // 최대 신호 추출 개수 +#define DHT_PIN 4 // GPIO로 사용할 핀 번호 + +#define IN 0 +#define OUT 1 +#define LOWS 0 +#define HIGH 1 +#define POUT 17 +#define VALUE_MAX 40 +#define DIRECTION_MAX 128 + +#define MAX_BUFFER_SIZE 256 +// 입력 및 출력을 처리하는 두 개의 스레드 생성 +char buffer[MAX_BUFFER_SIZE]; +char end[2]=""; +int limit_temperature = 25; // 최고 온도 +int limit_humidity = 40; // 최고 습도 +int data[5] = { 0, 0, 0, 0, 0 }; // 온습도 및 checksum 데이터 저장용 변수 배열 + +// 에러 메시지 출력 및 프로그램 종료 함수 +void error_handling(char *message) { + fputs(message, stderr); + fputc('\n', stderr); + exit(1); +} + +static int GPIOWrite(int pin, int value) { + static const char s_values_str[] = "01"; + + char path[VALUE_MAX]; + int fd; + + snprintf(path, VALUE_MAX, "/sys/class/gpio/gpio%d/value", pin); + fd = open(path, O_WRONLY); + if (-1 == fd) { + // fprintf(stderr, "Failed to open gpio value for writing!\n"); + return (-1); + } + + if (1 != write(fd, &s_values_str[LOWS == value ? 0 : 1], 1)) { + fprintf(stderr, "Failed to write value!\n"); + return (-1); + } + + close(fd); + return (0); +} + +void LED_GPIO(){ + int repeat = 2; + do { + GPIOWrite(POUT, repeat); + usleep(1000 * 1000); + } while(repeat--); +} + +void read_dht_data() { // dht데이터 읽기 함수 + + uint8_t laststate = HIGH; // DHT핀의 상태 저장용 변수(현재 신호가 HIGH인지 LOW인지 확인하기 위한 용도) + uint8_t counter = 0; // 신호의 길이를 측정하기 위한 카운터 변수 + uint8_t j = 0, i; // 40개의 신호 인덱스 용 변수 + + data[0] = data[1] = data[2] = data[3] = data[4] = 0; //초기 데이터 값은 0으로 지정 + + /* DHT11센서와의 통신을 개시하기 위해 DATA핀을 18ms동안 LOW로 출력 */ + pinMode(DHT_PIN, OUTPUT); + digitalWrite(DHT_PIN, 0); + delay(18); + digitalWrite(DHT_PIN, 1); + delayMicroseconds(40); + pinMode(DHT_PIN, INPUT); + + /* 핀을 입력모드로 설정해서 DHT11로 부터 응답을 기다림 */ + pinMode(DHT_PIN, INPUT); + + /* DHT11에서 오는 신호 검출 및 데이터비트 추출 */ + for (i = 0; i < MAX_TIMINGS; i++) // 총 85번 동안 신호를 확인 + { + counter = 0; // 초기 카운터는 0 + while (digitalRead( DHT_PIN ) == laststate) { //DHT핀의 신호를 읽어서 현재 지정한 DATA핀 신호와 같은 동안==즉 신호의 변환이 없는 동안 + + counter++; + delayMicroseconds(1); + if (counter == 255) // 즉 너무 오래 동안 대기하면==오류가 생겼다는 의미 임 + { + break; + } + } + laststate = digitalRead(DHT_PIN); // 현재 핀 상태 저장 + + if (counter == 255) // 카운터가 255이상 도달했다면, 데이터비트 수신 중지== for문 밖으로 나가서 처음부터 새로 받겠다는 의미임 + break; + + /* 첫번째 3개의 신호는 무시하고 짝수번째에 해당하는 신호길이를 읽어 0인지 1인지에 따라 온습도 변수에 저장 + 첫번째 3개의 신호는 DHT11의 응답 용 신호로 실제 데이터 길이를 통해 정보를 수신하는 값이 아니므로 무시함. + 짝수만 추출하는 이유는 짝수 번째의 신호 길이에 따라 해당 신호가 0을 의미하는지 1을 의미하는지를 나타냄. + */ + if ((i >= 4) && (i % 2 == 0)) + { + /* 가각의 데이터 비트를 온도 및 습도 변수에 하나씩 넣어줌 */ + data[j / 8] <<= 1; // 이진수의 자리수를 하나씩 옆으로 이동시킴 + if ( counter > 16 ) // 카운터의 값이 16보다 크다면, 즉 신호의 길이가 길어서 비트 1로 인식된다면 + data[j / 8] |= 1; // 해당 비트는 1을 넣어줌 + j++; // 다음 데이터를 위해 인덱스 값을 하나 증가 시킴 + } + } + + /* + * 40비트를 다 확인했다면 (8비트 x 5 ) 체크섬 데이터와 오류체크를 해서 + * 오류가 없으면 데이터를 출력함. + */ + if ((j >= 40) && (data[4] == ((data[0] + data[1] + data[2] + data[3]) & 0xFF))) { //에러가 없으면 습도 및 온도 출력 + printf( "Humidity = %d.%d %% Temperature = %d.%d C\n", data[0], data[1], data[2], data[3]); + if(data[2] >= limit_temperature){ //최고 온도 및 최고 습도를 넘을 경우, 온습도기 실행 + printf("temperature over\n"); + LED_GPIO(); + } + if(data[0] >= limit_humidity){ + printf("humidity over\n"); + LED_GPIO(); + } + }else { + printf("Data not good, skip\n"); //에러 발생시 Data not good 메시지 출력 + } +} + +void *thread_socket_to_output() { + + while (1){ + read_dht_data(); // 온도 및 습도 데이터 획득 및 출력 + delay( 1000 ); // 다음 읽기까지 2초 대기 + + if(strcmp(end, "e") == 0) { + LED_GPIO(); + break; + } + } +} + +void *read_func(void *arg) { + int client_socket = *(int *)arg; + while(1){ + int str_len = read(client_socket, buffer, sizeof(buffer)); + if (strcmp(buffer, "e") == 0){ + strcpy(end, "e"); + break; + } + } +} + +int main(int argc, char *argv[]) +{ + int client_socket; + struct sockaddr_in server_address; + int thr_id; + int status; + pthread_t p_thread[2]; + printf( "Raspberry Pi DHT11 temperature/humidity test\n" ); + + if ( wiringPiSetupGpio() == -1 ) //라즈베리파이의 BCM GPIO 핀번호를 사용하겠다고 선언 + exit( 1 ); + + // 클라이언트 소켓 생성 + client_socket = socket(PF_INET, SOCK_STREAM, 0); + if (client_socket == -1) error_handling("socket() error"); + + // 서버 주소 설정 + memset(&server_address, 0, sizeof(server_address)); + server_address.sin_family = AF_INET; + server_address.sin_addr.s_addr = inet_addr(argv[1]); + server_address.sin_port = htons(atoi(argv[2])); + + // 서버에 연결 + if (connect(client_socket, (struct sockaddr *)&server_address, sizeof(server_address)) == -1) + error_handling("connect() error"); + + printf("Connected to server\n"); + + while(1){ + int str_len = read(client_socket, buffer, sizeof(buffer)); + + if (strcmp(buffer, "s") == 0){ + thr_id = pthread_create(&p_thread[0], NULL, read_func, &client_socket); + if (thr_id < 0) error_handling("thread create error : "); + + thr_id = pthread_create(&p_thread[1], NULL, thread_socket_to_output, NULL); + if (thr_id < 0) error_handling("thread create error : "); + + // 스레드가 종료될 때까지 대기 + pthread_join(p_thread[0], (void **)&status); + pthread_join(p_thread[1], (void **)&status); + break; + } + } + + return(0); +}