Subversion Repository Public Repository

litesoft

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
// This Source Code is in the Public Domain per: http://litesoft.org/License.txt
package org.litesoft.GWT.eventbus.client.nonpublic;

import org.litesoft.GWT.eventbus.client.*;
import org.litesoft.commonfoundation.base.*;

public class TimerNode
{
    private TimerNode mPrev = null;
    private TimerNode mNext = null;
    private long mFireWhen;
    private int mClientIdNumber;
    private EventPackage mParcel;

    public TimerNode( int pFireInMilliSecs, int pClientIdNumber, EventPackage pPackage )
    {
        long now = MillisecTimeSource.INSTANCE.now();
        mFireWhen = now + pFireInMilliSecs;
        mClientIdNumber = pClientIdNumber;
        if ( null == (mParcel = pPackage) )
        {
            throw new IllegalArgumentException( "Parcel may not be null" );
        }
    }

    public long getFireWhen()
    {
        return mFireWhen;
    }

    public int getClientIdNumber()
    {
        return mClientIdNumber;
    }

    public EventPackage getParcel()
    {
        return mParcel;
    }

    public boolean isBefore( TimerNode pTimerNode )
    {
        return (pTimerNode != null) && (this.mFireWhen < pTimerNode.mFireWhen);
    }

    /**
     * Remove 'this' from LinkList
     *
     * @return mNext
     */
    public TimerNode remove()
    {
        // x - this - y
        TimerNode rv = this.mNext;
        if ( this.mPrev != null )
        {
            mPrev.mNext = this.mNext;
        }
        if ( this.mNext != null )
        {
            mNext.mPrev = this.mPrev;
        }
        mPrev = mNext = null;
        // x - y
        return rv;
    }

    /**
     * Insert 'pNewTimerNode' before 'this' in the LinkList
     *
     * @param pNewTimerNode may NOT have its links set
     *
     * @return pNewTimerNode
     */
    public TimerNode insertBeforeMe( TimerNode pNewTimerNode )
    {
        // x - this - y
        if ( chk( pNewTimerNode ) )
        {
            pNewTimerNode.mNext = this;
            pNewTimerNode.mPrev = this.mPrev;
            if ( this.mPrev != null )
            {
                this.mPrev.mNext = pNewTimerNode;
            }
            this.mPrev = pNewTimerNode;
        }
        // x - pNewTimerNode - this - y
        return pNewTimerNode;
    }

    /**
     * Insert 'pNewTimerNode' after 'this' in the LinkList
     *
     * @param pNewTimerNode may NOT have its links set
     */
    public void insertAfterMe( TimerNode pNewTimerNode )
    {
        // x - this - y
        if ( chk( pNewTimerNode ) )
        {
            pNewTimerNode.mNext = this.mNext;
            if ( this.mNext != null )
            {
                this.mNext.mPrev = pNewTimerNode;
            }
            this.mNext = pNewTimerNode;
            pNewTimerNode.mPrev = this;
        }
        // x - this - pNewTimerNode - y
    }

    private boolean chk( TimerNode pNewTimerNode )
    {
        if ( pNewTimerNode == null )
        {
            return false;
        }
        if ( (pNewTimerNode.mPrev != null) || (pNewTimerNode.mNext != null) )
        {
            throw new IllegalArgumentException( "NewTimerNode has non-Null links" );
        }
        return true;
    }

    /**
     * @return the New Head
     */
    public static TimerNode addTo( TimerNode pCurrentHead, TimerNode pNewTimerNode )
    {
        if ( pNewTimerNode == null )
        {
            return pCurrentHead;
        }
        if ( pCurrentHead == null )
        {
            return pNewTimerNode;
        }
        if ( pNewTimerNode.isBefore( pCurrentHead ) )
        {
            return pCurrentHead.insertBeforeMe( pNewTimerNode );
        }
        TimerNode cur = pCurrentHead;
        while ( cur.mNext != null )
        {
            cur = cur.mNext;
            if ( pNewTimerNode.isBefore( cur ) )
            {
                cur.insertBeforeMe( pNewTimerNode );
                return pCurrentHead;
            }
        }
        cur.insertAfterMe( pNewTimerNode );
        return pCurrentHead;
    }
}

Commits for litesoft/trunk/Java/GWT/OldClient/src/org/litesoft/GWT/eventbus/client/nonpublic/TimerNode.java

Diff revisions: vs.
Revision Author Commited Message
942 Diff Diff GeorgeS picture GeorgeS Mon 02 Jun, 2014 23:41:46 +0000

Extracting commonfoundation

939 Diff Diff GeorgeS picture GeorgeS Mon 02 Jun, 2014 21:30:31 +0000

Extracting commonfoundation

858 Diff Diff GeorgeS picture GeorgeS Sun 04 Nov, 2012 18:40:40 +0000
49 Diff Diff GeorgeS picture GeorgeS Mon 12 Apr, 2010 02:59:10 +0000

License Text

2 GeorgeS picture GeorgeS Sun 07 Feb, 2010 12:50:58 +0000