Chat Tool Over TCP/IP

わけのわからないままに、作ってみました。

プロトタイプです。

先ずはデッドコピーでも良いから、動かすことから入ります。

その後は、なぜなぜで解析します。

以下私の環境での例です。

$ mkdir -p ~/ecos/chat

$ cd ecos/chat

ここにchat.cを置く。

$ SRCS=chat.c DST=chat ./build_Makefile ../httpd_kernel
$ make
$ h8300-elf-objcopy -O srec chat chat.srec

で生成された .srecファイルを

ＲｅｄＢｏｏｔで

RedBoot>load -h 192.168.0.26 -b 0x400000 chat.srec

としてＮＩＣ（AKI-H8/3069F）のＲＡＭにロードします。

ロードが完了したら、ＲｅｄＢｏｏｔから

RedBoot>go 0x400000

で、Tera Term（クライアント）からTelnet でＮＩＣのポート　7734に接続します。

buf[256]を使ってのhalf duplexで、相互（クライアント-サーバー間）にメッセージを交換します。

tv.tv_sec と tv.tv_usecで設定したタイムアウト時間内にクライアント側から入力がないと、

for(;;)のループから抜けてクライアント-サーバー間のコネクションが切れます。

コネクションをキープしたい場合は、サーバー側（AKI-H8/3069F）で入力待ち状態にします。

Note:サーバー側からのSCI1からの入力にはscanf()を使っているので、スペースは入力終端

　　　コードと見做されます。

//==========================================================================

//
// chat.c
//
// Simple TCP Chat 'Server' test
//
//==========================================================================
// ####BSDALTCOPYRIGHTBEGIN####
// -------------------------------------------
// Portions of this software may have been derived from FreeBSD, OpenBSD,
// or other sources, and if so are covered by the appropriate copyright
// and license included herein.
// -------------------------------------------
// ####BSDALTCOPYRIGHTEND####
//==========================================================================
//#####DESCRIPTIONBEGIN####
//
// Author(s): gthomas
// Contributors: gthomas
// Date: 2000-01-10
// Purpose:
// Description: modified by jk1brk, last update 2019/12/28
//
//####DESCRIPTIONEND####
//
//==========================================================================
// Network server test code
#include <stdio.h>
#include <stdlib.h>
#include <network.h>

#ifndef CYGPKG_LIBC_STDIO
#define perror(s) diag_printf(#s ": %s\n", strerror(errno))
#endif

#define STACK_SIZE (CYGNUM_HAL_STACK_SIZE_TYPICAL + 0x1000)
static char stack[STACK_SIZE];
static cyg_thread thread_data;
static cyg_handle_t thread_handle;

extern void
cyg_test_exit(void);

void
pexit(char *s)
{
perror(s);
cyg_test_exit();
}

static void
server_test(struct bootp *bp)
{
int s, client;
socklen_t client_len;
struct sockaddr_in client_addr, local;
char buf[256], sbuf[256];
int one = 1;
fd_set in_fds;
int num, len;
struct timeval tv;

s = socket(AF_INET, SOCK_STREAM, 0);
if (s < 0) {
pexit("stream socket");
}
if (setsockopt(s, SOL_SOCKET, SO_REUSEADDR, &one, sizeof(one))) {
pexit("setsockopt SO_REUSEADDR");
}
if (setsockopt(s, SOL_SOCKET, SO_REUSEPORT, &one, sizeof(one))) {
pexit("setsockopt SO_REUSEPORT");
}
memset(&local, 0, sizeof(local));
local.sin_family = AF_INET;
local.sin_len = sizeof(local);
local.sin_port = htons(7734);               // remenber chat server port as 7734
local.sin_addr.s_addr = INADDR_ANY;
if(bind(s, (struct sockaddr *) &local, sizeof(local)) < 0) {
pexit("bind error");
}

listen(s, SOMAXCONN);
while (true) {
client_len = sizeof(client_addr);
if ((client = accept(s, (struct sockaddr *)&client_addr, &client_len)) < 0) {
pexit("accept");
}
client_len = sizeof(client_addr);
getpeername(client, (struct sockaddr *)&client_addr, &client_len);
diag_printf("connection from %s:%d\n", inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));

diag_sprintf(buf, "Hello %s:%d\n\r", inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));

   for(;;) {
       write(client, buf, strlen(buf));       // write to client
diag_sprintf(buf, "\rClient turns to type:");
write(client, buf , strlen(buf));

   tv.tv_sec = 50;                   // set time out
   tv.tv_usec = 0;
   FD_ZERO(&in_fds);
   FD_SET(client, &in_fds);

   num = select(client+1, &in_fds, 0, 0, &tv);
   if (num > 0) {
   len = read(client, buf, sizeof(buf)-1);   // read from client
      buf[len] = '\0';
   diag_printf("Client says = %s\n", buf);
write(client, buf , strlen(buf)); // echo back to client
   } else if (num == 0) {
   diag_printf("No reply - timed out\n");
break;
   } else {
perror("select");
   }
   diag_printf("Server turns to type:");
scanf("%s", sbuf); // scan at server
diag_sprintf(buf, "\n\rServer says = %s\n\r", sbuf);
}
close(client);
}
close(s);
}

void
net_test(cyg_addrword_t param)
{
diag_printf("Start chat SERVER test\n");
init_all_network_interfaces();
#ifdef CYGHWR_NET_DRIVER_ETH0
if (eth0_up) {
server_test(&eth0_bootp_data);
}
#endif
cyg_test_exit();
}

void
cyg_start(void)
{
// Create a main thread, so we can run the scheduler and have time 'pass'
cyg_thread_create(10, // Priority - just a number
net_test, // entry
0, // entry parameter
"Chat test",     // Name
&stack[0], // Stack
STACK_SIZE, // Size
&thread_handle, // Handle
&thread_data // Thread data structure
);
cyg_thread_resume(thread_handle);     // Start it
cyg_scheduler_start();
}

https://ameblo.jp/kissam59/entry-12539704336.html

https://ameblo.jp/kissam59/entry-12555521601.html

https://docs.freebsd.org/44doc/psd/20.ipctut/paper.pdf