OLD | NEW |
1 /* | 1 /* |
2 * Copyright (C) 2009, 2012 Ericsson AB. All rights reserved. | 2 * Copyright (C) 2009, 2012 Ericsson AB. All rights reserved. |
3 * Copyright (C) 2010 Apple Inc. All rights reserved. | 3 * Copyright (C) 2010 Apple Inc. All rights reserved. |
4 * | 4 * |
5 * Redistribution and use in source and binary forms, with or without | 5 * Redistribution and use in source and binary forms, with or without |
6 * modification, are permitted provided that the following conditions | 6 * modification, are permitted provided that the following conditions |
7 * are met: | 7 * are met: |
8 * | 8 * |
9 * 1. Redistributions of source code must retain the above copyright | 9 * 1. Redistributions of source code must retain the above copyright |
10 * notice, this list of conditions and the following disclaimer. | 10 * notice, this list of conditions and the following disclaimer. |
(...skipping 89 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
100 virtual void didFailRedirectCheck() OVERRIDE; | 100 virtual void didFailRedirectCheck() OVERRIDE; |
101 | 101 |
102 void scheduleInitialConnect(); | 102 void scheduleInitialConnect(); |
103 void connect(); | 103 void connect(); |
104 void networkRequestEnded(); | 104 void networkRequestEnded(); |
105 void scheduleReconnect(); | 105 void scheduleReconnect(); |
106 void connectTimerFired(Timer<EventSource>*); | 106 void connectTimerFired(Timer<EventSource>*); |
107 void abortConnectionAttempt(); | 107 void abortConnectionAttempt(); |
108 void parseEventStream(); | 108 void parseEventStream(); |
109 void parseEventStreamLine(unsigned pos, int fieldLength, int lineLength); | 109 void parseEventStreamLine(unsigned pos, int fieldLength, int lineLength); |
110 PassRefPtr<MessageEvent> createMessageEvent(); | 110 PassRefPtrWillBeRawPtr<MessageEvent> createMessageEvent(); |
111 | 111 |
112 KURL m_url; | 112 KURL m_url; |
113 bool m_withCredentials; | 113 bool m_withCredentials; |
114 State m_state; | 114 State m_state; |
115 | 115 |
116 OwnPtr<TextResourceDecoder> m_decoder; | 116 OwnPtr<TextResourceDecoder> m_decoder; |
117 RefPtr<ThreadableLoader> m_loader; | 117 RefPtr<ThreadableLoader> m_loader; |
118 Timer<EventSource> m_connectTimer; | 118 Timer<EventSource> m_connectTimer; |
119 Vector<UChar> m_receiveBuf; | 119 Vector<UChar> m_receiveBuf; |
120 bool m_discardTrailingNewline; | 120 bool m_discardTrailingNewline; |
121 bool m_requestInFlight; | 121 bool m_requestInFlight; |
122 | 122 |
123 AtomicString m_eventName; | 123 AtomicString m_eventName; |
124 Vector<UChar> m_data; | 124 Vector<UChar> m_data; |
125 AtomicString m_currentlyParsedEventId; | 125 AtomicString m_currentlyParsedEventId; |
126 AtomicString m_lastEventId; | 126 AtomicString m_lastEventId; |
127 unsigned long long m_reconnectDelay; | 127 unsigned long long m_reconnectDelay; |
128 String m_eventStreamOrigin; | 128 String m_eventStreamOrigin; |
129 }; | 129 }; |
130 | 130 |
131 } // namespace WebCore | 131 } // namespace WebCore |
132 | 132 |
133 #endif // EventSource_h | 133 #endif // EventSource_h |
OLD | NEW |