Category

Development Platform
Home > SourceCode/Document > Internet-Socket-Network > Browser Client > View Code
HTTee.c
Package: arena-beta-2b-src.tar.gz　[view]
Upload User: zlh9724
Upload Date: 2007-01-04
Package Size: 1991k
Code Size: 3k
Category:

Browser Client

Development Platform:

Unix_Linux

HTTee.c：Code Content
  1. /*  HTee.c
  2. ** TEE CLASS STREAM DEFINITION
  3. **
  4. ** (c) COPYRIGHT MIT 1995.
  5. ** Please first read the full copyright statement in the file COPYRIGH.
  6. **
  7. ** The Tee class just writes to two streams.  Easy.
  8. ** See also the Black Hole stream which is even easier.
  9. **
  10. ** HISTORY:
  11. **  8 Jul 94  FM Insulate free() from _free structure element.
  12. **
  13. */
  15. /* Library include files */
  16. #include "tcp.h"
  17. #include "HTUtils.h"
  18. #include "HTArray.h"
  19. #include "HTTee.h"
  21. /* Stream Object
  22. ** ------------
  23. */
  25. struct _HTStream {
  26.     CONST HTStreamClass * isa;
  27.     HTStream * s1;
  28.     HTStream * s2;
  29.     HTComparer * resolver;
  30. };
  32. /*
  33. ** Algorithm produced by H&kon
  34. */
  35. PRIVATE int default_resolver (CONST void *a, CONST void *b)
  36. {
  37.     if (*(int *) a < 0)
  38.         return *(int *) a;
  39.     if (*(int *) b < 0)
  40.         return *(int *) b;
  41.     if (*(int *) a == 0)
  42.         return *(int *) b;
  43.     return *(int *) a;
  44. }
  46. PRIVATE int HTTee_put_character (HTStream * me, char c)
  47. {
  48.     int ret1 = (*me->s1->isa->put_character)(me->s1, c);
  49.     int ret2 = (*me->s2->isa->put_character)(me->s2, c);
  50.     return me->resolver(&ret1, &ret2);
  51. }
  53. PRIVATE int HTTee_put_string (HTStream * me, CONST char* s)
  54. {
  55.     int ret1 = (*me->s1->isa->put_string)(me->s1, s);
  56.     int ret2 = (*me->s2->isa->put_string)(me->s2, s);
  57.     return me->resolver(&ret1, &ret2);
  58. }
  60. PRIVATE int HTTee_write (HTStream * me, CONST char* s, int l)
  61. {
  62.     int ret1 = (*me->s1->isa->put_block)(me->s1, s, l);
  63.     int ret2 = (*me->s2->isa->put_block)(me->s2, s, l);
  64.     return me->resolver(&ret1, &ret2);
  65. }
  67. PRIVATE int HTTee_flush (HTStream * me)
  68. {
  69.     int ret1 = (*me->s1->isa->flush)(me->s1);
  70.     int ret2 = (*me->s2->isa->flush)(me->s2);
  71.     return me->resolver(&ret1, &ret2);
  72. }
  74. PRIVATE int HTTee_free (HTStream * me)
  75. {
  76.     int ret1 = (*me->s1->isa->_free)(me->s1);
  77.     int ret2 = (*me->s2->isa->_free)(me->s2);
  78.     return me->resolver(&ret1, &ret2);
  79.     HT_FREE(me);
  80. }
  82. PRIVATE int HTTee_abort (HTStream * me, HTList * e)
  83. {
  84.     (*me->s1->isa->abort)(me->s1, e);
  85.     (*me->s2->isa->abort)(me->s2, e);
  86.     HT_FREE(me);
  87.     return HT_ERROR;
  88. }
  91. /* Tee stream
  92. ** ----------
  93. */
  94. PRIVATE CONST HTStreamClass HTTeeClass =
  95. {
  96. "Tee",
  97. HTTee_flush,
  98. HTTee_free,
  99. HTTee_abort,
  100. HTTee_put_character,  HTTee_put_string,
  101. HTTee_write
  102. }; 
  105. /* Tee Stream creation
  106. ** -------------------
  107. ** You can create a T stream using this method. Each stream returns a
  108. ** return value and in order to resolve conflicts in the return code
  109. ** you can specify a resolver callback function. Each time any of the 
  110. ** data methods are called the resolver function is then called with
  111. ** the return codes from the two streams. The return code of the T stream
  112. ** itself will be the result of the resolver function. If you pass NULL
  113. ** as the resolver routine then a default resolver is used.
  114. */
  115. PUBLIC HTStream * HTTee(HTStream * s1, HTStream * s2, HTComparer * resolver)
  116. {
  117.     HTStream * me;
  118.     if ((me = (HTStream  *) HT_CALLOC(1, sizeof(*me))) == NULL)
  119.         HT_OUTOFMEM("HTTee");
  120.     me->isa = &HTTeeClass;
  121.     me->s1 = s1;
  122.     me->s2 = s2;
  123.     me->resolver = resolver ? resolver : default_resolver;
  124.     return me;
  125. }