crowetic/protocol
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix linter

Browse Source
This commit is contained in:
Fabio Berger
2019-03-20 13:48:59 +01:00
parent 7cd27cd9c8
commit 941877a05a
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
packages/order-watcher/src/order_watcher/order_watcher.ts
View File

@@ -85,7 +85,7 @@ export class OrderWatcher {
private readonly _dependentOrderHashesTracker: DependentOrderHashesTracker; private readonly _dependentOrderHashesTracker: DependentOrderHashesTracker;
private readonly _orderStateByOrderHashCache: OrderStateByOrderHash = {}; private readonly _orderStateByOrderHashCache: OrderStateByOrderHash = {};
private readonly _orderByOrderHash: OrderByOrderHash = {}; private readonly _orderByOrderHash: OrderByOrderHash = {};
private readonly _orderByOrderHashLock = new Lock(); private readonly _lock = new Lock();
private readonly _eventWatcher: EventWatcher; private readonly _eventWatcher: EventWatcher;
private readonly _provider: ZeroExProvider; private readonly _provider: ZeroExProvider;
private readonly _collisionResistantAbiDecoder: CollisionResistanceAbiDecoder; private readonly _collisionResistantAbiDecoder: CollisionResistanceAbiDecoder;
@@ -234,13 +234,13 @@ export class OrderWatcher {
}; };
} }
private async _addLockToCallbackAsync(cbAsync: any, ...params: any[]): Promise<void> { private async _addLockToCallbackAsync(cbAsync: any, ...params: any[]): Promise<void> {
await this._orderByOrderHashLock.acquire(); await this._lock.acquire();
try { try {
await cbAsync(...params); await cbAsync(...params);
await this._orderByOrderHashLock.release(); await this._lock.release();
} catch (err) { } catch (err) {
// Make sure to releasee the lock if an error is thrown // Make sure to releasee the lock if an error is thrown
await this._orderByOrderHashLock.release(); await this._lock.release();
throw err; throw err;
} }
} }
@@ -508,4 +508,4 @@ export class OrderWatcher {
this._callbackIfExists(null, orderState); this._callbackIfExists(null, orderState);
} }
} }
} } // tslint:disable:max-file-line-count