less logs
This commit is contained in:
parent
a5506800df
commit
ab76283131
1 changed files with 2 additions and 2 deletions
|
|
@ -38,7 +38,7 @@ export default class {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
async Read(read: (tx: DataSource | EntityManager) => Promise<any>) {
|
async Read(read: (tx: DataSource | EntityManager) => Promise<any>) {
|
||||||
console.log("Read", this.activeReaders, this.pendingTx, this.writeRequested)
|
//console.log("Read", this.activeReaders, this.pendingTx, this.writeRequested)
|
||||||
if (!this.writeRequested) {
|
if (!this.writeRequested) {
|
||||||
return this.executeRead(read)
|
return this.executeRead(read)
|
||||||
}
|
}
|
||||||
|
|
@ -71,7 +71,7 @@ export default class {
|
||||||
}
|
}
|
||||||
|
|
||||||
PushToQueue<T>(op: TxOperation<T>) {
|
PushToQueue<T>(op: TxOperation<T>) {
|
||||||
console.log("PushToQueue", this.activeReaders, this.pendingTx, this.writeRequested)
|
//console.log("PushToQueue", this.activeReaders, this.pendingTx, this.writeRequested)
|
||||||
this.writeRequested = true
|
this.writeRequested = true
|
||||||
if (!this.pendingTx && this.activeReaders === 0) {
|
if (!this.pendingTx && this.activeReaders === 0) {
|
||||||
return this.execQueueItem(op)
|
return this.execQueueItem(op)
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue