ericthorsen

Keybase proof

I hereby claim:

• I am ericthorsen on github.
• I am thorseneric (https://keybase.io/thorseneric) on keybase.
• I have a public key ASBYZmrm4i8k_qQMO6bQRG-sxbxRlKKqIJT20TTPkSYesgo

To claim this, I am signing this object:

ericthorsen

        [TestModuleAttribute("calc_NEED_VCPj2_h", "calc_NEED_VCPj2_h", ModuleType.MathModule)]
        static public MKMap calc_NEED_VCPj2_h
            (
            String stratasuffix
            , Object j2
            , MKMap TAB_VCPj2_h
            , Double ADD_DIF_VCPj2
            )
        {
            MKMap NEED_VCP2j_h = new MKMap(String.Format("NEED_VCPj2_{0}", stratasuffix), stratasuffix);

ericthorsen

private void server_MIPRecordDequeued(MIPQueueRecord record)
		{
		try
		{
                if (record.OutBoundDocQueueID != -1)
                    _lastDocumentID = record.OutBoundDocQueueID;

                //Profile list exists for private sweep or retran
                if (record.ProfileList != null)
				{

ericthorsen

private void doWork(MIPQueueRecord record)
{
            if (!IsStopped)
            {
                //ET this is the old code...it waits to get an ack before moving on to the next record???
                //waitForAck();
                if (profile_.Ack)
                {//ET keep trying to add the item until the client times out (in case they stop acking)
                    TimeSpan tenMinutes = TimeSpan.FromMilliseconds(10 * 60 * 1000);
                    Int32 soFar = 0;

ericthorsen

                   MIPMessage msg = protocol_.ReadNextMessage(null);
                    if (msg.IsAcknowledgement)
                    {
                        //if this profile is not set for acknowledgement than we just log warning
                        if (profile_.Ack)
                        {
                            MIPQueueRecord mipQRec;
                            if(_ackQueue.TryTake(out mipQRec))
                                OnClientAckReceived(this.profile_.ProfileID, mipQRec);
                            else

ericthorsen

 if (profile_.Ack)
                    {//ET keep trying to add the item until the client times out (in case they stop acking)
                        TimeSpan tenMinutes = TimeSpan.FromMilliseconds(10*60*1000);
                        Int32 soFar = 0;
                        while (!_ackQueue.TryAdd(record, 20) && soFar < tenMinutes.TotalMilliseconds) ;
                        if (soFar >= tenMinutes.TotalMilliseconds)
                        {
                            Stop();
                            throw new ApplicationException(String.Format("Acknowledgement not received in 10 minutes. Disconnecting client {0}.",this.Profile.Name));
                        }