litesoft

Explore

Commits

Diff Revisions 150 vs 151 for /trunk/Java/core/Server/src/org/litesoft/peertopeer/nonpublic/peermanagement/PeerConnectionHandler.java

		@@ -22,8 +22,7 @@
22	22		private BlockingQueue<Serializable> mSenderQueue = new LinkedBlockingQueue<Serializable>();
23	23		private volatile boolean mClosing = false;
24	24
25		-	protected PeerConnectionHandler( PeerConnectionManager pConnectionManager, PeerDefinition pPeerDef,
26		-	Socket pSocket )
	25	+	protected PeerConnectionHandler( PeerConnectionManager pConnectionManager, PeerDefinition pPeerDef, Socket pSocket )
27	26		{
28	27		setName( getClass().getName() );
29	28		mConnectionManager = pConnectionManager;
		@@ -73,8 +72,7 @@
73	72		int count = zByteStream.getCount();
74	73		if ( count > MAX_SERIALIZED_OBJECT_SIZE )
75	74		{
76		-	throw new IOException( "Serialized Object too large (" + count + " > " +
77		-	MAX_SERIALIZED_OBJECT_SIZE + "), Object: " + pToSend );
	75	+	throw new IOException( "Serialized Object too large (" + count + " > " + MAX_SERIALIZED_OBJECT_SIZE + "), Object: " + pToSend );
78	76		}
79	77
80	78		try
		@@ -123,8 +121,7 @@
123	121		int count = ((zHiOrderByte & 0xFF) << 8) + (zLowOrderByte & 0xFF);
124	122		if ( count > MAX_SERIALIZED_OBJECT_SIZE )
125	123		{
126		-	throw new IOException( "De-Serialized Object too large (" + count + " > " +
127		-	MAX_SERIALIZED_OBJECT_SIZE + ")" );
	124	+	throw new IOException( "De-Serialized Object too large (" + count + " > " + MAX_SERIALIZED_OBJECT_SIZE + ")" );
128	125		}
129	126		byte[] buf = new byte[count];
130	127		for ( int i = 0; i < count; i++ )