lan to serial, serial to lan 중간에 블럭이 안되게
몇일전에 올렸던 질문인데 무플이라..ㅡㅡ; 다시 올림니다.
질문에 문제가 있다면 조언 부탁드립니다.
-------------------------------------------------------------------------
제가 하려는 작업은 이더넷과 시리얼 로 서로 데이터를 주고 받고 하는 겁니다.
그런데 tcp/ip에서 시리얼로는 데이터가 잘가는데요.
시리얼에서 tcp/ip로 보낼때는 tcp/ip에서 한바이트 정보를 보내야 시리얼에서 보낸데이터를 받을수 있습니다.
시리얼 통신부분은 kldp에 있는 how to serial 문서를 참고 했구요.
serial_init() 함수에 있는 아래 인자의 값을 수정해서 블럭되지 않도록 했거든요.
newtio.c_lflag = 0;
newtio.c_cc[VTIME] = 0; /* inter-character timer unused */
newtio.c_cc[VMIN] = 0; /* blocking read until 1 character arrives */
serial에서 이더넷으로만 정보를 보낼때는 블럭되지 않고 잘가거든요.(아래 루프문 참고)
while(1)
{
str_len=read(fd, message,BUFSIZE);
write(clnt_sock, message, str_len);
}
근데 양방향으로 할려니 잘 안되네요. 고수님들 도움 바랍니다....
-----------------------------------------------------------------------------------------------
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include "setup.h"
#define BAUDRATE B38400
#define MODEMDEVICE "/dev/ttyS1"
#define _POSIX_SOURCE 1 /* POSIX 호환 소스 */
#define FALSE 0
#define TRUE 1
volatile int STOP=FALSE;
int fd;
int baud;
#define BUFSIZE 255
void error_handling(char *message);
struct termios oldtio,newtio;
void serial_init(int idx)
{
int c, res;
char buf[255];
load();
baud = bps_bit[App[idx].SI.bps];
s_port = App[idx].s_port;
c_ip = App[idx].c_ip;
c_port = App[idx].c_port;
s_mode = App[idx].s_mode;
se_dev= App[idx].SI.device;
printf(" device : %s, baud :%s, sport %s, cip %s, cport %s , mode %d \n",se_dev, bps_str[App[idx].SI.bps], s_port, c_ip, c_port, s_mode);
fd = open(se_dev, O_RDWR | O_NOCTTY | O_NONBLOCK );
if (fd \n", argv[0]);
exit(1);
}
*/
serial_init(index);
serv_sock= socket(AF_INET, SOCK_STREAM, 0);
if (serv_sock == -1)
error_handling("socket() error");
memset(&serv_addr, 0, sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
// serv_addr.sin_port = htons(atoi(argv[1]));
serv_addr.sin_port = htons(atoi(s_port));
if(bind(serv_sock, (struct sockaddr*)&serv_addr, sizeof(serv_addr))== -1)
error_handling("bind() error");
if(listen(serv_sock, 5) == -1)
error_handling("listen() error");
clnt_addr_size = sizeof(clnt_addr);
clnt_sock = accept(serv_sock, (struct sockaddr*)& clnt_addr,(socklen_t*) &clnt_addr_size);
if(clnt_sock == -1)
error_handling("accept() error");
while(1){
str_len=read(clnt_sock, message, BUFSIZE);
write(fd, message, str_len);
str_len=read(fd, message,BUFSIZE);
write(clnt_sock, message, str_len);
}
tcsetattr(fd,TCSANOW,&oldtio);// restore
close(clnt_sock);
return 0;
}
while(1) 부분이 →
while(1) 부분이 → 방향의 흐름과 ← 방향의 흐름을 번갈아가며 처리하고 있기 때문에 한쪽에서 다른쪽으로 데이터가 넘어가지 않으면 다른 방향은 블럭됩니다. 동시에 두 방향을 모두 처리할 수 있도록 그 부분을 스레드로 따로 빼시거나, select를 사용하세요.
음..
리눅스에서 스레드 기법이 있나요. select는 알겠는데..
http://wiki.kldp.org/wiki.php/LinuxdocSgml/Serial-Programming-HOWTO
문서를 참고 했구요. 여기서 3.4 입력 장치 멀티플렉싱에서 select를 이용한 예제가 있는데
파일 디스크립트를 이용해서 제어 하는데 소켓은 파일 디스크립트가 아닌거 같거든요
"select() 시스템 호출 함수와 해당하는 매크로 함수들은 fd_set을 사용한다. fd_set는 bit array로서 file descriptor의 bit entry로 작용한다. select()는 해당하는 file descriptor의 bit들을 세팅한 fd_set을 입력 파라미터로 받아서 입력, 출력 혹은 예외 발생이 일어난 경우 리턴한다."
라고 하는데 소켓도 이런형식으로 처리 가능 한지 답변 부탁드립니다.
--------------------------------------------------------------------
main()
{
int fd1, fd2; /* input sources 1 and 2 */
fd_set readfs; /* file descriptor set */
int maxfd; /* maximum file desciptor used */
int loop=1; /* loop while TRUE */
/* open_input_source opens a device, sets the port correctly, and
returns a file descriptor */
fd1 = open_input_source("/dev/ttyS1"); /* COM2 */
if (fd1<0) exit(0);
fd2 = open_input_source("/dev/ttyS2"); /* COM3 */
if (fd2<0) exit(0);
maxfd = MAX (fd1, fd2)+1; /* maximum bit entry (fd) to test */
/* loop for input */
while (loop) {
FD_SET(fd1, &readfs); /* set testing for source 1 */
FD_SET(fd2, &readfs); /* set testing for source 2 */
/* block until input becomes available */
select(maxfd, &readfs, NULL, NULL, NULL);
if (FD_ISSET(fd1, &readfs)) /* input from source 1 available */
handle_input_from_source1();
if (FD_ISSET(fd2, &readfs)) /* input from source 2 available */
handle_input_from_source2();
}
}
----------------------------------------------------------
파일 디스크립트는 가능할거 같은데 소켓 핸들러도 가능 한가요?
소켓 핸들도
소켓 핸들도 파일디스크립터의 일종이기 때문에 동일하게 select를 사용할 수 있습니다.
리눅스에서 스레드 쓰기는 pthread 로 검색해 보시면 이것저것 찾으실 수 있을 겁니다.
^^
와우 빠른 답변 감사 합니다. 4분만에 답변달아 주시다닝
퇴근 하면 바로 해봐야 겠네요.. 회사는 리눅스가 없어설 ㅎㅎ.
바로 밑에 씌어져
바로 밑에 씌어져 있는 글입니다.
댓글 달기