ictamain.h

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

/* routines located in ictamain.c					*/
/************************************************************************/

void showCurrMenu(void);
void testCheckKey(icUserData userdata, icTimerId timerid);
void errorCallBack(icInt errorCode, icErrorMessage inf);
void defCfgAll (void);
void defCfgServer (void);
void defCfgClient (void);
void startCompTest (void);
void stopCompTest (void);
void defAllStartAll (void);

/************************************************************************/
/* routines located in icta_cfg.c					*/
/************************************************************************/

ST_RET ictaConfigure(void);

/************************************************************************/
/* routines located in itcautil.c					*/
/************************************************************************/

int findOutWho(void);
ICTA_TYPE *findUserType (char *aType);
int findStdType (char *aType);
int findAcctType (char *aType);
ICTA_REMOTE_INFO *findRemote(int whose, char *remoteName);
ICTA_LINK_INFO *findOutWhichLink(ICTA_REMOTE_INFO **pstRemote);
ICTA_VAR_INFO *findOutWhichVar(ICTA_REMOTE_INFO *pstRemote, int who);
ICTA_VAR_INFO *findClientVar(ICTA_REMOTE_INFO *pstRemote, icChar *varName);
char *findVarType(int iccpType);
ICTA_MSG_INFO *findServerMsg(int nRef, ICTA_REMOTE_INFO *pstRemote);
ICTA_DEVICE *findClientDevice(char *deviceName, ICTA_REMOTE_INFO *pstRemote);
ICTA_DEVICE *findServerDevice(char *deviceName);
ICTA_SIMPLE_ACCT *findSimpleAccount(icInt nAcctRef, int who);
ICTA_MATRIX_ACCT *findMatrixAccount(icInt nAcctRef, int who);
ST_VOID pause_msg (ST_CHAR *str);
void startInterval( void );
double endInterval( void );
ICTA_LINK_INFO *findLink(ICTA_REMOTE_INFO *pstRemote, char *linkName);
void freeVCC (void);
void defAllObjForRemote (ICTA_REMOTE_INFO *pstRemote);

/************************************************************************/
/* routines located in ictassoc.c:  associtaion managment functions	*/
/************************************************************************/

void defCfgRemotes (void);
void defCfgLinks (void);
void startRemotes (void);
void startLinks (void);
void stopRemotes (void);
void stopLinks (void);
void showChanInfo (void);
void showAssocSummary (void);
void sendAbort (void);
void linkUpCallBack(icLinkId lid, icUserData data);
void linkUpCallBackEx (icLinkId linkId, icChar *arName, icUserData data);
void linkDownCallBack(icLinkId lid, icUserData data);
void linkDownCallBackEx (icLinkId linkId, icChar *arName, icUserData data);
void remoteStopCallBack (icRemoteId rid, icUserData data);
ST_RET doDefRemotes(ICTA_REMOTE_INFO *remoteListHead, int who);
ST_RET doDefFeatures(ICTA_REMOTE_INFO *remoteListHead);
ST_RET doDefLinks(ICTA_REMOTE_INFO *remoteListHead, int who);
ST_RET doStopLinks(int howMany, ICTA_REMOTE_INFO *remoteListHead);


/************************************************************************/
/* routines located in icta_var.c:  types and variables functions	*/
/************************************************************************/

void defCfgTypes (void);
void defCfgVars (void);
void defNewType (void);
void defNewVar (void);
void readVarTypes (void);
void readVarNames (void);
void readVar (void);
void writeVar (void);
void readLocal (void);
void writeLocal (void);
void changeVar (void);
ST_RET doDefClientVars(void);
ST_RET doDefServerVars(void);
ST_RET doDefTypes(void);
void readTypeCallBack(icLinkId link, icInt status, icInt scope, 
                      icChar *varname, icInt vartype,
                      icTypeId typeid, icChar *tdl );
void readNamesCallBack(icLinkId link, icInt status, icInt scope, 
		       icInt numberNames, icChar  **nameList, icBoolean last);
void clientWriteCallBack(icInt status, icUserData data);
void clientReadCallBack(icInt status, icUserData data);
void serverWriteCallBack( icInt status, icUserData data );
void serverReadCallBack(icInt status, icUserData data);
ST_INT make_objname (OBJECT_NAME *info);
#define USE_VA_BSEARCH
ST_VOID initializeVar(ICTA_VAR_INFO *pstVar);
ST_VOID incrementVar(ICTA_VAR_INFO *pstVar);


void incomingDsTs (icDsTsReason reason, icInt numVars,
		   icUserData *pUserData, icInt *pStatus);

/************************************************************************/
/* routines located in ictatran.c:  data set transfers			*/
/************************************************************************/

void defCfgTrans (void);
void defNewTrans (void);
void showTranSummary (void);
void ctrlTranGroup (void);
void transRejectCallBack(icInt status, icLinkId linkid );
ST_RET doDefTranGroups(ST_VOID);
void doGetDataSetNames (void);

