valitydev/thrift
14
0
Fork 0
mirror of https://github.com/valitydev/thrift.git synced 2024-11-07 02:45:22 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Java test client/server fixes

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/incubator/thrift/trunk@665104 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Mark Slee 2007-05-04 18:49:56 +00:00
parent e9a1edc75d
commit fa6ac9f2aa
2 changed files with 15 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
test/java/src/TestClient.java
View File

@ -71,7 +71,7 @@ public class TestClient {
}
TBinaryProtocol binaryProtocol =
new TBinaryProtocol(transport);
new TBinaryProtocol(transport, false, false);
ThriftTest.Client testClient =
new ThriftTest.Client(binaryProtocol);
@ -330,15 +330,19 @@ public class TestClient {
System.out.print(k2 + " => {");
AbstractMap<Integer, Long> userMap = v2.userMap;
System.out.print("{");
for (int k3 : userMap.keySet()) {
System.out.print(k3 + " => " + userMap.get(k3) + ", ");
if (userMap != null) {
for (int k3 : userMap.keySet()) {
System.out.print(k3 + " => " + userMap.get(k3) + ", ");
}
}
System.out.print("}, ");
ArrayList<Xtruct> xtructs = v2.xtructs;
System.out.print("{");
for (Xtruct x : xtructs) {
System.out.print("{" + "\"" + x.string_thing + "\", " + x.byte_thing + ", " + x.i32_thing + ", "+ x.i64_thing + "}, ");
if (xtructs != null) {
for (Xtruct x : xtructs) {
System.out.print("{" + "\"" + x.string_thing + "\", " + x.byte_thing + ", " + x.i32_thing + ", "+ x.i64_thing + "}, ");
}
}
System.out.print("}");

7
test/java/src/TestServer.java
View File

@ -3,6 +3,7 @@ package com.facebook.thrift.test;
import com.facebook.thrift.TException;
import com.facebook.thrift.protocol.TBinaryProtocol;
import com.facebook.thrift.protocol.TProtocol;
import com.facebook.thrift.protocol.TProtocolFactory;
import com.facebook.thrift.server.TServer;
import com.facebook.thrift.server.TSimpleServer;
import com.facebook.thrift.server.TThreadPoolServer;
@ -250,13 +251,17 @@ public class TestServer {
TServerSocket tServerSocket =
new TServerSocket(port);
// Protocol factory
TProtocolFactory tProtocolFactory =
new TBinaryProtocol.Factory(true, true);
TServer serverEngine;
// Simple Server
// serverEngine = new TSimpleServer(testProcessor, tServerSocket);
// ThreadPool Server
serverEngine = new TThreadPoolServer(testProcessor, tServerSocket);
serverEngine = new TThreadPoolServer(testProcessor, tServerSocket, tProtocolFactory);
// Run it
System.out.println("Starting the server on port " + port + "...");