OLD | NEW |
1 /* | 1 /* |
2 * Copyright (C) 2012 Google Inc. All rights reserved. | 2 * Copyright (C) 2012 Google Inc. All rights reserved. |
3 * | 3 * |
4 * Redistribution and use in source and binary forms, with or without | 4 * Redistribution and use in source and binary forms, with or without |
5 * modification, are permitted provided that the following conditions | 5 * modification, are permitted provided that the following conditions |
6 * are met: | 6 * are met: |
7 * 1. Redistributions of source code must retain the above copyright | 7 * 1. Redistributions of source code must retain the above copyright |
8 * notice, this list of conditions and the following disclaimer. | 8 * notice, this list of conditions and the following disclaimer. |
9 * 2. Redistributions in binary form must reproduce the above copyright | 9 * 2. Redistributions in binary form must reproduce the above copyright |
10 * notice, this list of conditions and the following disclaimer in the | 10 * notice, this list of conditions and the following disclaimer in the |
(...skipping 269 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
280 void RTCDataChannel::didReceiveRawData(const char* data, size_t dataLength) | 280 void RTCDataChannel::didReceiveRawData(const char* data, size_t dataLength) |
281 { | 281 { |
282 if (m_stopped) | 282 if (m_stopped) |
283 return; | 283 return; |
284 | 284 |
285 if (m_binaryType == BinaryTypeBlob) { | 285 if (m_binaryType == BinaryTypeBlob) { |
286 // FIXME: Implement. | 286 // FIXME: Implement. |
287 return; | 287 return; |
288 } | 288 } |
289 if (m_binaryType == BinaryTypeArrayBuffer) { | 289 if (m_binaryType == BinaryTypeArrayBuffer) { |
290 RefPtr<DOMArrayBuffer> buffer = DOMArrayBuffer::create(data, dataLength)
; | 290 RefPtr<DOMArrayBuffer> buffer = DOMArrayBuffer::createOrNull(data, dataL
ength); |
291 scheduleDispatchEvent(MessageEvent::create(buffer.release())); | 291 // Being out of memory results in silent failure: message dropped. |
| 292 if (buffer) |
| 293 scheduleDispatchEvent(MessageEvent::create(buffer.release())); |
292 return; | 294 return; |
293 } | 295 } |
294 ASSERT_NOT_REACHED(); | 296 ASSERT_NOT_REACHED(); |
295 } | 297 } |
296 | 298 |
297 void RTCDataChannel::didDetectError() | 299 void RTCDataChannel::didDetectError() |
298 { | 300 { |
299 if (m_stopped) | 301 if (m_stopped) |
300 return; | 302 return; |
301 | 303 |
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
353 | 355 |
354 DEFINE_TRACE(RTCDataChannel) | 356 DEFINE_TRACE(RTCDataChannel) |
355 { | 357 { |
356 visitor->trace(m_executionContext); | 358 visitor->trace(m_executionContext); |
357 visitor->trace(m_scheduledEvents); | 359 visitor->trace(m_scheduledEvents); |
358 visitor->template registerWeakMembers<RTCDataChannel, &RTCDataChannel::clear
WeakMembers>(this); | 360 visitor->template registerWeakMembers<RTCDataChannel, &RTCDataChannel::clear
WeakMembers>(this); |
359 RefCountedGarbageCollectedEventTargetWithInlineData<RTCDataChannel>::trace(v
isitor); | 361 RefCountedGarbageCollectedEventTargetWithInlineData<RTCDataChannel>::trace(v
isitor); |
360 } | 362 } |
361 | 363 |
362 } // namespace blink | 364 } // namespace blink |
OLD | NEW |