/************************************************************************/
/* routines located in ictainfo.c:  info message functions		*/
/************************************************************************/

void defCfgMsgs (void);
void sendMsg (void);
void recvMsgCallBack(icInt status, icInt infoRefNum, icInt localRef,
     	   	     icInt messageId, icInt  msgSize, void *msgByteArrayPtr,
                     icUserData  userData);
void reqInfoMsgCallBack(icInt status, icLinkId linkId, icBoolean startTransfer,
    		        icUserData usrData);
ST_INT doDefMsgs(int who, ICTA_REMOTE_INFO *remoteList);

/************************************************************************/
/* routines located in icta_dev.c:  device functions			*/
/************************************************************************/

void defCfgDevices (void);
void defNewDevice (void);
void selectDevice (void);
void operateDevice (void);
void clearDevice (void);
void getDeviceTag (void);
void setDeviceTag (void);
void doDeviceTest (void);
void selectDevInd(icRemoteId remoteId, icUserData ud);
void operateDevInd(icRemoteId remoteId, icDeviceValue value, icUserData ud);
void selectDevConf (icSelectStatus status, icCheckbackID checkbackID,
                    icUserData ud);
void operateDevConf (icOperStatus status, icUserData ud);
void getDevTagInd (icRemoteId remoteId, icUserData userData);
void setDevTagInd (icRemoteId remoteId, icTagValue tagValue,
		  char *reason, icUserData userData);
void getDevTagConf (icGetTagStatus status, icTagValue tagValue,
		   char *reason, icBoolean bArmed, 
		   icUserData userData);
void setDevTagConf (icSetTagStatus status, icUserData userData);
ST_INT doDefDevices (int who, ICTA_REMOTE_INFO *remoteList);

/************************************************************************/
/* routines located in ictaacct.c:  transfer account functions		*/
/************************************************************************/

void defCfgAccts (void);
void defNewAcct (void);
void defCfgConditions (void);
void defNewConditions (void);
void requestTA (void);
void sendTA (void);
void  recvTACallBack (icInt status, 
  		      icChar condition, 
		      icInt requestId,
		      icGMTBasedSType timeStamp, 
		      icReferenceNumType *localRefPtr,
		      icTypeAccountHeader *accountHdrPtr, 
		      void *accountValPtr,
		      icTypeTransmissionSeg *segmentHdrPtr, 
		      void *segmentValPtr,
		      icUserData data);
void  sendTACallBack (icInt status,
    		      icLinkId lp,
    		      icInt requestId,
    		      icScheduleTimeType startTime,
    		      icDurationType duration,
    		      icInt reference,
    		      icChar conditionRequested,
    		      icUserData data);
void  TACondCallBack (icInt status, icLinkId lp,
		      icChar contitions, icUserData data);
ST_INT doDefAccounts (int who, ICTA_REMOTE_INFO *remoteList);
ST_INT doDefConditions (void);

/************************************************************************/
/* functions located in ictatest.c:  special test functions		*/
/************************************************************************/

void cfgServerCompTest(ICTA_REMOTE_INFO *pstRemote);
void cfgClientCompTest(ICTA_REMOTE_INFO *pstRemote);
void serverCompTest(icUserData userdata, icTimerId timerId);
void clientCompTest(icUserData userdata, icTimerId timerId);
void cleanUpCompTest(void);
void ctClientWriteCallBack(icInt status, icUserData data);
void ctClientReadCallBack(icInt status, icUserData data);
void ctServerWriteCallBack( icInt status, icUserData data);
void ctServerReadCallBack(icInt status, icUserData data);
void ctRecvMsgCallBack(icInt status, icInt infoRefNum, icInt localRef,
     	   	     icInt messageId, icInt  msgSize, void *msgByteArrayPtr,
                     icUserData  userData);
void ctSendMsgCallBack(icInt status, icLinkId linkId, icBoolean startTransfer,
    		      icUserData usrData);
void ctSelectDevInd(icRemoteId remoteId, icUserData ud);
void ctOperateDevInd(icRemoteId remoteId, icDeviceValue value, icUserData ud);
void ctSelectDevConf (icSelectStatus status, icCheckbackID checkbackID,
                    icUserData ud);
void ctOperateDevConf (icOperStatus status, icUserData ud);
void ctRecvTACallBack (icInt status, 
  		      icChar condition, 
		      icInt requestId,
		      icGMTBasedSType timeStamp, 
		      icReferenceNumType *localRefPtr,
		      icTypeAccountHeader *accountHdrPtr, 
		      void *accountValPtr,
		      icTypeTransmissionSeg *segmentHdrPtr, 
		      void *segmentValPtr,
		      icUserData data);
void  ctSendTACallBack (icInt status,
    		      icLinkId lp,
    		      icInt requestId,
    		      icScheduleTimeType startTime,
    		      icDurationType duration,
    		      icInt reference,
    		      icChar conditionRequested,
    		      icUserData data);
