~ubuntu-branches/ubuntu/raring/pgpool2/raring-proposed

« back to all changes in this revision

Viewing changes to pool_proto_modules.c

  • Committer: Bazaar Package Importer
  • Author(s): Christoph Berg
  • Date: 2011-06-10 10:18:29 UTC
  • mfrom: (1.1.6 upstream)
  • Revision ID: james.westby@ubuntu.com-20110610101829-oy0uronxs3xz6jer
Tags: 3.0.4-1
* New upstream release
* Use format 3.0 (quilt).

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
1
/* -*-pgsql-c-*- */
2
2
/*
3
 
 * $Header: /cvsroot/pgpool/pgpool-II/pool_proto_modules.c,v 1.89.2.7 2011/02/23 13:19:32 kitagawa Exp $
 
3
 * $Header: /cvsroot/pgpool/pgpool-II/pool_proto_modules.c,v 1.89.2.9 2011/05/26 05:04:10 kitagawa Exp $
4
4
 * 
5
5
 * pgpool: a language independent connection pool server for PostgreSQL 
6
6
 * written by Tatsuo Ishii
700
700
 
701
701
                                msg->len = len;
702
702
                                msg->contents = contents;
 
703
 
 
704
                                query_context->rewritten_query = rewrite_query;
703
705
                        }
704
706
                }
705
707
        }
1424
1426
POOL_STATUS CloseComplete(POOL_CONNECTION *frontend, POOL_CONNECTION_POOL *backend)
1425
1427
{
1426
1428
        POOL_SESSION_CONTEXT *session_context;
 
1429
        POOL_STATUS status;
1427
1430
 
1428
1431
        /* Get session context */
1429
1432
        session_context = pool_get_session_context();
1433
1436
                return POOL_END;
1434
1437
        }
1435
1438
 
 
1439
        /* Send CloseComplete(3) to frontend before removing the target message */
 
1440
        status = SimpleForwardToFrontend('3', frontend, backend);
 
1441
 
 
1442
        /* Remove the target message */
1436
1443
        if (session_context->uncompleted_message)
1437
1444
        {
1438
1445
                pool_remove_sent_message(session_context->uncompleted_message->kind,
1445
1452
                return POOL_END;
1446
1453
        }
1447
1454
 
1448
 
        return SimpleForwardToFrontend('3', frontend, backend);
 
1455
        return status;
1449
1456
}
1450
1457
 
1451
1458
POOL_STATUS CommandComplete(POOL_CONNECTION *frontend, POOL_CONNECTION_POOL *backend)