status-im
/
react-native
mirror of https://github.com/status-im/react-native.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Refactor MessageQueue 

Summary:
Looking to address a few new `FlowFixMe`s I had to do some minor refactoring of `MessageQueue`. Has the advantage of (IMO) making things clearer by removing a redundant counter and some gratuitous bitwise operations.

Previously `_callbacks` was an array of `?Function`s where even elements were failure callbacks and odd elements were successes. Each new call incremented `_callID` by one and `_callbackID` by two. I've changed this to use two arrays `_successCallbacks` and `_failureCallbacks` indexed by `callID`. That made the `_callbackID` counter unnecessary and reduced the need for computed indices.

Tested with flow and a quick play with UIExplorer.
Closes https://github.com/facebook/react-native/pull/11986

Differential Revision: D4962162

Pulled By: javache

fbshipit-source-id: 17dddfedc0cb5950dbdd9bd06fae6eb6de4c4a7d
This commit is contained in:
rh389 2017-04-28 03:47:19 -07:00 committed by Facebook Github Bot
parent 96d13b663b
commit 0a55e42ef6
1 changed files with 24 additions and 34 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
Libraries/BatchedBridge/MessageQueue.js
View File

@ -44,8 +44,8 @@ const DEBUG_INFO_LIMIT = 32;
class MessageQueue { class MessageQueue {
_callableModules: {[key: string]: Object}; _callableModules: {[key: string]: Object};
_queue: [Array<number>, Array<number>, Array<any>, number]; _queue: [Array<number>, Array<number>, Array<any>, number];
_callbacks: []; _successCallbacks: Array<?Function>;
_callbackID: number; _failureCallbacks: Array<?Function>;
_callID: number; _callID: number;
_inCall: number; _inCall: number;
_lastFlush: number; _lastFlush: number;
@ -60,8 +60,8 @@ class MessageQueue {
constructor() { constructor() {
this._callableModules = {}; this._callableModules = {};
this._queue = [[], [], [], 0]; this._queue = [[], [], [], 0];
this._callbacks = []; this._successCallbacks = [];
this._callbackID = 0; this._failureCallbacks = [];
this._callID = 0; this._callID = 0;
this._lastFlush = 0; this._lastFlush = 0;
this._eventLoopStartTime = new Date().getTime(); this._eventLoopStartTime = new Date().getTime();
@ -143,22 +143,17 @@ class MessageQueue {
enqueueNativeCall(moduleID: number, methodID: number, params: Array<any>, onFail: ?Function, onSucc: ?Function) { enqueueNativeCall(moduleID: number, methodID: number, params: Array<any>, onFail: ?Function, onSucc: ?Function) {
if (onFail || onSucc) { if (onFail || onSucc) {
if (__DEV__) { if (__DEV__) {
const callId = this._callbackID >> 1; this._debugInfo[this._callID] = [moduleID, methodID];
this._debugInfo[callId] = [moduleID, methodID]; if (this._callID > DEBUG_INFO_LIMIT) {
if (callId > DEBUG_INFO_LIMIT) { delete this._debugInfo[this._callID - DEBUG_INFO_LIMIT];
delete this._debugInfo[callId - DEBUG_INFO_LIMIT];
} }
} }
onFail && params.push(this._callbackID); // Encode callIDs into pairs of callback identifiers by shifting left and using the rightmost bit
/* $FlowFixMe(>=0.38.0 site=react_native_fb,react_native_oss) - Flow error // to indicate fail (0) or success (1)
* detected during the deployment of v0.38.0. To see the error, remove onFail && params.push(this._callID << 1);
* this comment and run flow */ onSucc && params.push((this._callID << 1) | 1);
this._callbacks[this._callbackID++] = onFail; this._successCallbacks[this._callID] = onSucc;
onSucc && params.push(this._callbackID); this._failureCallbacks[this._callID] = onFail;
/* $FlowFixMe(>=0.38.0 site=react_native_fb,react_native_oss) - Flow error
* detected during the deployment of v0.38.0. To see the error, remove
* this comment and run flow */
this._callbacks[this._callbackID++] = onSucc;
} }
if (__DEV__) { if (__DEV__) {
@ -255,13 +250,16 @@ class MessageQueue {
__invokeCallback(cbID: number, args: Array<any>) { __invokeCallback(cbID: number, args: Array<any>) {
this._lastFlush = new Date().getTime(); this._lastFlush = new Date().getTime();
this._eventLoopStartTime = this._lastFlush; this._eventLoopStartTime = this._lastFlush;
const callback = this._callbacks[cbID];
// The rightmost bit of cbID indicates fail (0) or success (1), the other bits are the callID shifted left.
const callID = cbID >>> 1;
const callback = (cbID & 1) ? this._successCallbacks[callID] : this._failureCallbacks[callID];
if (__DEV__) { if (__DEV__) {
const debug = this._debugInfo[cbID >> 1]; const debug = this._debugInfo[callID];
const module = debug && this._remoteModuleTable[debug[0]]; const module = debug && this._remoteModuleTable[debug[0]];
const method = debug && this._remoteMethodTable[debug[0]][debug[1]]; const method = debug && this._remoteMethodTable[debug[0]][debug[1]];
if (callback == null) { if (!callback) {
let errorMessage = `Callback with id ${cbID}: ${module}.${method}() not found`; let errorMessage = `Callback with id ${cbID}: ${module}.${method}() not found`;
if (method) { if (method) {
errorMessage = `The callback ${method}() exists in module ${module}, ` errorMessage = `The callback ${method}() exists in module ${module}, `
@ -278,21 +276,13 @@ class MessageQueue {
} }
Systrace.beginEvent( Systrace.beginEvent(
`MessageQueue.invokeCallback(${profileName}, ${stringifySafe(args)})`); `MessageQueue.invokeCallback(${profileName}, ${stringifySafe(args)})`);
} else {
if (!callback) {
return;
}
} }
/* $FlowFixMe(>=0.38.0 site=react_native_fb,react_native_oss) - Flow error if (!callback) {
* detected during the deployment of v0.38.0. To see the error, remove this return;
* comment and run flow */ }
this._callbacks[cbID & ~1] = null;
/* $FlowFixMe(>=0.38.0 site=react_native_fb,react_native_oss) - Flow error this._successCallbacks[callID] = this._failureCallbacks[callID] = null;
* detected during the deployment of v0.38.0. To see the error, remove this
* comment and run flow */
this._callbacks[cbID | 1] = null;
// $FlowIssue(>=0.35.0) #14551610
callback.apply(null, args); callback.apply(null, args);
if (__DEV__) { if (__DEV__) {