void ctTACondCallBack (icInt status, icLinkId lp,
		      icChar conditions, icUserData data);

void logCompTestResults(void);
void doCompStartEmUp(ICTA_REMOTE_INFO *remoteList);




/************************************************************************/
/* functions located in ictab4b8.c:  new block 4 and block 8 functions	*/
/************************************************************************/

void b4b8RegMsgCB (void);
void b4DefCond (void);
void b8DefCond (void);
void b4RegCondCB (void);
void b8RegCondCB (void);
void b4b8SendMsg (void);
ST_RET setupB4Client (ICTA_REMOTE_INFO *pstRemote);
ST_RET setupB8Client (ICTA_REMOTE_INFO *pstRemote);
ST_RET setupB4Server (ICTA_REMOTE_INFO *pstRemote);
ST_RET setupB8Server (ICTA_REMOTE_INFO *pstRemote);

/************************************************************************/
/* functions located in ictab8Test.c:  send TAReports			*/
/************************************************************************/
ST_VOID startB8Test (ST_VOID);
ST_VOID stopB8Test (ST_VOID);



/************************************************************************/
/* functions located in the toolkit not prototyped in icapi.h		*/
/************************************************************************/

char     *icPerror( int errorCode ); 
void icDisplayChanInfo( char *chantxt );

#ifdef _WIN32
int gettimeofday( struct timeval *, void * );   
#endif

icInt icDefineTypeEx(icChar *typeName, icChar *typeDefinition, 
		     icTypeId *TypeID);





/************************************************************************/
/* some macros to support SISCO_THREADS					*/
/************************************************************************/
#if defined (SISCO_THREADS) && (defined (__alpha) || defined(_AIX))
#if defined(_POSIX_C_SOURCE) && (_POSIX_C_SOURCE >= 199506L)
/*****************/
/* POSIX 1003.1c */
/*****************/
#define IC_PTHREAD_COND_INIT(cond_ptr, cond_attr, rtnval) \
  {   \
  rtnval = 0; \
  rtnval = pthread_cond_init (cond_ptr, cond_attr); \
  if (rtnval != 0) \
    { \
    slog (sLogCtrl, 0, thisFileName, __LINE__, 	     		\
         "IC_PTHREAD_COND_INIT error %d.", rtnval);\
    } \
  }
#define IC_PTHREAD_CREATE(thread_ptr, attr, start_rtn, start_arg, rtnval)  \
  {\
  rtnval = 0;	\
  rtnval = pthread_create (thread_ptr, attr, 	\
  			   start_rtn, (void *) start_arg);	\
  if (rtnval != 0)	\
    { \
    slog (sLogCtrl, 0, thisFileName, __LINE__,		\
    	  "IC_PTHREAD_CREATE error %d", rtnval);	\
    } \
  }

#define IC_PTHREAD_EXIT(anArg, rtnval)	\
  {	\
  rtnval = 0;	\
  rtnval = pthread_exit ((void *) anArg);	\
  if (rtnval != 0)	\
    {	\
    slog (sLogCtrl, 0, thisFileName, __LINE__,	\
    	  "IC_PTHREAD_EXIT error %d.", rtnval);	\
    }	\
  }

#else
/*****************/
/* POSIX 1003.4a */
/*****************/
#define IC_PTHREAD_COND_INIT(cond_ptr, cond_attr_ptr, rtnval) \
  {   \
  rtnval = 0; \
  if (cond_attr_ptr == NULL) \
    { \
    rtnval = pthread_cond_init (cond_ptr, pthread_condattr_default); \
    } \
  else \
    { \
    rtnval = pthread_cond_init(cond_ptr, *((pthread_condattr_t *)cond_attr_ptr)); \
    } \
  if (rtnval != 0) \
    { \
    slog (sLogCtrl, 0, thisFileName, __LINE__,	\
          "IC_PTHREAD_COND_INIT error %d.", errno);	\
    } \
  }

#define IC_PTHREAD_CREATE(thread_ptr, attr, start_rtn, start_arg, rtnval)  \
  {\
  rtnval = 0;\
  rtnval = pthread_create ((pthread_t *) thread_ptr, attr,\
  			  (pthread_startroutine_t) start_rtn,\
			  (pthread_addr_t) start_arg);\
  if (rtnval != 0)\
    {\
    slog (sLogCtrl, 0, thisFileName, __LINE__,\
    	  "IC_PTHREAD_CREATE error %d.", errno);\
    }\
  }

#define IC_PTHREAD_EXIT(anArg, rtnval)\
  {\
  pthread_exit ((pthread_addr_t) anArg);\
  }


#endif	/* end POSIX		*/
#endif  /* end SISCO_THREADS	*/

#endif		/* end #ifndef ICTAMAIN_INCLUDED		*/









/************************************************************************/
/* NOTE: compile with QUALITY_TEST defined to track incoming quality	*/
/*	 flags on Block1 and Block2 transfer reports			*/
/************************************************************************/