commit 421444f2df2c27fcb1affdbd5bfac6cc972144fa
author Jens Geyer <jensg@apache.org> Wed Mar 20 22:13:25 2019 +0100
committer Jens Geyer <jensg@apache.org> Thu Mar 21 09:03:13 2019 +0100
tree 9fa793943e23d87e6a9dc4bf433d20ca879eb2d0
parent 98c194103de11742b8785bdca49816265a84c32f

THRIFT-4831 interface ITProtocolFactory should be class TProtocolFactory again
Client: netstd
Patch: Jens Geyer

This closes #1767

lib/netstd/Thrift/Server/TServer.cs

diff --git a/lib/netstd/Thrift/Server/TServer.cs b/lib/netstd/Thrift/Server/TServer.cs
index b351913..f40f2b7 100644
--- a/lib/netstd/Thrift/Server/TServer.cs
+++ b/lib/netstd/Thrift/Server/TServer.cs
@@ -29,10 +29,10 @@
     public abstract class TServer
     {
         protected readonly ILogger Logger;
-        protected ITProtocolFactory InputProtocolFactory;
+        protected TProtocolFactory InputProtocolFactory;
         protected TTransportFactory InputTransportFactory;
         protected ITProcessorFactory ProcessorFactory;
-        protected ITProtocolFactory OutputProtocolFactory;
+        protected TProtocolFactory OutputProtocolFactory;
         protected TTransportFactory OutputTransportFactory;
 
         protected TServerEventHandler ServerEventHandler;
@@ -40,7 +40,7 @@
 
         protected TServer(ITProcessorFactory processorFactory, TServerTransport serverTransport,
             TTransportFactory inputTransportFactory, TTransportFactory outputTransportFactory,
-            ITProtocolFactory inputProtocolFactory, ITProtocolFactory outputProtocolFactory,
+            TProtocolFactory inputProtocolFactory, TProtocolFactory outputProtocolFactory,
             ILogger logger = null)
         {
             ProcessorFactory = processorFactory ?? throw new ArgumentNullException(nameof(processorFactory));

lib/netstd/Thrift/Server/TSimpleAsyncServer.cs

diff --git a/lib/netstd/Thrift/Server/TSimpleAsyncServer.cs b/lib/netstd/Thrift/Server/TSimpleAsyncServer.cs
index a0a3e4c..813d3f3 100644
--- a/lib/netstd/Thrift/Server/TSimpleAsyncServer.cs
+++ b/lib/netstd/Thrift/Server/TSimpleAsyncServer.cs
@@ -34,7 +34,7 @@
         private volatile Task _serverTask;
 
         public TSimpleAsyncServer(ITAsyncProcessor processor, TServerTransport serverTransport,
-            ITProtocolFactory inputProtocolFactory, ITProtocolFactory outputProtocolFactory,
+            TProtocolFactory inputProtocolFactory, TProtocolFactory outputProtocolFactory,
             ILoggerFactory loggerFactory, int clientWaitingDelay = 10)
             : this(new TSingletonProcessorFactory(processor), serverTransport,
                 new TTransportFactory(), new TTransportFactory(),
@@ -45,7 +45,7 @@
 
         public TSimpleAsyncServer(ITProcessorFactory itProcessorFactory, TServerTransport serverTransport,
             TTransportFactory inputTransportFactory, TTransportFactory outputTransportFactory,
-            ITProtocolFactory inputProtocolFactory, ITProtocolFactory outputProtocolFactory,
+            TProtocolFactory inputProtocolFactory, TProtocolFactory outputProtocolFactory,
             ILogger logger, int clientWaitingDelay = 10)
             : base(itProcessorFactory, serverTransport, inputTransportFactory, outputTransportFactory,
                 inputProtocolFactory, outputProtocolFactory, logger)

lib/netstd/Thrift/Server/TThreadPoolAsyncServer.cs

diff --git a/lib/netstd/Thrift/Server/TThreadPoolAsyncServer.cs b/lib/netstd/Thrift/Server/TThreadPoolAsyncServer.cs
index e5c5660..1c76b68 100644
--- a/lib/netstd/Thrift/Server/TThreadPoolAsyncServer.cs
+++ b/lib/netstd/Thrift/Server/TThreadPoolAsyncServer.cs
@@ -77,7 +77,7 @@
         public TThreadPoolAsyncServer(ITAsyncProcessor processor,
          TServerTransport serverTransport,
          TTransportFactory transportFactory,
-         ITProtocolFactory protocolFactory)
+         TProtocolFactory protocolFactory)
             : this(new TSingletonProcessorFactory(processor), serverTransport,
                transportFactory, transportFactory,
                protocolFactory, protocolFactory,
@@ -88,7 +88,7 @@
         public TThreadPoolAsyncServer(ITProcessorFactory processorFactory,
                      TServerTransport serverTransport,
                      TTransportFactory transportFactory,
-                     ITProtocolFactory protocolFactory)
+                     TProtocolFactory protocolFactory)
             : this(processorFactory, serverTransport,
              transportFactory, transportFactory,
              protocolFactory, protocolFactory,
@@ -100,8 +100,8 @@
                      TServerTransport serverTransport,
                      TTransportFactory inputTransportFactory,
                      TTransportFactory outputTransportFactory,
-                     ITProtocolFactory inputProtocolFactory,
-                     ITProtocolFactory outputProtocolFactory,
+                     TProtocolFactory inputProtocolFactory,
+                     TProtocolFactory outputProtocolFactory,
                      int minThreadPoolThreads, int maxThreadPoolThreads, ILogger logger= null)
             : this(processorFactory, serverTransport, inputTransportFactory, outputTransportFactory,
              inputProtocolFactory, outputProtocolFactory,
@@ -114,8 +114,8 @@
                      TServerTransport serverTransport,
                      TTransportFactory inputTransportFactory,
                      TTransportFactory outputTransportFactory,
-                     ITProtocolFactory inputProtocolFactory,
-                     ITProtocolFactory outputProtocolFactory,
+                     TProtocolFactory inputProtocolFactory,
+                     TProtocolFactory outputProtocolFactory,
                      Configuration threadConfig,
                      ILogger logger = null)
             : base(processorFactory, serverTransport, inputTransportFactory, outputTransportFactory,