|
@@ -174,12 +174,16 @@ int insert_filter ( struct stream_application *app,
|
174
|
174
|
struct filter_stream *filter ) {
|
175
|
175
|
struct stream_connection *conn = app->conn;
|
176
|
176
|
|
177
|
|
- if ( ! app->conn ) {
|
|
177
|
+ if ( ! conn ) {
|
178
|
178
|
DBGC ( filter, "Filter %p cannot insert onto closed stream\n",
|
179
|
179
|
filter );
|
180
|
180
|
return -ENOTCONN;
|
181
|
181
|
}
|
182
|
182
|
|
|
183
|
+ DBGC ( filter, "Filter %p inserted on stream %p\n", filter, app );
|
|
184
|
+
|
|
185
|
+ filter->upstream.app = app;
|
|
186
|
+ filter->downstream.conn = conn;
|
183
|
187
|
app->conn = &filter->upstream;
|
184
|
188
|
conn->app = &filter->downstream;
|
185
|
189
|
|