Skip to content

Commit

Permalink
db.js use var slot to save arr[idx]
Browse files Browse the repository at this point in the history
  • Loading branch information
kaven276 committed Sep 28, 2012
1 parent df383d3 commit 988bfe8
Showing 1 changed file with 9 additions and 7 deletions.
16 changes: 9 additions & 7 deletions lib/db.js
Expand Up @@ -79,11 +79,12 @@ var dbListener = net.createServer({allowHalfOpen : true}, function(c){
} }


logger.db('oracle server(%d:%d) connected, now has %d', c.sid, c.serial, dbListener.connections); logger.db('oracle server(%d:%d) connected, now has %d', c.sid, c.serial, dbListener.connections);
if (dbPool[c.pseq]) { var slot = dbPool[c.pseq];
dbPool[c.pseq].oraSock = c; if (slot) {
dbPool[c.pseq].status = 'free'; slot.oraSock = c;
slot.status = 'free';
} else { } else {
dbPool[c.pseq] = new Slot(c); slot = dbPool[c.pseq] = new Slot(c);
} }
freeList.push(c); freeList.push(c);


Expand All @@ -92,9 +93,9 @@ var dbListener = net.createServer({allowHalfOpen : true}, function(c){
c.on('end', function(pos){ c.on('end', function(pos){
logger.db('oracle server(%d:%d) disconnected, now has %d', c.sid, c.serial, dbListener.connections); logger.db('oracle server(%d:%d) disconnected, now has %d', c.sid, c.serial, dbListener.connections);


dbPool[c.pseq].hBytesRead += c.bytesRead; slot.hBytesRead += c.bytesRead;
dbPool[c.pseq].hBytesWritten += c.bytesWritten; slot.hBytesWritten += c.bytesWritten;
dbPool[c.pseq].status = 'closed'; slot.status = 'closed';


pos = find(quitList, c); pos = find(quitList, c);
if (~pos) { if (~pos) {
Expand Down Expand Up @@ -201,6 +202,7 @@ function pushBackToFreelist(oraSock, busyRec){
logger.db('push back to %d', oraSock.seq); logger.db('push back to %d', oraSock.seq);
oraSock.removeAllListeners('data'); oraSock.removeAllListeners('data');
oraSock.removeAllListeners('timeout'); oraSock.removeAllListeners('timeout');

// mark this busyRec has no oraSock for use, css/fb depend on it to detect timeout clearup // mark this busyRec has no oraSock for use, css/fb depend on it to detect timeout clearup
freeList.unshift(oraSock); freeList.unshift(oraSock);
dbPool[oraSock.pseq].status = 'free'; dbPool[oraSock.pseq].status = 'free';
Expand Down

0 comments on commit 988bfe8

Please sign in to comment.