clientthread.java

derby database source code.good for you.

/*

   Derby - Class org.apache.derby.impl.drda.ClientThread

   Copyright 2002, 2004 The Apache Software Foundation or its licensors, as applicable.

   Licensed under the Apache License, Version 2.0 (the "License");
   you may not use this file except in compliance with the License.
   You may obtain a copy of the License at

      http://www.apache.org/licenses/LICENSE-2.0

   Unless required by applicable law or agreed to in writing, software
   distributed under the License is distributed on an "AS IS" BASIS,
   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   See the License for the specific language governing permissions and
   limitations under the License.

 */

package org.apache.derby.impl.drda;

import java.io.*;
import java.net.*;
import java.security.*;

final class ClientThread extends Thread {

	NetworkServerControlImpl parent;
	ServerSocket serverSocket;
	private int timeSlice;
	private int connNum;

		ClientThread (NetworkServerControlImpl nsi, ServerSocket ss) {

			// Create a more meaningful name for this thread (but preserve its
			// thread id from the default name).
			NetworkServerControlImpl.setUniqueThreadName(this, "NetworkServerThread");

			parent=nsi;
			serverSocket=ss;
			timeSlice=nsi.getTimeSlice();
		}
			
		public void run() 
		{

			Socket clientSocket = null;
			Session clientSession = null;


			for (;;)
			{
				try {
	          		try{
	             			clientSocket = (Socket) AccessController.doPrivileged(
						new PrivilegedExceptionAction() {
							public Object run() throws IOException
							{
								return serverSocket.accept();
							}
						}
					 );
							clientSocket.setKeepAlive(parent.getKeepAlive());
					//set time out					
					//this looks highly suspect.  Why does timeSlice setSoTimeout?		
					if (timeSlice != 0)
						clientSocket.setSoTimeout(timeSlice);
				} catch (PrivilegedActionException e) {
					Exception e1 = e.getException();
	            			if (e1 instanceof IOException){
						synchronized(parent.getShutdownSync()) {
							if (!parent.getShutdown())
	                					parent.consolePropertyMessage("DRDA_UnableToAccept.S");
							}
					} else throw e1;
	                		break;
				} // end priv try/catch block
				
				connNum = parent.getNewConnNum();
	                	parent.consolePropertyMessage("DRDA_ConnNumber.I", 
							Integer.toString(connNum));

				//create a new Session for this session
				// Note that we always re-fetch the tracing
				// configuration from the parent, because it
				// may have changed (there are administrative
				// commands which allow dynamic tracing
				// reconfiguration).
				clientSession = new Session(connNum, clientSocket, 
					parent.getTraceDirectory(),
					parent.getTraceAll());

				//add to Session list
				parent.addToSessionTable(new Integer(connNum), clientSession);

				//create a new thread for this connection if we need one
				//and if we are allowed
				if (parent.getFreeThreads() == 0 && 
					(parent.getMaxThreads() == 0  || 
					parent.getThreadList().size() < parent.getMaxThreads()))
				{
					DRDAConnThread thread = new DRDAConnThread(clientSession, 
						parent, timeSlice, parent.getLogConnections());
					parent.getThreadList().addElement(thread);
					thread.start();
				}
				else //wait for a free thread
					parent.runQueueAdd(clientSession);
				}catch (Exception e) {
					if (e instanceof InterruptedException)
						return;
					parent.consoleExceptionPrintTrace(e);
				} // end outer try/catch block
			} // end for(;;)

		}// end run()
}