---

NetCommon.c

Go to the documentation of this file.

/*
 *    gui - [gega user interface] the flexible solution for user interface problems
 *    Copyright (C) 2002  Gergely Gati
 *
 *    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; version 2 of the License.
 *
 *    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
 *
 *    Gergely Gati
 *      email:           g.gati@freemail.hu
 *      AIM screenname:  GatiGergely
 *      ICQ number:      93131690
 *
 */
#include <stdlib.h>
#include <string.h>

#include "debug.h"
#include "Memory.h"
#include "xml_Gui.h"
#include "NetCommon.h"



/*
static char *msgnames[1024];
static char *msgtypes[]=
{
  " -  ***ILLEGAL",
  " - S NONE",
  " - C NONE",
  " - S ECHO",
  " - C ECHO",
  " - S LOADFILE",
  " - S WINEVENT",
  " - S APP",
  " - C CALLGAD",
  " - C CLOSEWIN",
  " - C QUIT",
  " - C OPENWIN",
  "R- S ECHO",
  "R- C ECHO",
  "R- S LOADFILE",
  "R- S WINEVENT",
  "R- S APP",
  "R- C CALLGAD",
  "R- C CLOSEWIN",
  "R- C QUIT",
  "R- C OPENWIN",
  NULL
};
*/



/*
char *net_GetMsgName(u8 type)
{
  char *ret;

  if(msgnames[0]==NULL)
  {
    int i;
    for(i=0;i<255;i++) msgnames[i]=msgtypes[0];
    msgnames[REQ_NONE]=msgtypes[1];
    msgnames[REQ_NONE+FL_CLI]=msgtypes[2];
    msgnames[REQ_SECHO]=msgtypes[3];
    msgnames[REQ_CECHO]=msgtypes[4];
    msgnames[REQ_SLOADFILE]=msgtypes[5];
    msgnames[REQ_SWINEVENT]=msgtypes[6];
    msgnames[REQ_SAPP]=msgtypes[7];
    msgnames[REQ_CCALLGAD]=msgtypes[8];
    msgnames[REQ_CCLOSEWIN]=msgtypes[9];
    msgnames[REQ_CCLOSEAPP]=msgtypes[10];
    msgnames[REQ_COPENWIN]=msgtypes[11];

    msgnames[REQ_SECHO|FL_REPLY]=msgtypes[12];
    msgnames[REQ_CECHO|FL_REPLY]=msgtypes[13];
    msgnames[REQ_SLOADFILE|FL_REPLY]=msgtypes[14];
    msgnames[REQ_SWINEVENT|FL_REPLY]=msgtypes[15];
    msgnames[REQ_SAPP|FL_REPLY]=msgtypes[16];
    msgnames[REQ_CCALLGAD|FL_REPLY]=msgtypes[17];
    msgnames[REQ_CCLOSEWIN|FL_REPLY]=msgtypes[18];
    msgnames[REQ_CCLOSEAPP|FL_REPLY]=msgtypes[19];
    msgnames[REQ_COPENWIN|FL_REPLY]=msgtypes[20];
  }
  ret=msgnames[type];
printf("req type: 0x%02x = %s\n",type,msgnames[type]);
  return(ret);
}
*/

int net_GetPort(void)
{
  return(9394);
}


u8 *net_MarshalPutLong(u8 *msg, u32 value)
{
  debug_Begin();

  *((u32 *)msg)=glw_htonl(value);

  debug_End();

  return(msg+4);
}


u8 *net_MarshalPutString(u8 *msg, char *value)
{
  u8 *ret;
  int len;

  debug_Begin();

  len=strlen(value)+1;
  ret=msg+len+4;
  *((u32 *)msg)=glw_htonl(len);
  strcpy(msg+4,value);

  debug_End();

  return(ret);
}


u8 *net_MarshalPutBinary(u8 *msg, u8 *value, int len)
{
  u8 *ret;

  debug_Begin();

  ret=msg+len+4;
  *((u32 *)msg)=glw_htonl(len);
  if(len>0) memcpy(msg+4,value,len);

  debug_End();

  return(ret);
}


u8 *net_MarshalPutTaglist(u8 *msg, tag *taglist)
{
  tag *tags;
  u8 *st;
  int tag_count;

  debug_Begin();

  st=msg;
  for(msg+=4,tag_count=0,tags=taglist;tags->Name!=TAG_DONE;tags=tag_GetNextTag(tags),tag_count++)
  {
    msg=net_MarshalPutLong(msg,tags->Name);
    if((tags->Name&TAGT_STRING)!=0)
    {
      msg=net_MarshalPutString(msg,(char *)tags->Data);
    }
    else msg=net_MarshalPutLong(msg,tags->Data);
  }
  net_MarshalPutLong(st,tag_count);

  debug_End();

  return(msg);
}


