Skip to content

Commit

Permalink
rename SQLStatementExecutor.ready to wakeUp
Browse files Browse the repository at this point in the history
  • Loading branch information
codefollower committed Feb 9, 2017
1 parent 0572616 commit 64ec33a
Show file tree
Hide file tree
Showing 5 changed files with 10 additions and 10 deletions.
Expand Up @@ -23,6 +23,6 @@ public interface SQLStatementExecutor {


void executeNextStatementIfNeeded(PreparedStatement current); void executeNextStatementIfNeeded(PreparedStatement current);


void ready(); void wakeUp();


} }
Expand Up @@ -1855,7 +1855,7 @@ public Page call() throws Exception {
Page p = Page.read(fileStore, pos, map, filePos, maxPos); Page p = Page.read(fileStore, pos, map, filePos, maxPos);
cachePage(pos, p, p.getMemory()); cachePage(pos, p, p.getMemory());
if (sqlStatementExecutor != null) if (sqlStatementExecutor != null)
sqlStatementExecutor.ready(); sqlStatementExecutor.wakeUp();
return p; return p;
} }
}; };
Expand Down
Expand Up @@ -424,7 +424,7 @@ private void addPreparedCommandToQueue(PreparedCommand pc, int sessionId) {
} }


sessionInfo.preparedCommandQueue.add(pc); sessionInfo.preparedCommandQueue.add(pc);
sessionInfo.commandHandler.ready(); sessionInfo.commandHandler.wakeUp();
} }


void sendError(Transfer transfer, int id, Throwable t) { void sendError(Transfer transfer, int id, Throwable t) {
Expand Down
4 changes: 2 additions & 2 deletions lealone-net/src/main/java/org/lealone/net/CommandHandler.java
Expand Up @@ -101,11 +101,11 @@ public void run() {


public void end() { public void end() {
stop = true; stop = true;
ready(); wakeUp();
} }


@Override @Override
public void ready() { public void wakeUp() {
haveWork.release(1); haveWork.release(1);
} }


Expand Down
10 changes: 5 additions & 5 deletions lealone-net/src/main/java/org/lealone/net/PreparedCommand.java
Expand Up @@ -22,11 +22,11 @@


public class PreparedCommand { public class PreparedCommand {


int id; final int id;
PreparedStatement stmt; final PreparedStatement stmt;
Transfer transfer; final Transfer transfer;
Session session; final Session session;
Runnable runnable; private final Runnable runnable;


PreparedCommand(int id, PreparedStatement stmt, Transfer transfer, Session session, Runnable runnable) { PreparedCommand(int id, PreparedStatement stmt, Transfer transfer, Session session, Runnable runnable) {
this.id = id; this.id = id;
Expand Down

0 comments on commit 64ec33a

Please sign in to comment.