Subversion Repositories shark

/*

 * Project: S.Ha.R.K.

 *

 * Coordinators:

 *   Giorgio Buttazzo    <giorgio@sssup.it>

 *   Paolo Gai           <pj@gandalf.sssup.it>

 *

 * Authors     :

 *   Paolo Gai           <pj@gandalf.sssup.it>

 *   (see the web pages for full authors list)

 *

 * ReTiS Lab (Scuola Superiore S.Anna - Pisa - Italy)

 *

 * http://www.sssup.it

 * http://retis.sssup.it

 * http://shark.sssup.it

 */

/*

 * Copyright (C) 2000 Luca Abeni, Paolo Gai

 *

 * This program is free software; you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation; either version 2 of the License, or

 * (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

 *

 *

 * CVS :        $Id: aster1.c,v 1.1 2002/10/28 08:13:37 pj Exp

 This is the talkdx.c Hartik's example.

 File:        Talk.C

 Revision:    1.00

 Author:      Luca Abeni

   Simple Netlib demo: nothing of seriously real-time, only another Unix

   Talk clone.

   Read it to see how the UDP/IP layers of the networ library work.

*/

#include <kernel/kern.h>

#include <string.h>

#include <drivers/crtwin.h>

#include <drivers/shark_keyb26.h>

#include <drivers/udpip.h>

WIN dbg;

BYTE esc = FALSE;

char talk_myipaddr[20];

char talk_toipaddr[20];

/*

   This non real-time task reads UDP packets from the network and writes

   them in a window

*/

TASK scrittore(void)

{

  char str[2000];

  UDP_ADDR from, local;

  WIN displ;

  int s,n;

  /* Connect on the local port #100 */

  local.s_port = 100;

  s = udp_bind(&local, NULL);

  /* Open the window */

  win_init(&displ,0,0,79,6);

  win_frame(&displ,BLACK,WHITE,"Remote",2);

  while (1) {

    /* Clear the buffer for receiving the packet...*/

    memset(str, 0, 1999);

    /*...and receive the packet (block until a packet arrives */

    n = udp_recvfrom(s, str, &from);

    win_puts(&displ, str);

  }

}

/*

   This non real-time task reads strings from the keyoard and sends them

   to the remote host

*/

TASK write(void)

{

  WIN wr;

  UDP_ADDR to,local;

  char str[80],tmp[5],ch;

  int s;

  IP_ADDR bindlist[5];

  win_init(&wr,0,7,79,6);

  win_frame(&wr,BLACK,WHITE,"Local",2);

  /* Create a socket for transitting */

  ip_str2addr(talk_myipaddr,&(local.s_addr));

  local.s_port = 101;

  /*

    If we want the address of the remote host in the ARP table before

    begginning the transmission (to eliminate a possible source of

    unpredictability), we can use the bindlist, otherwise we set the

    second parameter of udp_bind to NULL

  */

  ip_str2addr(talk_toipaddr,&(bindlist[0]));

  memset(&(bindlist[1]), 0, sizeof(IP_ADDR));

  s = udp_bind(&local, /*bindlist*/NULL);

  ip_str2addr(talk_toipaddr,&(to.s_addr));

  to.s_port = 100;

  sprintf(str,"Local IP address %d.%d.%d.%d\n", local.s_addr.ad[0],

          local.s_addr.ad[1], local.s_addr.ad[2],

          local.s_addr.ad[3]);

  win_puts(&dbg,str);

  sprintf(str,"Talk to %d.%d.%d.%d   ",to.s_addr.ad[0],to.s_addr.ad[1],

          to.s_addr.ad[2],to.s_addr.ad[3]);

  win_puts(&dbg,str);

  while (1) {

    /* Get the string...*/

    while((ch = keyb_getch(BLOCK)) != 13) {

        sprintf(tmp,"%c",ch);

        strcat(str,tmp);

        win_puts(&wr,tmp);

    }

    strcat(str,"\n");

    win_puts(&wr,"\n");

    /*...and send it!!! */

    udp_sendto(s,str,strlen(str)+2,&to);

    str[0] = 0;

  }

}

/* This function is called when the user presses CTRL-C (stops the systems) */

void esci(KEY_EVT *k)

{

  esc = TRUE;

  exit(1);

}

int main(int argc, char **argv)

{

  KEY_EVT k;

  struct net_model m = net_base;

  NRT_TASK_MODEL m_nrt;

  k.flag = CNTL_BIT;

  k.scan = KEY_C;  

  k.ascii = 'c';

  k.status = KEY_PRESSED;

  keyb_hook(k,esci,FALSE);

  k.flag = CNTR_BIT;

  k.scan = KEY_C;  

  k.ascii = 'c';

  k.status = KEY_PRESSED;

  keyb_hook(k,esci,FALSE);

  clear();

  cprintf(" S.Ha.R.K. Talk!                     Ver. 1.10\n");

  if (argc != 3) {

    cprintf("S.Ha.R.K. Talk usage: talk fromIP toIP\n");

    return 0;

  }

  strcpy(talk_myipaddr, argv[1]);

  strcpy(talk_toipaddr, argv[2]);

  /* We want a task for TX mutual exclusion */

  net_setmode(m, TXTASK);

  /* We use UDP/IP stack */

  net_setudpip(m, talk_myipaddr, "255.255.255.255");

  /* OK: let's start the NetLib! */

  if (net_init(&m) == 1) {

    cprintf("Net Init OK...\n");

  } else {

    cprintf("Net Init Failed...\n");

    exit(300);

  }

  //dump_irq();

  cprintf("\n\n\n\tPress ENTER\n");

  while (!esc) {

    keyb_getcode(&k,BLOCK);

    if (k.ascii == 13) esc = TRUE;

  }

  esc = FALSE;

  clear();

  win_init(&dbg,0,20,60,3);

  win_frame(&dbg,BLACK,WHITE,"Debug",2);

  /* Start the sender and receiver tasks...*/

  nrt_task_default_model(m_nrt);

  task_activate(task_create("aaa",scrittore,&m_nrt,NULL));

  task_activate(task_create("bbb",write,&m_nrt,NULL));

  return 0;

}