dce_hinfo.c

Ho Chi Minh City University of Technology Computer Science Department Distributed Computing E

/***************************************
Ho Chi Minh City University of Technology
    Computer Science Department 
Distributed Computing Environment (DCE)
Written by Nguyen Van Noi -59406114
File dce_hinfo.c on Tue Dec 22 13:30:40 1998
****************************************/
#include <values.h>
#include "dce_server.h"

PHINFO
NewHinfo (int order, u_long addr)
{
  PHINFO p = (PHINFO) malloc (sizeof (HINFO));
  if (!p)
    return NULL;
  p->order = order;
  p->addr = addr;
  p->status = 1;
  p->time = 2 * TIMEOUT_IAMALIVE + 1;
  return p;
}

void
DecTime (void *pt)
{
  PHINFO p = (PHINFO) pt;
  if (p->time >= 0)
    p->time -= TIMEOUT_IAMALIVE;
  else
    p->status = 0;
}
void
dce_server_dcetime ()
{
  TravelList (Server.pList, DecTime);
}
int _MinOrder;
void
MinOrder (void *pt)
{
  PHINFO p = (PHINFO) pt;
  if ((p->status == 1) && (_MinOrder > p->order))
    _MinOrder = p->order;
}

int
dce_server_minorder ()
{
  _MinOrder = MAXINT;
  TravelList (Server.pList, MinOrder);
  return _MinOrder;
}

int
cmpsinfo (void *p1, void *p2)
{
  PHINFO p = (PHINFO) p1;
  u_long *pu = (u_long *) p2;
  if (*pu == p->addr)
    {
      p->status = 1;
      p->time = 2 * TIMEOUT_IAMALIVE + 1;
      return 1;
    }
  return 0;
}
void
dce_agent_update_newmsg ()
{
  PHINFO p;
  void **pr = ItemLookup (Server.pList, (void *) &msg.saddr, cmpsinfo);
  if (pr)
    {
      free (pr);
      return;
    }
  p = NewHinfo (msg.order, msg.saddr);
  if (!p)
    return;
  InsertList (Server.pList, (void *) p);
}

int
cmppp (void *p1, void *p2)
{
  PHINFO p = (PHINFO) p1;
  u_long *pu = (u_long *) p2;
  if (*pu == p->addr)
    return 1;
  return 0;

}

void
dce_server_delete_server (u_long u)
{
  DeleteItem (Server.pList, (void *) &u, cmppp, NULL);
}

void
userbroadcast (void *p)
{
  long *pl = (long *) p;
  Server.Msg.lextra = *pl;
  dce_server_mcastsend ((char *) &Server.Msg, sizeof (MSG));
}

void
dce_server_userbroadcast ()
{
  TravelList (Server.pUserList, userbroadcast);
}

void
servicebroadcast (void *pt)
{
  PSERVICEINFO p = (PSERVICEINFO) pt;
  Server.Msg.nextra = p->param;
  strcpy (Server.Msg.sername, p->sername);
  dce_server_mcastsend ((char *) &Server.Msg, sizeof (MSG));
}
void
dce_server_servicebroadcast ()
{
  TravelList (Server.pService, servicebroadcast);
}

void
userservicebroadcast (void *pt)
{
  PUSERSERVICE p = (PUSERSERVICE) pt;
  msg.type = DCE_MSG_ALL_REPLY_ALL_USERSERVICE;
  msg.who = UNKNOWN;
  msg.pid = p->pid;
  msg.saddr = p->serveraddr;
  msg.uid = p->uid;
  msg.nextra = p->sernum;
  msg.aaddr = p->clientaddr;
  msg.lextra = p->tStart;
  msg.lextra1 = p->tEnd;
  msg.sport = p->time;
  dce_server_mcastsend ((char *) &msg, sizeof (MSG));
}
void
dce_server_userservicebroadcast ()
{
  TravelList (Server.pCurUserService, userservicebroadcast);
}