Thrift frame size adjustment

Author: davidhjp01

src/proxyfmu/client/proxy_slave.cpp

@@ -63,6 +63,7 @@ proxy_slave::proxy_slave(const filesystem::path& fmuPath, const std::string& ins
         host = remote->host();
         std::shared_ptr<TTransport> socket(new TSocket(host, remote->port()));
         auto transport = std::make_shared<TFramedTransport>(socket);
+        transport->setMaxFrameSize(50 * 1024 * 1024);
         std::shared_ptr<TProtocol> protocol(new TBinaryProtocol(transport));
         auto client = std::make_shared<BootServiceClient>(protocol);
 

tool/proxyfmu.cpp

@@ -42,6 +42,23 @@ class ServerReadyEventHandler : public TServerEventHandler
     }
 };
 
+
+class ProxyFMUFramedTransportFactory : public TTransportFactory
+{
+public:
+    explicit ProxyFMUFramedTransportFactory(uint32_t maxFrameSize)
+        : maxFrameSize_(maxFrameSize)
+    { }
+
+    std::shared_ptr<TTransport> getTransport(std::shared_ptr<TTransport> trans) override
+    {
+        return std::shared_ptr<TTransport>(new TFramedTransport(trans, maxFrameSize_));
+    }
+
+private:
+    uint32_t maxFrameSize_;
+};
+
 const int port_range_min = 49152;
 const int port_range_max = 65535;
 
@@ -50,6 +67,7 @@ const int max_port_retries = 10;
 const int SUCCESS = 0;
 const int COMMANDLINE_ERROR = 1;
 const int UNHANDLED_ERROR = 2;
+const int MAX_FRAME_SIZE = 50 * 1024 * 1024;
 
 
 void wait_for_input()
@@ -68,7 +86,7 @@ int run_booter_application(const int port)
     std::shared_ptr<boot_service_handler> handler(new boot_service_handler());
     std::shared_ptr<TProcessor> processor(new BootServiceProcessor(handler));
 
-    std::shared_ptr<TTransportFactory> transportFactory(new TFramedTransportFactory());
+    std::shared_ptr<TTransportFactory> transportFactory(new ProxyFMUFramedTransportFactory(MAX_FRAME_SIZE));
     std::shared_ptr<TProtocolFactory> protocolFactory(new TBinaryProtocolFactory());
 
     std::shared_ptr<TServerTransport> serverTransport(new TServerSocket(port));
@@ -93,7 +111,7 @@ int run_application(const std::string& fmu, const std::string& instanceName)
     std::shared_ptr<fmu_service_handler> handler(new fmu_service_handler(fmu, instanceName, stop));
     std::shared_ptr<TProcessor> processor(new FmuServiceProcessor(handler));
 
-    std::shared_ptr<TTransportFactory> transportFactory(new TFramedTransportFactory());
+    std::shared_ptr<TTransportFactory> transportFactory(new ProxyFMUFramedTransportFactory(MAX_FRAME_SIZE));
     std::shared_ptr<TProtocolFactory> protocolFactory(new TBinaryProtocolFactory());
 
     proxyfmu::fixed_range_random_generator rng(port_range_min, port_range_max);

version.txt

@@ -1 +1 @@
-0.4.0
+0.4.1