u32 net_MarshalGetLong(u8 **msg)
{
  u32 ret;

  debug_Begin();

  ret=glw_ntohl(*((u32 *)*msg));
  *msg+=4;

  debug_End();

  return(ret);
}


char *net_MarshalGetString(u8 **msg)
{
  char *str;
  int len;

  debug_Begin();

  len=glw_ntohl(*((u32 *)(*msg)));
  if(NULL!=(str=mem_malloc(len)))
  {
    memcpy(str,(*msg)+4,len);
    str[len-1]='\0';
  }
  *msg+=len+4;

  debug_End();

  return(str);
}


u8 *net_MarshalGetBinary(u8 **msg, int *len)
{
  u8 *data;
  int blen;

  debug_Begin();

  blen=glw_ntohl(*((u32 *)*msg));
  if(NULL!=(data=mem_malloc(blen)))
  {
    memcpy(data,(*msg)+4,blen);
    if(len!=NULL) *len=blen;
  }
  *msg+=blen+4;

  debug_End();

  return(data);
}


int net_MarshalGetBinaryLen(u8 **msg)
{
  int blen;

  blen=glw_ntohl(*((u32 *)*msg));

  return(blen);
}



tag *net_MarshalGetTaglist(u8 **msg)
{
  tag *ret,*tags;
  int tag_count,i;

  debug_Begin();

  tag_count=(int)net_MarshalGetLong(msg);
  if(NULL!=(ret=mem_malloc((tag_count+1)*sizeof(tag))))
  {
    for(tags=ret,i=0;i<tag_count;i++,tags++)
    {
      tags->Name=net_MarshalGetLong(msg);
      if((tags->Name&TAGT_STRING)!=0)
      {
        tags->Data=(u32)net_MarshalGetString(msg);
      }
      else tags->Data=net_MarshalGetLong(msg);
    }
    tags->Name=TAG_DONE;
  }

  debug_End();

  return(ret);
}


void net_MarshalFreeTaglist(tag *taglist)
{
  tag *tags;

  if(taglist!=NULL)
  {
    for(tags=taglist;tags->Name!=TAG_DONE;tags=tag_GetNextTag(tags))
    {
      if((tags->Name&TAGT_STRING)!=0) mem_free((void *)tags->Data);
    }
    mem_free(taglist);
  }
}


int net_SetState(u32 conn, int waitfor, u32 userdata)
{
  int ret=-1;
  struct glw_ConnUser *cuser=(struct glw_ConnUser *)conn;

  debug_Begin();

  ret=cuser->waitfor;
  cuser->waitfor=waitfor;
  cuser->userdata=userdata;

  debug_End();

  return(ret);
}


int net_MsgToWaitList(u32 conn, struct glw_SockMsg *msg)
{
  int ret=0;
  struct glw_ConnUser *cuser=(struct glw_ConnUser *)conn;
  Node_t *node;

  debug_Begin();

  if(cuser!=NULL&&msg!=NULL)
  {
    if(NULL!=(node=list_CreateNode()))
    {
      list_SetNodeData(node,msg);
      list_InsertNodeTail(cuser->waitlist,node);
      ret=1;
    }
  }

  debug_End();

  return(ret);
}


struct glw_SockMsg *net_MsgFromWaitList(u32 conn)
{
  struct glw_SockMsg *ret=NULL;
  struct glw_ConnUser *cuser=(struct glw_ConnUser *)conn;
  Node_t *node;

  debug_Begin();

  if(cuser!=NULL&&cuser->waitfor==REQ_NONE&&NULL!=(node=list_RemoveNodeHead(cuser->waitlist)))
  {
    ret=(struct glw_SockMsg *)list_GetNodeData(node);
    list_DeleteNode(node);
  }

  debug_End();

  return(ret);
}


void net_ClearMsgList(u32 conn)
{
  struct glw_ConnUser *cuser=(struct glw_ConnUser *)conn;
  struct glw_SockMsg *msg;
  Node_t *node;

  debug_Begin();

  if(NULL!=cuser&&cuser->waitlist!=NULL)
  {
    while(NULL!=(node=list_RemoveNodeHead(cuser->waitlist)))
    {
      msg=list_GetNodeData(node);
      list_DeleteNode(node);
      if(NULL!=msg)
      {
        if(NULL!=msg->body) mem_free(msg->body);
        mem_free(msg);
      }
    }
    list_DeleteList(cuser->waitlist);
    cuser->waitlist=NULL;
  }

  debug_End();
}


u32 net_GetUserData(u32 conn)
{
  struct glw_ConnUser *cuser=(struct glw_ConnUser *)conn;
  return(cuser->userdata);
}


int net_GetWaitfor(u32 conn)
{
  struct glw_ConnUser *cuser=(struct glw_ConnUser *)conn;
  return(cuser->waitfor);
}


int net_StrMsgLen(char *str)
{
  return(strlen(str)+1+4);
}

---