Index: ossp-pkg/l2/l2_channel.c
RCS File: /v/ossp/cvs/ossp-pkg/l2/l2_channel.c,v
rcsdiff -q -kk '-r1.13' '-r1.14' -u '/v/ossp/cvs/ossp-pkg/l2/l2_channel.c,v' 2>/dev/null
--- l2_channel.c	2001/09/05 10:59:37	1.13
+++ l2_channel.c	2001/09/05 13:56:12	1.14
@@ -70,18 +70,25 @@
 l2_result_t l2_channel_open(l2_channel_t *ch)
 {
     l2_result_t rv;
+    l2_channel_t *chFirst;
 
     if (ch == NULL)
         return L2_ERROR;
     if (ch->state != L2_CHSTATE_CREATED)
         return L2_ERROR;
-    while (ch != NULL && ch->handler.open == L2_OK)
+    chFirst = ch;
+    while (ch != NULL && ch->handler.open == NULL)
         ch = ch->downstream;
     if (ch == NULL)
         return L2_ERROR;
     rv = ch->handler.open(&ch->context, ch);
-    if (rv == L2_OK)
-        ch->state = L2_CHSTATE_OPENED;
+    if (rv == L2_OK) {
+        ch = chFirst;
+        do {
+            ch->state = L2_CHSTATE_OPENED;
+            ch = ch->downstream;
+        } while (ch != NULL);
+    }
     return rv;
 }
 
@@ -97,7 +104,7 @@
         return L2_ERROR;
     if (bufsize == 0)
         return L2_OK;
-    while (ch != NULL && ch->handler.write == L2_OK)
+    while (ch != NULL && ch->handler.write == NULL)
         ch = ch->downstream;
     if (ch == NULL)
         return L2_ERROR;
@@ -113,7 +120,7 @@
         return L2_ERROR;
     if (ch->state != L2_CHSTATE_OPENED)
         return L2_ERROR;
-    while (ch != NULL && ch->handler.flush == L2_OK)
+    while (ch != NULL && ch->handler.flush == NULL)
         ch = ch->downstream;
     if (ch == NULL)
         return L2_ERROR;
@@ -124,18 +131,25 @@
 l2_result_t l2_channel_close(l2_channel_t *ch)
 {
     l2_result_t rv;
+    l2_channel_t *chFirst;
 
     if (ch == NULL)
         return L2_ERROR;
+    chFirst = ch;
     if (ch->state != L2_CHSTATE_OPENED)
         return L2_ERROR;
-    while (ch != NULL && ch->handler.close == L2_OK)
+    while (ch != NULL && ch->handler.close == NULL)
         ch = ch->downstream;
     if (ch == NULL)
         return L2_ERROR;
     rv = ch->handler.close(&ch->context, ch);
-    if (rv == L2_OK)
-        ch->state = L2_CHSTATE_CREATED;
+    if (rv == L2_OK) {
+        ch = chFirst;
+        do {
+            ch->state = L2_CHSTATE_CREATED;
+            ch = ch->downstream;
+        } while (ch != NULL);
+    }
     return rv;
 }
 
@@ -148,7 +162,7 @@
     if (ch->state == L2_CHSTATE_OPENED)
         if ((rv = l2_channel_close(ch)) != L2_OK)
             return rv;
-    while (ch != NULL && ch->handler.destroy == L2_OK)
+    while (ch != NULL && ch->handler.destroy == NULL)
         ch = ch->downstream;
     if (ch != NULL)
         rv = ch->handler.destroy(&ch->context, ch);