equal
deleted
inserted
replaced
257 if (lm_message_get_type (m) == LM_MESSAGE_TYPE_STREAM) { |
257 if (lm_message_get_type (m) == LM_MESSAGE_TYPE_STREAM) { |
258 connection_stream_received (connection, m); |
258 connection_stream_received (connection, m); |
259 goto out; |
259 goto out; |
260 } |
260 } |
261 |
261 |
262 if (lm_message_get_type (m) == LM_MESSAGE_TYPE_STREAM_ERROR) { |
|
263 connection_stream_error (connection, m); |
|
264 goto out; |
|
265 } |
|
266 |
|
267 if ((lm_message_get_sub_type (m) == LM_MESSAGE_SUB_TYPE_ERROR) || |
262 if ((lm_message_get_sub_type (m) == LM_MESSAGE_SUB_TYPE_ERROR) || |
268 (lm_message_get_sub_type (m) == LM_MESSAGE_SUB_TYPE_RESULT)) { |
263 (lm_message_get_sub_type (m) == LM_MESSAGE_SUB_TYPE_RESULT)) { |
269 id = lm_message_node_get_attribute (m->node, "id"); |
264 id = lm_message_node_get_attribute (m->node, "id"); |
270 |
265 |
271 if (id) { |
266 if (id) { |
292 result = _lm_message_handler_handle_message (hd->handler, |
287 result = _lm_message_handler_handle_message (hd->handler, |
293 connection, |
288 connection, |
294 m); |
289 m); |
295 } |
290 } |
296 |
291 |
|
292 if (lm_message_get_type (m) == LM_MESSAGE_TYPE_STREAM_ERROR) { |
|
293 connection_stream_error (connection, m); |
|
294 goto out; |
|
295 } |
|
296 |
297 out: |
297 out: |
298 lm_connection_unref (connection); |
298 lm_connection_unref (connection); |
299 |
299 |
300 return; |
300 return; |
301 } |
301 } |