anon.pay

Class AIControlChannel

java.lang.Object

anon.client.AbstractChannel

anon.client.AbstractControlChannel

anon.client.StreamedControlChannel

anon.client.XmlControlChannel

anon.pay.AIControlChannel

public class AIControlChannel
extends XmlControlChannel

This control channel is used for communication with the AI (AccountingInstance or Abrechnungsinstanz in German) which lives in the first mix. The AI sends a request when it wants a cost confirmation from us. This thread waits for incoming requests and sends the requested confirmations to the AI.

Version:

1.0

Author:

Bastian Voigt, Tobias Bayer, Rolf Wendolsky

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	AIControlChannel.EmptyAccountPacketObserver
private class	AIControlChannel.PreviousPrepdaidBytes

Field Summary

Fields

Modifier and Type	Field and Description
static long	AI_LOGIN_TIMEOUT
private static int	FIRST_MIX
static java.util.Hashtable	HASH_PREPAID_ON_SERVICES
private java.util.Vector	m_aiListeners
private int	m_aiLogin_timeout
private java.util.Vector	m_aiLoginSyncObject
private boolean	m_bEmptyMessageSent
private boolean	m_bLastCCSignaled
private boolean	m_bMultiplexerClosed
private boolean	m_bPrepaidReceived
private MixCascade	m_connectedCascade
private XMLEasyCC	m_initialCC
private XMLErrorMessage	m_lastErrorMessage
private AIControlChannel.EmptyAccountPacketObserver	m_packetCountEmptyObserver
private PacketCounter	m_packetCounter
private PayAccount	m_payAccount
private boolean	m_prepaidAmountInPayRequest indicates that the prepaid Bytes are transmitted by a PayRequest instead of a challenge.
private long	m_prepaidBytes
private static long	m_totalBytes
static long	MAX_PREPAID_INTERVAL
static long	MIN_PREPAID_INTERVAL
private static long	MULTIPLE_LOGIN_BLOCK_TIME
private static java.lang.String	PREPAID_AMOUNT_IN_PAY_REQ_MIXVERSION
static boolean	REVERT_PRE_PREPAID

Fields inherited from class anon.client.AbstractChannel

m_parentMultiplexer

Constructor Summary

Constructors

Constructor and Description
AIControlChannel(Multiplexer a_multiplexer, PacketCounter a_packetCounter, IServiceContainer a_serviceContainer, MixCascade a_connectedCascade)

Method Summary

Modifier and Type	Method and Description
void	addAIListener(IAIEventListener a_aiListener)
private boolean	checkAccountChanged()
protected void	finalize()
static long	getBytes()
private AIControlChannel.PreviousPrepdaidBytes	getPreviousPrepaidBytes()
private void	handlePrepaidBytesReceived(int prepaidBytes, PayAccount activeAccount)
boolean	isPrepaidAmountInPayRequest()
void	multiplexerClosed() This method is called on every channel in the channel-table after the multiplexer is closed.
private void	processCcToSign(XMLEasyCC cc) processCcToSign: to be called by processPayRequest (only the initial, old CC is sent as a naked XMLEasyCC, new CCs to sign are sent inside a XMLPayRequest)
private void	processChallenge(XMLChallenge chal) processChallenge
private void	processInitialCC(XMLEasyCC a_cc) processInitialCC: last step of connecting to a pay cascade: take last CC as sent by AI as base value for future CCs Also, send a CC for (bytes in last CC + prepay interval of cascade) to avoid triggering the cascade's hardlimit by starting to transfer bytes without prepaying
private void	processPayRequest(XMLPayRequest request) process a XMLPayRequest message, which might request a XMLAccountCertificate, request a XMLBalance, or contain a XMLEasyCC which the AI asks the JAP to sign
void	processXmlMessage(org.w3c.dom.Document docMsg) proccessXMLMessage - this is called when a new request is coming in.
void	sendAccountCert()
void	setAILoginTimeout(int aiLogin_timeout)
void	setPrepaidAmountInPayRequest(boolean prepaidAmountInPayRequest)
private void	updateBalance(PayAccount currentAccount, boolean a_bSynchronous)

Methods inherited from class anon.client.XmlControlChannel

processMessage, sendXmlMessage

Methods inherited from class anon.client.StreamedControlChannel

processPacketData, sendByteMessage

Methods inherited from class anon.client.AbstractControlChannel

getServiceContainer, isSending, processReceivedPacket, sendRawMessage

Methods inherited from class anon.client.AbstractChannel

createEmptyMixPacket, deleteChannel, isClosed, sendPacket

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MAX_PREPAID_INTERVAL

public static final long MAX_PREPAID_INTERVAL

See Also:

Constant Field Values

MIN_PREPAID_INTERVAL

public static final long MIN_PREPAID_INTERVAL

See Also:

Constant Field Values

AI_LOGIN_TIMEOUT

public static final long AI_LOGIN_TIMEOUT

See Also:

Constant Field Values

MULTIPLE_LOGIN_BLOCK_TIME

