开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数值算法/人工智能 > 生物技术 > 查看源码
ncbi_file_connector.c
资源名称：ncbi_cxx_win--Jul_08_2004.zip　[点击查看]
上传用户：yhdzpy8989
上传日期：2007-06-13
资源大小：13604k
文件大小：11k
源码类别：

生物技术

开发平台：

C/C++

ncbi_file_connector.c：源码内容
  1. /*
  2.  * ===========================================================================
  3.  * PRODUCTION $Log: ncbi_file_connector.c,v $
  4.  * PRODUCTION Revision 1000.0  2003/10/29 16:36:42  gouriano
  5.  * PRODUCTION PRODUCTION: IMPORTED [ORIGINAL] Dev-tree R6.12
  6.  * PRODUCTION
  7.  * ===========================================================================
  8.  */
  10. /*  $Id: ncbi_file_connector.c,v 1000.0 2003/10/29 16:36:42 gouriano Exp $
  11.  * ===========================================================================
  12.  *
  13.  *                            PUBLIC DOMAIN NOTICE
  14.  *               National Center for Biotechnology Information
  15.  *
  16.  *  This software/database is a "United States Government Work" under the
  17.  *  terms of the United States Copyright Act.  It was written as part of
  18.  *  the author's official duties as a United States Government employee and
  19.  *  thus cannot be copyrighted.  This software/database is freely available
  20.  *  to the public for use. The National Library of Medicine and the U.S.
  21.  *  Government have not placed any restriction on its use or reproduction.
  22.  *
  23.  *  Although all reasonable efforts have been taken to ensure the accuracy
  24.  *  and reliability of the software and data, the NLM and the U.S.
  25.  *  Government do not and cannot warrant the performance or results that
  26.  *  may be obtained by using this software or data. The NLM and the U.S.
  27.  *  Government disclaim all warranties, express or implied, including
  28.  *  warranties of performance, merchantability or fitness for any particular
  29.  *  purpose.
  30.  *
  31.  *  Please cite the author in any work or product based on this material.
  32.  *
  33.  * ===========================================================================
  34.  *
  35.  * Author:  Vladimir Alekseyev, Denis Vakatov, Anton Lavrentiev
  36.  *
  37.  * File Description:
  38.  *   Implement CONNECTOR for a FILE stream
  39.  *
  40.  *   See in "connectr.h" for the detailed specification of the underlying
  41.  *   connector("CONNECTOR", "SConnectorTag") methods and structures.
  42.  *
  43.  */
  45. #include "ncbi_ansi_ext.h"
  46. #include <connect/ncbi_file_connector.h>
  47. #include <stdio.h>
  48. #include <stdlib.h>
  51. /***********************************************************************
  52.  *  INTERNAL -- Auxiliary types and static functions
  53.  ***********************************************************************/
  55. /* All internal data necessary to perform the (re)connect and i/o
  56.  */
  57. typedef struct {
  58.     char*         inp_file_name;
  59.     char*         out_file_name;
  60.     FILE*         finp;
  61.     FILE*         fout;
  62.     SFileConnAttr attr;
  63. } SFileConnector;
  66. /***********************************************************************
  67.  *  INTERNAL -- "s_VT_*" functions for the "virt. table" of connector methods
  68.  ***********************************************************************/
  70. #ifdef __cplusplus
  71. extern "C" {
  72. #endif /* __cplusplus */
  73.     static const char* s_VT_GetType (CONNECTOR       connector);
  74.     static EIO_Status  s_VT_Open    (CONNECTOR       connector,
  75.                                      const STimeout* timeout);
  76.     static EIO_Status  s_VT_Wait    (CONNECTOR       connector,
  77.                                      EIO_Event       event,
  78.                                      const STimeout* timeout);
  79.     static EIO_Status  s_VT_Write   (CONNECTOR       connector,
  80.                                      const void*     buf,
  81.                                      size_t          size,
  82.                                      size_t*         n_written,
  83.                                      const STimeout* timeout);
  84.     static EIO_Status  s_VT_Flush   (CONNECTOR       connector,
  85.                                      const STimeout* timeout);
  86.     static EIO_Status  s_VT_Read    (CONNECTOR       connector,
  87.                                      void*           buf,
  88.                                      size_t          size,
  89.                                      size_t*         n_read,
  90.                                      const STimeout* timeout);
  91.     static EIO_Status  s_VT_Status  (CONNECTOR       connector,
  92.                                      EIO_Event       dir);
  93.     static EIO_Status  s_VT_Close   (CONNECTOR       connector,
  94.                                      const STimeout* timeout);
  95.     static void        s_Setup      (SMetaConnector* meta,
  96.                                      CONNECTOR       connector);
  97.     static void        s_Destroy    (CONNECTOR       connector);
  98. #  ifdef IMPLEMENTED__CONN_WaitAsync
  99.     static EIO_Status s_VT_WaitAsync(void*                   connector,
  100.                                      FConnectorAsyncHandler  func,
  101.                                      SConnectorAsyncHandler* data);
  102. #  endif
  103. #ifdef __cplusplus
  104. } /* extern "C" */
  105. #endif /* __cplusplus */
  108. /*ARGSUSED*/
  109. static const char* s_VT_GetType
  110. (CONNECTOR connector)
  111. {
  112.     return "FILE";
  113. }
  116. /*ARGSUSED*/
  117. static EIO_Status s_VT_Open
  118. (CONNECTOR       connector,
  119.  const STimeout* timeout)
  120. {
  121.     SFileConnector* xxx = (SFileConnector*) connector->handle;
  122.     const char*     mode = 0;
  124.     /* if connected already, and trying to reconnect */
  125.     if (xxx->finp  &&  xxx->fout)
  126.         return eIO_Success;
  128.     /* open file for output */
  129.     switch ( xxx->attr.w_mode ) {
  130.     case eFCM_Truncate:
  131.         mode = "wb";  break;
  132.     case eFCM_Seek: /* mode = "rb+"; break; */
  133.     case eFCM_Append:
  134.         mode = "ab";  break;
  135.     }
  137.     xxx->fout = fopen(xxx->out_file_name, mode);
  138.     if ( !xxx->fout ) {
  139.         return eIO_Unknown;
  140.     }
  142.     /* open file for input */
  143.     xxx->finp = fopen(xxx->inp_file_name, "rb");
  144.     if ( !xxx->finp ) {
  145.         fclose(xxx->fout);
  146.         xxx->fout = 0;
  147.         return eIO_Unknown;
  148.     }
  150.     /* Due to the shortage of portable 'fseek' call
  151.      * ignore read/write positions so far;
  152.      * only 0/EOF are in use for writing, and only 0 for reading
  153.      */
  154.     return eIO_Success;
  155. }
  158. /*ARGSUSED*/
  159. static EIO_Status s_VT_Write
  160. (CONNECTOR       connector,
  161.  const void*     buf,
  162.  size_t          size,
  163.  size_t*         n_written,
  164.  const STimeout* timeout)
  165. {
  166.     SFileConnector* xxx = (SFileConnector*) connector->handle;
  168.     if ( !size ) {
  169.         *n_written = 0;
  170.         return eIO_Success;
  171.     }
  173.     *n_written = fwrite(buf, 1, size, xxx->fout);
  174.     if ( !*n_written ) {
  175.         return eIO_Unknown;
  176.     }
  178.     return eIO_Success;
  179. }
  182. /*ARGSUSED*/
  183. static EIO_Status s_VT_Read
  184. (CONNECTOR       connector,
  185.  void*           buf,
  186.  size_t          size,
  187.  size_t*         n_read,
  188.  const STimeout* timeout)
  189. {
  190.     SFileConnector* xxx = (SFileConnector*) connector->handle;
  192.     if ( !size ) {
  193.         *n_read = 0;
  194.         return eIO_Success;
  195.     }
  197.     *n_read = fread(buf, 1, size, xxx->finp);
  198.     if ( !*n_read ) {
  199.         return feof(xxx->finp) ? eIO_Closed : eIO_Unknown;
  200.     }
  202.     return eIO_Success;
  203. }
  206. /*ARGSUSED*/
  207. static EIO_Status s_VT_Wait
  208. (CONNECTOR       connector,
  209.  EIO_Event       event,
  210.  const STimeout* timeout)
  211. {
  212.     return eIO_Success;
  213. }
  216. /*ARGSUSED*/
  217. static EIO_Status s_VT_Flush
  218. (CONNECTOR       connector,
  219.  const STimeout* timeout)
  220. {
  221.     SFileConnector* xxx = (SFileConnector*) connector->handle;
  223.     if (fflush(xxx->fout) != 0)
  224.         return eIO_Unknown;
  226.     return eIO_Success;
  227. }
  230. static EIO_Status s_VT_Status
  231. (CONNECTOR connector,
  232.  EIO_Event dir)
  233. {
  234.     SFileConnector* xxx = (SFileConnector*) connector->handle;
  235.     assert(dir == eIO_Read || dir == eIO_Write);
  236.     if (dir == eIO_Read)
  237.         return feof(xxx->finp) ? eIO_Closed :
  238.         (ferror(xxx->finp) ? eIO_Unknown : eIO_Success);
  239.     else
  240.         return ferror(xxx->fout) ?  eIO_Unknown : eIO_Success;
  241. }
  244. /*ARGSUSED*/
  245. static EIO_Status s_VT_Close
  246. (CONNECTOR       connector,
  247.  const STimeout* timeout)
  248. {
  249.     SFileConnector* xxx = (SFileConnector*) connector->handle;
  251.     fclose(xxx->finp);
  252.     xxx->finp = 0;
  253.     fclose(xxx->fout);
  254.     xxx->fout = 0;
  255.     return eIO_Success;
  256. }
  259. static void s_Setup
  260. (SMetaConnector* meta,
  261.  CONNECTOR       connector)
  262. {
  263.     /* initialize virtual table */
  264.     CONN_SET_METHOD(meta, get_type,   s_VT_GetType,   connector);
  265.     CONN_SET_METHOD(meta, open,       s_VT_Open,      connector);
  266.     CONN_SET_METHOD(meta, wait,       s_VT_Wait,      connector);
  267.     CONN_SET_METHOD(meta, write,      s_VT_Write,     connector);
  268.     CONN_SET_METHOD(meta, flush,      s_VT_Flush,     connector);
  269.     CONN_SET_METHOD(meta, read,       s_VT_Read,      connector);
  270.     CONN_SET_METHOD(meta, status,     s_VT_Status,    connector);
  271.     CONN_SET_METHOD(meta, close,      s_VT_Close,     connector);
  272. #ifdef IMPLEMENTED__CONN_WaitAsync
  273.     CONN_SET_METHOD(meta, wait_async, s_VT_WaitAsync, connector);
  274. #endif
  275.     meta->default_timeout = 0/*infinite*/;
  276. }
  279. static void s_Destroy
  280. (CONNECTOR connector)
  281. {
  282.     SFileConnector* xxx = (SFileConnector*) connector->handle;
  283.     
  284.     free(xxx->inp_file_name);
  285.     free(xxx->out_file_name);
  286.     free(xxx);
  287.     connector->handle = 0;
  288.     free(connector);
  289. }
  292. /***********************************************************************
  293.  *  EXTERNAL -- the connector's "constructors"
  294.  ***********************************************************************/
  296. extern CONNECTOR FILE_CreateConnector
  297. (const char* inp_file_name,
  298.  const char* out_file_name)
  299. {
  300.     static const SFileConnAttr def_attr = { 0, eFCM_Truncate, 0 };
  302.     return FILE_CreateConnectorEx(inp_file_name, out_file_name, &def_attr);
  303. }
  306. extern CONNECTOR FILE_CreateConnectorEx
  307. (const char*          inp_file_name,
  308.  const char*          out_file_name,
  309.  const SFileConnAttr* attr)
  310. {
  311.     CONNECTOR       ccc = (SConnector*) malloc(sizeof(SConnector));
  312.     SFileConnector* xxx = (SFileConnector*) malloc(sizeof(SFileConnector));
  314.     /* initialize internal data structures */
  315.     xxx->inp_file_name = strdup(inp_file_name);
  316.     xxx->out_file_name = strdup(out_file_name);
  317.     xxx->finp          = 0;
  318.     xxx->fout          = 0;
  320.     memcpy(&xxx->attr, attr, sizeof(SFileConnAttr));
  322.     /* initialize connector data */
  323.     ccc->handle  = xxx;
  324.     ccc->next    = 0;
  325.     ccc->meta    = 0;
  326.     ccc->setup   = s_Setup;
  327.     ccc->destroy = s_Destroy;
  329.     return ccc;
  330. }
  333. /*
  334.  * --------------------------------------------------------------------------
  335.  * $Log: ncbi_file_connector.c,v $
  336.  * Revision 1000.0  2003/10/29 16:36:42  gouriano
  337.  * PRODUCTION: IMPORTED [ORIGINAL] Dev-tree R6.12
  338.  *
  339.  * Revision 6.12  2003/05/31 05:14:56  lavr
  340.  * Add ARGSUSED where args are meant to be unused
  341.  *
  342.  * Revision 6.11  2003/05/14 03:55:53  lavr
  343.  * Slight VT table reformatting
  344.  *
  345.  * Revision 6.10  2002/10/28 15:46:20  lavr
  346.  * Use "ncbi_ansi_ext.h" privately
  347.  *
  348.  * Revision 6.9  2002/10/22 15:11:24  lavr
  349.  * Zero connector's handle to crash if revisited
  350.  *
  351.  * Revision 6.8  2002/09/24 15:06:00  lavr
  352.  * Log moved to end
  353.  *
  354.  * Revision 6.7  2002/04/26 16:32:36  lavr
  355.  * Added setting of default timeout in meta-connector's setup routine
  356.  *
  357.  * Revision 6.6  2001/12/04 15:56:35  lavr
  358.  * Use strdup() instead of explicit strcpy(malloc(...), ...)
  359.  *
  360.  * Revision 6.5  2001/01/25 17:04:43  lavr
  361.  * Reversed:: DESTROY method calls free() to delete connector structure
  362.  *
  363.  * Revision 6.4  2001/01/23 23:11:20  lavr
  364.  * Status virtual method implemented
  365.  *
  366.  * Revision 6.3  2001/01/11 16:38:16  lavr
  367.  * free(connector) removed from s_Destroy function
  368.  * (now always called from outside, in METACONN_Remove)
  369.  *
  370.  * Revision 6.2  2000/12/29 17:55:53  lavr
  371.  * Adapted for use of new connector structure.
  372.  *
  373.  * Revision 6.1  2000/04/12 15:18:13  vakatov
  374.  * Initial revision
  375.  *
  376.  * ==========================================================================
  377.  */