mmsajou.c

ICCP Toolkit 是在 Tru64下开发Tase.2通信协议的开发包

                {
                strcpy (inp_str, temp);
                vi_ptr->var_tag = inp_str;
                inp_str += len;
                }
              else
                {
                vi_done = SD_TRUE;
                wait_msg ("\n Total Data too long, entry was lost ");
                }
              }
      
            if (vi_entered)
              {
              printf (" Enter Value Specification (R) : ");
              if (len = input_hex ((ST_UCHAR *)temp, 100))
                {
                if ((tot_len += len) < 2048)
            	  {
            	  ec_ptr->ef.data.list_of_var_pres = SD_TRUE;
            	  memcpy (inp_str, temp, len);
            	  vi_ptr->value_spec.data = (ST_UCHAR *)inp_str;
            	  vi_ptr->value_spec.len	= len;
            	  inp_str += len;
            	  ec_ptr->ef.data.num_of_var++;
            	  vi_ptr++;
            	  }
                else
            	  {
            	  vi_entered = SD_FALSE;
            	  wait_msg ("\n Total Data too long, entry was lost ");
                  }
                }
              else
                vi_entered = SD_FALSE;
              }
            if (!vi_entered)
              vi_done = SD_TRUE;
            }			/* end of Var enter loop		*/
				/* point to next entry content		*/
	  vi_ptr	= (VAR_INFO *) (ec_ptr + 1);
	  vi_ptr += ec_ptr->ef.data.num_of_var;
	  ec_ptr	= (ENTRY_CONTENT *) vi_ptr;
          }			/* end of DATA	if			*/
        else				/* entry form -- annotation	*/
          {
          printf (" Enter Annotation (R) : ");
          if (strget (temp))
            {
            len = strlen (temp) + 1;
            if ((tot_len += len) < 2000)
              {
              strcpy (inp_str, temp);
              ec_ptr->ef.annotation	    = inp_str;
              inp_str += len;
              }
            else
              wait_msg ("\n Total Data too long, entry was lost ");
            }
	  ec_ptr += 1;			/* point to next EntryContent	*/
          }

	req_info->num_of_jou_entry++;	/* inc # entries		*/
	}
      else
	done = SD_TRUE;
      }
    }

  if (data_entered)
    {
    if (!mp_jwrite (chan, req_info))
      print_req_error ();

    if (num_reps)			/* if this an auto repeat -	*/
      {
      if (start_cont ())		/* wait for 1st to complete	*/
	return;
      num_outstanding = 1;
      while (rep_count < num_reps)	/* if enough done -		*/
	{
	if (! mp_jwrite (chan, req_info))
	  break;
	num_outstanding++;
	if (cont_serve ())			/* if user hit a key	*/
	  return;
	}
      cont_done ();			/* display results		*/
      }
    }
  else
    wait_msg ("\n Must enter all required information ");

  (*menu_set_fun) ();
#endif
  }

/************************************************************************/
/*			do_jinit					*/
/* create and send an initialize journal request			*/
/************************************************************************/

ST_VOID do_jinit (ST_VOID)
  {
#if MMS_JINIT_EN & REQ_EN

JINIT_REQ_INFO req_info;
ST_INT chan;
ST_BOOLEAN data_entered;
ST_INT len;
ST_CHAR	temp [100];
ST_CHAR   *inp_str;

  if (!get_chan (&chan))
    {
    (*menu_set_fun) ();
    return;
    }

  inp_str = dest_buffer;

  printf ("\n Enter Journal Name : \n");
  data_entered = get_objname (&req_info.jou_name);

  if (data_entered)
    {
    if (ask (" Send Limit Spec ? ",0))
      {
      req_info.limit_spec_pres = 1;
      req_info.limit_time.form = MMS_BTOD6;
      req_info.limit_time.ms = 12345;
      req_info.limit_time.day = 6210;		/* 1/1/2001 */

      if (ask (" Send Limiting Entry ? ",0))
        {
        req_info.limit_entry_pres = 1;
        printf (" Enter Limiting Entry : (O) ");
        if (len = input_hex ((ST_UCHAR *)temp, 100))
          {
          memcpy (inp_str, temp, len);
          req_info.limit_entry     = (ST_UCHAR *)inp_str;
          req_info.limit_entry_len = len;
          inp_str += len;
          }
	else
          req_info.limit_entry_pres = 0;
	 
        }
      else
        req_info.limit_entry_pres = 0;
      }
    else
      req_info.limit_spec_pres = 0;
    }

  if (data_entered)
    {
    if (!mp_jinit (chan, &req_info))
      print_req_error ();

    if (num_reps)			/* if this an auto repeat -	*/
      {
      if (start_cont ())		/* wait for 1st to complete	*/
	return;
      num_outstanding = 1;
      while (rep_count < num_reps)	/* if enough done -		*/
	{
	if (! mp_jinit (chan, &req_info))
	  break;
	num_outstanding++;
	if (cont_serve ())			/* if user hit a key	*/
	  return;
	}
      cont_done ();			/* display results		*/
      }
    }
  else
    wait_msg ("\n Must enter all required information ");

  (*menu_set_fun) ();
#endif
  }