private static final long MULTIPLE_LOGIN_BLOCK_TIME

See Also:

Constant Field Values

FIRST_MIX

private static final int FIRST_MIX

See Also:

Constant Field Values

PREPAID_AMOUNT_IN_PAY_REQ_MIXVERSION

private static final java.lang.String PREPAID_AMOUNT_IN_PAY_REQ_MIXVERSION

See Also:

Constant Field Values

REVERT_PRE_PREPAID

public static final boolean REVERT_PRE_PREPAID

See Also:

Constant Field Values

HASH_PREPAID_ON_SERVICES

public static final java.util.Hashtable HASH_PREPAID_ON_SERVICES

m_aiLogin_timeout

private int m_aiLogin_timeout

m_lastErrorMessage

private XMLErrorMessage m_lastErrorMessage

m_totalBytes

private static long m_totalBytes

m_bPrepaidReceived

private boolean m_bPrepaidReceived

m_prepaidBytes

private long m_prepaidBytes

m_bMultiplexerClosed

private boolean m_bMultiplexerClosed

m_aiListeners

private java.util.Vector m_aiListeners

m_packetCounter

private PacketCounter m_packetCounter

m_packetCountEmptyObserver

private AIControlChannel.EmptyAccountPacketObserver m_packetCountEmptyObserver

m_bEmptyMessageSent

private boolean m_bEmptyMessageSent

m_connectedCascade

private MixCascade m_connectedCascade

m_payAccount

private PayAccount m_payAccount

m_initialCC

private XMLEasyCC m_initialCC

m_aiLoginSyncObject

private final java.util.Vector m_aiLoginSyncObject

m_prepaidAmountInPayRequest

private boolean m_prepaidAmountInPayRequest

indicates that the prepaid Bytes are transmitted by a PayRequest instead of a challenge. (supported by mixes of version >= 08.42 )

m_bLastCCSignaled

private boolean m_bLastCCSignaled

Constructor Detail

AIControlChannel

public AIControlChannel(Multiplexer a_multiplexer,
                        PacketCounter a_packetCounter,
                        IServiceContainer a_serviceContainer,
                        MixCascade a_connectedCascade)

Method Detail

addAIListener

public void addAIListener(IAIEventListener a_aiListener)

processXmlMessage

public void processXmlMessage(org.w3c.dom.Document docMsg)

proccessXMLMessage - this is called when a new request is coming in.

Specified by:

processXmlMessage in class XmlControlChannel

Parameters:

docMsg - Document

handlePrepaidBytesReceived

private void handlePrepaidBytesReceived(int prepaidBytes,
                                        PayAccount activeAccount)

processChallenge

private void processChallenge(XMLChallenge chal)
                       throws java.lang.Exception

processChallenge

Parameters:

xMLChallenge - XMLChallenge

Throws:

java.lang.Exception

checkAccountChanged

private boolean checkAccountChanged()

processPayRequest

private void processPayRequest(XMLPayRequest request)

process a XMLPayRequest message, which might request a XMLAccountCertificate, request a XMLBalance, or contain a XMLEasyCC which the AI asks the JAP to sign

Parameters:

request - XMLPayRequest

updateBalance

private void updateBalance(PayAccount currentAccount,
                           boolean a_bSynchronous)

processCcToSign

private void processCcToSign(XMLEasyCC cc)
                      throws java.lang.Exception

processCcToSign: to be called by processPayRequest (only the initial, old CC is sent as a naked XMLEasyCC, new CCs to sign are sent inside a XMLPayRequest)

Throws:

java.lang.Exception

sendAccountCert

public void sendAccountCert()
                     throws AnonServiceException

Throws:

AnonServiceException

getBytes

public static long getBytes()

getPreviousPrepaidBytes

private AIControlChannel.PreviousPrepdaidBytes getPreviousPrepaidBytes()

processInitialCC

private void processInitialCC(XMLEasyCC a_cc)

processInitialCC: last step of connecting to a pay cascade: take last CC as sent by AI as base value for future CCs Also, send a CC for (bytes in last CC + prepay interval of cascade) to avoid triggering the cascade's hardlimit by starting to transfer bytes without prepaying

Parameters:

a_cc - XMLEasyCC: the last CC that the JAP sent to this Cascade, as returned from the AI

finalize

protected void finalize()
                 throws java.lang.Throwable

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable

multiplexerClosed

public void multiplexerClosed()

Description copied from class: AbstractChannel

This method is called on every channel in the channel-table after the multiplexer is closed. Children of AbstractAnonChannel should overwrite this method. It's not necessary to delete the channel from the channel-table but maybe there are some other tasks to do.

Overrides:

multiplexerClosed in class AbstractChannel

setAILoginTimeout

public void setAILoginTimeout(int aiLogin_timeout)

isPrepaidAmountInPayRequest

public boolean isPrepaidAmountInPayRequest()

setPrepaidAmountInPayRequest

public void setPrepaidAmountInPayRequest(boolean prepaidAmountInPayRequest)