try {
			int receivedBytes=0;
			byte[] dataBuffer = new byte[Hub.SESSION_BUFFER_SIZE];
			InputStream stream=mClientSocket.getInputStream();
			
			//Пока данные есть...
			while ((receivedBytes = stream.read(dataBuffer, 0, dataBuffer.length)) != -1) {
				if(!isPeerToPeer()){
					mPacketSplitter.splitData(dataBuffer, receivedBytes);
				}
				else{
					getPartner().sendRawData(dataBuffer, receivedBytes);
				}
			}

			removeSession();
		}catch (Exception e) {
			removeSession();
		}
		finally{
			try {
				mClientSocket.close();
			} catch (IOException e) {
				System.out.println(String.format("ERROR CLOSE! ID =%s",getHostId()));
				e.printStackTrace();
			}
		}

private class ListenConnections implements Runnable
	{
		public void run() {
			try {
				
				Socket acceptClient = null;
				
				while(true){
					
					acceptClient=mSocketListener.accept();
					
					if(SESSONS_COUNT<SETTINGS.HUB_MAX_CONNECTIONS){
						acceptClient.setSoTimeout(SETTINGS.HUB_TIME_OUT);
						new Thread(new Session(acceptClient,Hub.this)).start();
						SESSONS_COUNT++;
					}else{
						sendData(acceptClient, new Packets.Error(ErrorCodes.SERVER_OVERLOADED));
						acceptClient.close();
					}
					
				}
			}catch(Exception ex){
				ex.printStackTrace();
				if(!mStopServer){
					LogHelper.logError(ex, "ListenConnections");
				}				
			}
		}
	}

public void signInHost(Session session,Packets.HelloServer hello) {
		synchronized (mSignInSemaphore) {
			//Connection mConnection=null;
			CallableStatement mStatement = null;
			ResultSet mResult = null;

			try {
				try{
					
					//mConnection=getDbConnection();
					mStatement = mConnection.prepareCall("CALL SIGN_IN_HOST(?,?,?,?,?,?,?,?)");
					mStatement.setString(1, hello.name);
					mStatement.setString(2, hello.password);
					
                                        ....................................................
					....................................................

					mResult = mStatement.executeQuery();
					mConnection.commit();
					
					if (mResult.next()) {

						if (mResult.getString(1).equals("NOT_REGISTERED")) {
							session.sendData(new Packets.Error(ErrorCodes.INVALID_USERNAME_OR_PASSWORD));
							session.killSession();
						} else if (mResult.getString(1).equals("BUSY")) {
							session.killSession();
						} else if (mResult.getString(1).equals("ONLINE")) {
							session.setSessionId(mStatement.getResultSet().getInt(4));
							session.setLogId(mStatement.getResultSet().getInt(3));
							session.setHostId(mStatement.getResultSet().getInt(2));
							session.sessionType = Session.SessionType.Host;
							session.sendData(new Packets.HelloHost());
							session.setEncryptionKey(hello.password.substring(0, 15));
		
							HOSTS_SESSIONS.put(session.getHostId(), session);
						}

					} else {
						session.killSession();
					}
				}
				catch(SQLException e){
					LogHelper.logError(e, "signInHost");
					session.killSession();
					if(mConnection!=null){mConnection.rollback();}
				}
			} catch (Exception e) {
				LogHelper.logError(e, "signInHost");
				session.killSession();
			}
			finally {
				try {
					//if (mConnection!=null){mConnection.close();}
					if (mStatement != null) {mStatement.close();}
					if (mResult != null) {mResult.close();}
				} catch (SQLException e) {
					LogHelper.logError(e, "signInHost");
				}
			}
		}
    }