/************************************************************************/
/*			do_jstat					*/
/* create and send a report journal status request			*/
/************************************************************************/

ST_VOID do_jstat (ST_VOID)
  {
#if MMS_JINIT_EN & REQ_EN

JSTAT_REQ_INFO req_info;
ST_INT chan;
ST_BOOLEAN data_entered;

  if (!get_chan (&chan))
    {
    (*menu_set_fun) ();
    return;
    }
  printf ("\n Enter Journal Name : \n");
  data_entered = get_objname (&req_info.jou_name);

  if (data_entered)
    {
    if (!mp_jstat (chan, &req_info))
      print_req_error ();

    if (num_reps)			/* if this an auto repeat -	*/
      {
      if (start_cont ())		/* wait for 1st to complete	*/
	return;
      num_outstanding = 1;
      while (rep_count < num_reps)	/* if enough done -		*/
	{
	if (! mp_jstat (chan, &req_info))
	  break;
	num_outstanding++;
	if (cont_serve ())			/* if user hit a key	*/
	  return;
	}
      cont_done ();			/* display results		*/
      }
    }
  else
    wait_msg ("\n Must enter all required information ");

  (*menu_set_fun) ();
#endif
  }

/************************************************************************/
/*			do_jcreate					*/
/* create and send a create journal request				*/
/************************************************************************/

ST_VOID do_jcreate (ST_VOID)
  {
#if MMS_JCREATE_EN & REQ_EN

JCREATE_REQ_INFO req_info;
ST_INT chan;
ST_BOOLEAN data_entered;

  if (!get_chan (&chan))
    {
    (*menu_set_fun) ();
    return;
    }

  printf (" Enter Journal Name :\n");
  data_entered = get_objname (&req_info.jou_name);

  if (data_entered)
    {
    if (!mp_jcreate (chan, &req_info))
      print_req_error ();

    if (num_reps)			/* if this an auto repeat -	*/
      {
      if (start_cont ())		/* wait for 1st to complete	*/
	return;
      num_outstanding = 1;
      while (rep_count < num_reps)	/* if enough done -		*/
	{
	if (! mp_jcreate (chan, &req_info))
	  break;
	num_outstanding++;
	if (cont_serve ())			/* if user hit a key	*/
	  return;
	}
      cont_done ();			/* display results		*/
      }
    }
  else
    wait_msg ("\n Must enter all required information ");

  (*menu_set_fun) ();
#endif
  }

/************************************************************************/
/*			do_jdelete					*/
/* create and send a delete journal request				*/
/************************************************************************/

ST_VOID do_jdelete (ST_VOID)
  {
#if MMS_JDELETE_EN & REQ_EN

JDELETE_REQ_INFO req_info;
ST_INT chan;
ST_BOOLEAN data_entered;

  if (!get_chan (&chan))
    {
    (*menu_set_fun) ();
    return;
    }

  printf (" Enter Journal Name :\n");
  data_entered = get_objname (&req_info.jou_name);

  if (data_entered)
    {
    if (!mp_jdelete (chan, &req_info))
      print_req_error ();

    if (num_reps)			/* if this an auto repeat -	*/
      {
      if (start_cont ())		/* wait for 1st to complete	*/
	return;
      num_outstanding = 1;
      while (rep_count < num_reps)	/* if enough done -		*/
	{
	if (! mp_jdelete (chan, &req_info))
	  break;
	num_outstanding++;
	if (cont_serve ())			/* if user hit a key	*/
	  return;
	}
      cont_done ();			/* display results		*/
      }
    }
  else
    wait_msg ("\n Must enter all required information ");

  (*menu_set_fun) ();
#endif
  }