home *** CD-ROM | disk | FTP | other *** search
/ Power-Programmierung / CD2.mdf / c / library / dos / diverses / text_cla / fio.cpp < prev    next >
Encoding:
C/C++ Source or Header  |  1992-05-12  |  7.0 KB  |  331 lines
  1. //////////////////////////////////////////////////////////////////////// 
  2. //+ 
  3. //  Module Name:  fio.cpp 
  4. // 
  5. //  Description:  FIO specific routines 
  6. // 
  7. //  Include Modules Referenced:  fio.h 
  8. // 
  9. //  Written by:  John Tal 
  10. // 
  11. // 
  12. //  Modification history: 
  13. // 
  14. //  Date         Engineer     Mod #          Modification Description 
  15. // 
  16. //  12-Feb-1992  Tal          v 1.0-001      Initial conversion to C++ 
  17. //- 
  18. //////////////////////////////////////////////////////////////////////// 
  19.  
  20.  
  21.  
  22.  
  23. #include <fio.h> 
  24.   
  25. //////////////////////////////////////////////////////////////////////// 
  26. //+ 
  27. // Function Name:   GetFile 
  28. // 
  29. // Class:           FIO_C 
  30. // 
  31. // Security:        Public 
  32. // 
  33. // Description:     Checks for existance of a file 
  34. // 
  35. // Parameters 
  36. //    In:           pcSeedPathName = File being looked for 
  37. // 
  38. // Return Codes:    SHORT = FIO_OK = file exists 
  39. //                        = FIO_NO_FILE = file does not exist 
  40. // 
  41. // Written by:      John Tal 
  42. // 
  43. // 
  44. // Modification History: 
  45. // 
  46. //  Date         Engineer     Mod #          Modification Description 
  47. // 
  48. //  12-Feb-1992  Tal          v 1.0-001      Initial conversion to C++ 
  49. // 
  50. //- 
  51. //////////////////////////////////////////////////////////////////////// 
  52.  
  53.  
  54. SHORT FIO_C::GetFile(PCHAR pcSeedPathName)
  55. { 
  56.     C_DEF_MODULE("FIO_C::GetFile") 
  57.  
  58.     struct stat stStatMain; 
  59.  
  60.     /* check if file exists */ 
  61.  
  62.     C_STATUS = stat(pcSeedPathName,&stStatMain);     
  63.   
  64.     if(C_STATUS) 
  65.        C_SET_STATUS(FIO_NO_FILE) 
  66.     else 
  67.        C_SET_STATUS(FIO_OK) 
  68.  
  69.     C_RETURN 
  70. } 
  71.  
  72.   
  73. //////////////////////////////////////////////////////////////////////// 
  74. //+ 
  75. // Function Name:   RemoveFile 
  76. // 
  77. // Class:           FIO_C 
  78. // 
  79. // Security:        Public 
  80. // 
  81. // Description:     Remove a file, to be called by reader only 
  82. // 
  83. // Parameters 
  84. //    In:           pcSeedPathName = File to be removed 
  85. // 
  86. // Return Codes:    SHORT = result from system unlink call 
  87. // 
  88. // Written by:      John Tal 
  89. // 
  90. // 
  91. // Modification History: 
  92. // 
  93. //  Date         Engineer     Mod #          Modification Description 
  94. // 
  95. //  12-Feb-1992  Tal          v 1.0-001      Initial conversion to C++ 
  96. // 
  97. //- 
  98. //////////////////////////////////////////////////////////////////////// 
  99.   
  100. SHORT FIO_C::RemoveFile(PCHAR pcSeedPathName)
  101. { 
  102.    C_DEF_MODULE("FIO_C::RemoveFile") 
  103.  
  104.    C_STATUS = unlink(pcSeedPathName); 
  105.    
  106.    C_RETURN 
  107. } 
  108.  
  109.   
  110. //////////////////////////////////////////////////////////////////////// 
  111. //+ 
  112. // Function Name:   IncSeedPathName 
  113. // 
  114. // Class:           FIO_C 
  115. // 
  116. // Security:        Public 
  117. // 
  118. // Description:     Increment the extension of a filename 
  119. // 
  120. // Parameters 
  121. //    In:           pcSeedPathName = Filename to increment 
  122. // 
  123. // Return Codes:    SHORT = C_OK = Got an item 
  124. //                        = C_NOTOK = Heap empty 
  125. // 
  126. // Written by:      John Tal 
  127. // 
  128. // 
  129. // Modification History: 
  130. // 
  131. //  Date         Engineer     Mod #          Modification Description 
  132. // 
  133. //  12-Feb-1992  Tal          v 1.0-001      Initial conversion to C++ 
  134. // 
  135. //- 
  136. //////////////////////////////////////////////////////////////////////// 
  137.   
  138. SHORT FIO_C::IncSeedPathName(PCHAR pcSeedPathName)
  139. {
  140.     C_DEF_MODULE("FIO_C::IncSeedPathName")
  141.  
  142.     INT   iPos;
  143.     CHAR  szExtension[FIO_EXTENSION_LEN + 2];
  144.     INT   iExtension;
  145.     CHAR  szWorkStr[128];
  146.  
  147.     iPos = FindChar(pcSeedPathName,FIO_PERIOD); 
  148.  
  149.     if(iPos == FIO_NO_CHAR) 
  150.        C_LEAVE(iPos); 
  151.  
  152.     strcpy(szExtension,&pcSeedPathName[iPos + 1]); 
  153.     iExtension = atoi(szExtension); 
  154.     iExtension++; 
  155.     if(iExtension > FIO_MAX_EXTENSION) 
  156.        iExtension = 0; 
  157.  
  158.     sprintf(szExtension,"%d",iExtension); 
  159.     while(strlen(szExtension) < FIO_EXTENSION_LEN) 
  160.     { 
  161.        strcpy(szWorkStr,"0"); 
  162.        strcat(szWorkStr,szExtension); 
  163.        strcpy(szExtension,szWorkStr); 
  164.     } 
  165.  
  166.     strcpy(&pcSeedPathName[iPos + 1],szExtension); 
  167.  
  168. C_MODULE_EXIT: 
  169.  
  170.     C_RETURN 
  171. } 
  172.  
  173.   
  174. //////////////////////////////////////////////////////////////////////// 
  175. //+ 
  176. // Function Name:   FindChar 
  177. // 
  178. // Class:           FIO_C 
  179. // 
  180. // Security:        Private 
  181. // 
  182. // Description:     Looks for a character in a string [0] based 
  183. // 
  184. // Parameters 
  185. //    In:           pcString = string to check 
  186. //                  cChar = character to search for 
  187. // 
  188. // Return Codes:    SHORT = FIO_NOCHAR = Charcter not found 
  189. //                        = !FIO_NO_CHAR = Offset of charcter in string 
  190. // 
  191. // Written by:      John Tal 
  192. // 
  193. // 
  194. // Modification History: 
  195. // 
  196. //  Date         Engineer     Mod #          Modification Description 
  197. // 
  198. //  12-Feb-1992  Tal          v 1.0-001      Initial conversion to C++ 
  199. // 
  200. //- 
  201. //////////////////////////////////////////////////////////////////////// 
  202.   
  203.  
  204. SHORT FIO_C::FindChar(PCHAR pcString, CHAR cChar)
  205. {
  206.     C_DEF_MODULE("FIO_C::FindChar")
  207.  
  208.     INT i;
  209.     INT iLen;
  210.  
  211.     iLen = strlen(pcString);
  212.     for(i = 0; i < iLen; i++)
  213.       if(pcString[i] == cChar)
  214.      break;
  215.  
  216.     if(i < iLen)
  217.       C_SET_STATUS(i)
  218.     else
  219.       C_SET_STATUS(FIO_NO_CHAR)
  220.  
  221.     C_RETURN
  222. }
  223.  
  224.  
  225.  
  226. #define TEST
  227. #ifdef TEST
  228.  
  229.  
  230. #include <cmemlib.h>
  231.  
  232. #include "mos.h"
  233.  
  234.  
  235. char  szReaderSeedPathName[] = "Testing.000"; 
  236. char  szWriterSeedPathName[] = "Testing.000"; 
  237.  
  238.  
  239.  
  240. //
  241. //  Reader Proc 
  242. //
  243.  
  244. SHORT 
  245. Proc1(MOS_P pclMos, PVOID pvWorkArea)
  246. {
  247.     C_DEF_MODULE("Proc1")
  248.     FIO_C  cFio;
  249.      
  250.     C_STATUS = cFio.GetFile(szReaderSeedPathName);
  251.  
  252.     if(!C_STATUS) 
  253.     { 
  254.        printf("Reader: Working on file %s\n",szReaderSeedPathName); 
  255.        cFio.RemoveFile(szReaderSeedPathName); 
  256.        cFio.IncSeedPathName(szReaderSeedPathName); 
  257.     } 
  258.     else 
  259.     { 
  260.        C_STATUS = pclMos -> Sleep(1);
  261.     } 
  262.  
  263.     pvWorkArea = pvWorkArea;  // keep compiler quiet
  264.  
  265.     C_RETURN 
  266.  
  267. } 
  268.  
  269.  
  270.  
  271. #define TEMP_FILE_NAME  "Temp.Dat" 
  272.  
  273. // 
  274. // Writer Proc
  275. //
  276.  
  277. SHORT 
  278. Proc2(MOS_P pclMos,PVOID pvWorkArea) 
  279. { 
  280.    C_DEF_MODULE("Proc2") 
  281.    FIO_C  cFio; 
  282.  
  283.    FILE *fp; 
  284.  
  285.    fp = fopen(TEMP_FILE_NAME,"w"); 
  286.    fclose(fp); 
  287.  
  288.    /* It is highly recommended that you write out the file as a temporary file 
  289.       and rename it after it is closed.  This will prevent the reader from 
  290.       dealing with situations where the data has not been flushed out to 
  291.       disk by the operating system (i.e. Unix). 
  292.    */ 
  293.  
  294.    rename(TEMP_FILE_NAME,szWriterSeedPathName); 
  295.  
  296.    printf("Writer: Created file %s\n",szWriterSeedPathName); 
  297.    cFio.IncSeedPathName(szWriterSeedPathName); 
  298.  
  299.    // C_STATUS = pclMos -> Sleep(1);
  300.  
  301.    pvWorkArea = pvWorkArea;  // keep compiler quiet
  302.  
  303.    C_RETURN 
  304. } 
  305.  
  306.  
  307. main(VOID)
  308. {
  309.     C_DEF_MODULE("Fio Test Main") 
  310.  
  311.     char szSeedPathName[128 + 1]; 
  312.     int iMode; 
  313.     int iSts; 
  314.     FILE * fp; 
  315.  
  316.     MOS_C  clMos;
  317.  
  318.     C_STATUS = clMos.ProcCreate(Proc1,"FIO_PROC_1",10,NULL);
  319.     C_STATUS = clMos.ProcCreate(Proc2,"FIO_PROC_2",10,NULL); 
  320.  
  321.     C_STATUS = clMos.Scheduler(); 
  322.  
  323.     C_RETURN
  324. } 
  325.  
  326.  
  327.  
  328. #endif 
  329.  
  330.  
  331.