ipvs: SCTP Trasport Loadbalancing Support

[net-next-2.6.git] / net / netfilter / ipvs / ip_vs_sync.c

diff --git a/net/netfilter/ipvs/ip_vs_sync.c b/net/netfilter/ipvs/ip_vs_sync.c
index e177f0dc20849d4b62620939e9b2532db12f3e7e..8fb0ae61676116fd81604c7f157a357b3262f6ae 100644 (file)
--- a/net/netfilter/ipvs/ip_vs_sync.c
+++ b/net/netfilter/ipvs/ip_vs_sync.c
@@ -400,6 +400,11 @@ static void ip_vs_process_message(const char *buffer, const size_t buflen)
                                        flags |= IP_VS_CONN_F_INACTIVE;
                                else
                                        flags &= ~IP_VS_CONN_F_INACTIVE;
+                       } else if (s->protocol == IPPROTO_SCTP) {
+                               if (state != IP_VS_SCTP_S_ESTABLISHED)
+                                       flags |= IP_VS_CONN_F_INACTIVE;
+                               else
+                                       flags &= ~IP_VS_CONN_F_INACTIVE;
                        }
                        cp = ip_vs_conn_new(AF_INET, s->protocol,
                                            (union nf_inet_addr *)&s->caddr,
@@ -434,6 +439,15 @@ static void ip_vs_process_message(const char *buffer, const size_t buflen)
                                atomic_dec(&dest->inactconns);
                                cp->flags &= ~IP_VS_CONN_F_INACTIVE;
                        }
+               } else if ((cp->dest) && (cp->protocol == IPPROTO_SCTP) &&
+                          (cp->state != state)) {
+                       dest = cp->dest;
+                       if (!(cp->flags & IP_VS_CONN_F_INACTIVE) &&
+                            (state != IP_VS_SCTP_S_ESTABLISHED)) {
+                           atomic_dec(&dest->activeconns);
+                           atomic_inc(&dest->inactconns);
+                           cp->flags &= ~IP_VS_CONN_F_INACTIVE;
+                       }
                }
 
                if (opt)