git-svn-id: https://svn.erp5.org/repos/neo/trunk@1719 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1718 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1717 71dcc9de-d417-0410-9af5-da40c76e7ee4

This tool monkey patch the NEO Storage 'copyTransactionFrom' method to
compute statistical information about import.
It expect a data.fs path as argument and send a report mail to defined
recipients.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1716 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1715 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1714 71dcc9de-d417-0410-9af5-da40c76e7ee4

- Return False when a ping has been sent, so current instance isn't trashed
  and replaced by ping's internal expectPacket.
- Make current idleEvent instance handle ping's timeout, to avoid creating
  a new event for each ping sent in relation to an existing event.
- Don't call expectPacket from ping when given a msg_id, meaning it is
  related to an existing event.
- Add a minimal delay of 5 seconds between 2 pings.
- Update event tests

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1713 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1712 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1711 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1710 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1709 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1708 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1707 71dcc9de-d417-0410-9af5-da40c76e7ee4

When a new handler is applied on a connection, register a special packet
in the request queue to set the handler when all current requests receive
their answer.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1706 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1705 71dcc9de-d417-0410-9af5-da40c76e7ee4

The connection may have been already added to writable events in poll, it
usefull to add it here only if the buffer was initialy empty.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1704 71dcc9de-d417-0410-9af5-da40c76e7ee4

At connection level, when packet parsing fails there is no packet instance
(in except block). As there is no meaning to log a packet when it is
malformed, remove this parameter from _packetMalformed().

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1703 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1702 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1701 71dcc9de-d417-0410-9af5-da40c76e7ee4

This exception is used only during packet decoding.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1700 71dcc9de-d417-0410-9af5-da40c76e7ee4

Fix related tests.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1699 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1698 71dcc9de-d417-0410-9af5-da40c76e7ee4

In writable(), the _send() call could have closed the connection so don't
close it again if aborted or don't disable write events polling has this is
already done.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1697 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1696 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1695 71dcc9de-d417-0410-9af5-da40c76e7ee4

Remove hanlder methods for that packet in order to reveal if it happens in
reality, so ti could be fixed.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1694 71dcc9de-d417-0410-9af5-da40c76e7ee4

uuid variable is used both to contain peer uuid and one of the uuids sent
in message payload.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1693 71dcc9de-d417-0410-9af5-da40c76e7ee4

The implementation lacks some checks around the handling of
setClusterState, so add a TODO about this so we can get rid of former
XXX comment.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1692 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1691 71dcc9de-d417-0410-9af5-da40c76e7ee4

This call, whose return value is ignore, is just here to establish the
connection with master if it was cut.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1690 71dcc9de-d417-0410-9af5-da40c76e7ee4

Makes it thread-safe (with detailed explanation on for each method).
Makes it more efficient for unregister and registered uses.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1689 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1688 71dcc9de-d417-0410-9af5-da40c76e7ee4

Also, make logging done when catching OperationFailure exception consistent
with logging done when catching PrimaryFailure exception.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1687 71dcc9de-d417-0410-9af5-da40c76e7ee4

This does not change code flow:
- self.master_node is None when entering the loop for the first time
- there is no way to restart the loop other than a PrimaryFailure exception

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1686 71dcc9de-d417-0410-9af5-da40c76e7ee4

This is identical to what is done in master/app.py:run.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1685 71dcc9de-d417-0410-9af5-da40c76e7ee4

This reduces the cost of invoking log method when the log line is not to
be emitted.
Also, don't put a space before a colon.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1684 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1683 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1682 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1681 71dcc9de-d417-0410-9af5-da40c76e7ee4

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1680 71dcc9de-d417-0410-9af5-da40c76e7ee4