クラス org.objectweb.cjdbc.controller.core.ControllerWorkerThread

org.objectweb.cjdbc.controller.core.ControllerWorkerThreadのコラボレーション図

[凡例]すべてのメンバ一覧

---

説明

The ControllerWorkerThread handles a connection with a C-JDBC driver. It reads a String containing the virtual database name from the driver and sends back the corresponding ConnectionPoint.

作者:

Emmanuel Cecchet

バージョン:

1.0

ControllerWorkerThread.java の 49 行で定義されています。

Public メソッド
	ControllerWorkerThread (ControllerServerThread serverThread)
void	run ()
スタティック変数
Trace	logger
Private 変数
ControllerServerThread	serverThread
boolean	isKilled = false

---

コンストラクタとデストラクタ

org.objectweb.cjdbc.controller.core.ControllerWorkerThread.ControllerWorkerThread (  ControllerServerThread  serverThread  )

Creates a new ControllerWorkerThread instance. 引数: serverThread  the ControllerServerThread that created us. ControllerWorkerThread.java の 77 行で定義されています。 { super("ControllerWorkerThread"); this.serverThread = serverThread; }

---

メソッド

void org.objectweb.cjdbc.controller.core.ControllerWorkerThread.run (   )

Gets a connection from the connection queue and process it. ControllerWorkerThread.java の 86 行で定義されています。 参照先 org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.addCurrentNbOfThread(), org.objectweb.cjdbc.controller.core.ControllerServerThread.controller, org.objectweb.cjdbc.controller.core.ControllerServerThread.controllerServerThreadPendingQueue, org.objectweb.cjdbc.common.stream.CJDBCOutputStream.flush(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getActiveThreads(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getCurrentNbOfThreads(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getIdleThreads(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getMaxNbOfConnections(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getMaxNbOfThreads(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getMinNbOfThreads(), org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase.getPendingConnections(), org.objectweb.cjdbc.controller.core.Controller.getVirtualDatabase(), org.objectweb.cjdbc.controller.core.ControllerServerThread.idleWorkerThreads, org.objectweb.cjdbc.controller.core.ControllerWorkerThread.isKilled, org.objectweb.cjdbc.controller.core.ControllerServerThread.isShuttingDown, org.objectweb.cjdbc.controller.core.ControllerWorkerThread.logger, org.objectweb.cjdbc.common.stream.CJDBCInputStream.readInt(), org.objectweb.cjdbc.common.stream.CJDBCInputStream.readUTF(), org.objectweb.cjdbc.controller.core.ControllerWorkerThread.serverThread, と org.objectweb.cjdbc.common.stream.CJDBCOutputStream.writeObject(). { Socket clientSocket; if (serverThread == null) { logger.error(Translate.get("controller.workerthread.null.serverthread")); isKilled = true; } else if (serverThread.controllerServerThreadPendingQueue == null) { logger.error(Translate.get("controller.workerthread.null.pendingqueue")); isKilled = true; } // Main loop while (!isKilled) { if (serverThread.isShuttingDown()) break; // Get a connection from the pending queue synchronized (serverThread.controllerServerThreadPendingQueue) { while (serverThread.controllerServerThreadPendingQueue.isEmpty()) { // Nothing to do, let's sleep ... serverThread.idleWorkerThreads++; boolean timeout = false; try { long before = System.currentTimeMillis(); serverThread.controllerServerThreadPendingQueue .wait(ControllerConstants.DEFAULT_CONTROLLER_WORKER_THREAD_SLEEP_TIME); long now = System.currentTimeMillis(); // Check if timeout has expired timeout = now - before >= ControllerConstants.DEFAULT_CONTROLLER_WORKER_THREAD_SLEEP_TIME; } catch (InterruptedException ignore) { } serverThread.idleWorkerThreads--; // We are shutting down if (serverThread.controllerServerThreadPendingQueue == null) { isKilled = true; break; } if (timeout && serverThread.controllerServerThreadPendingQueue.isEmpty()) { // Nothing to do, let's die. isKilled = true; break; } } if (isKilled) break; // Get a connection clientSocket = (Socket) serverThread.controllerServerThreadPendingQueue .remove(0); } // synchronized (serverThread.controllerServerThreadPendingQueue) if (clientSocket == null) { logger.error(Translate.get("controller.workerthread.null.socket")); continue; } else if (logger.isDebugEnabled()) logger.debug(Translate.get("controller.workerthread.connection.from", new String[]{clientSocket.getInetAddress().toString(), String.valueOf(clientSocket.getPort())})); try { // Disable Nagle algorithm else small messages are not sent // (at least under Linux) even if we flush the output stream. clientSocket.setTcpNoDelay(true); // Handle connection CJDBCInputStream in = new CJDBCInputStream(clientSocket); CJDBCOutputStream out = new CJDBCOutputStream(clientSocket); // Check protocol version for driver compatibility int version = in.readInt(); if (version != Commands.ProtocolVersion) { logger.warn(Translate.get( "controller.workerthread.protocol.incompatible", version)); continue; } String virtualDatabaseName = in.readUTF(); // Read the virtual database name VirtualDatabase vdb = serverThread.controller .getVirtualDatabase(virtualDatabaseName); if (vdb == null) { String msg = Translate.get("virtualdatabase.not.found", virtualDatabaseName); logger.warn(msg); continue; } // At this point we have the virtual database the driver wants to // connect to and we have to give the job to a // VirtualDatabaseWorkerThread ArrayList vdbActiveThreads = vdb.getActiveThreads(); ArrayList vdbPendingQueue = vdb.getPendingConnections(); if (vdbActiveThreads == null) { logger.error(Translate .get("controller.workerthread.null.active.thread")); isKilled = true; } if (vdbPendingQueue == null) { logger .error(Translate.get("controller.workerthread.null.connection")); isKilled = true; } // Start minimum number of worker threads boolean tooManyConnections; synchronized (vdbActiveThreads) { while (vdb.getCurrentNbOfThreads() < vdb.getMinNbOfThreads()) { // Fork a new worker thread if (logger.isDebugEnabled()) logger.debug(Translate .get("controller.workerthread.starting.thread.for.minimum")); VirtualDatabaseWorkerThread thread = new VirtualDatabaseWorkerThread( serverThread.controller, vdb); vdbActiveThreads.add(thread); vdb.addCurrentNbOfThread(); thread.start(); } // Check if maximum number of concurrent connections has been // reached tooManyConnections = (vdb.getMaxNbOfConnections() > 0) && vdbActiveThreads.size() + vdbPendingQueue.size() > vdb .getMaxNbOfConnections(); } if (tooManyConnections) { out.writeObject(new SQLException(Translate .get("controller.workerthread.too.many.connections"))); out.flush(); continue; } // Put the connection in the queue synchronized (vdbPendingQueue) { vdbPendingQueue.add(in); vdbPendingQueue.add(out); // Nullify the socket else it is closed in the finally block clientSocket = null; synchronized (vdbActiveThreads) { // Is a thread available? if (vdb.getIdleThreads() == 0) { // No if ((vdb.getCurrentNbOfThreads() <= vdb.getMaxNbOfThreads()) || (vdb.getMaxNbOfThreads() == 0)) { // Fork a new worker thread if (logger.isDebugEnabled()) logger.debug(Translate .get("controller.workerthread.starting.thread")); VirtualDatabaseWorkerThread thread = new VirtualDatabaseWorkerThread( serverThread.controller, vdb); vdbActiveThreads.add(thread); vdb.addCurrentNbOfThread(); thread.start(); } else if (logger.isInfoEnabled()) logger.info(Translate.get( "controller.workerthread.maximum.thread", vdb .getMaxNbOfThreads())); } else { if (logger.isDebugEnabled()) logger.debug(Translate .get("controller.workerthread.notify.thread")); // Here we notify all threads else if one thread doesn't wake // up after the first notify() we will send a second notify() // and one signal will be lost. So the safe way is to wake up // everybody and that worker threads go back to sleep if there // is no job. vdbPendingQueue.notifyAll(); } } } } // } catch (OptionalDataException e) { logger .error(Translate.get("controller.workerthread.protocol.error", e)); } catch (IOException e) { logger.error(Translate.get("controller.workerthread.io.error", e)); } finally { try { if (clientSocket != null) { if (logger.isDebugEnabled()) logger.debug(Translate .get("controller.workerthread.connection.closing")); clientSocket.close(); } } catch (IOException ignore) { } } } if (logger.isDebugEnabled()) logger.debug(Translate.get("controller.workerthread.terminating")); }

---

変数

boolean org.objectweb.cjdbc.controller.core.ControllerWorkerThread.isKilled = false [private]

ControllerWorkerThread.java の 61 行で定義されています。 参照元 org.objectweb.cjdbc.controller.core.ControllerWorkerThread.run().

Trace org.objectweb.cjdbc.controller.core.ControllerWorkerThread.logger [static, package]

初期値: Trace .getLogger("org.objectweb.cjdbc.controller.core.Controller") Logger instance. ControllerWorkerThread.java の 64 行で定義されています。 参照元 org.objectweb.cjdbc.controller.core.ControllerWorkerThread.run().

ControllerServerThread org.objectweb.cjdbc.controller.core.ControllerWorkerThread.serverThread [private]

ControllerWorkerThread.java の 60 行で定義されています。 参照元 org.objectweb.cjdbc.controller.core.ControllerWorkerThread.run().

---

このクラスの説明は次のファイルから生成されました:

• src/org/objectweb/cjdbc/controller/core/ControllerWorkerThread.java

---