Delta V Software Forums

Code: Select all

#include <algorithm>
#include <iostream>
#include <string>
#include <vector>
#include <RCF/RCF.hpp>
#include "MyService.hpp"

class Session
{
public:
	Session()
	{
		std::cout << "+ Session #" << this << std::endl;
	}

	~Session()
	{
		std::cout << "- Session #" << this << std::endl;
	}
};

class MyServiceImpl
{
public:
    // Reverses the order of strings in the vector.
    void reverse(std::vector<std::string> &v)
    {
        RCF::getCurrentRcfSession().getSessionObject<Session>(true);

        std::cout << "Reversing a vector of strings...\n";
        std::vector<std::string> w;
        std::copy(v.rbegin(), v.rend(), std::back_inserter(w));
        v.swap(w);
    }
};

int main()
{
    RCF::RcfInitDeinit rcfInit;

    // Start a TCP server on port 50001, and expose MyServiceImpl.
    MyServiceImpl myServiceImpl;
    RCF::RcfServer server( RCF::TcpEndpoint("0.0.0.0", 50001) );
    server.bind<MyService>(myServiceImpl);
    server.start();

    std::cout << "Press Enter to exit..." << std::endl;
    std::cin.get();

    return 0;
}

Code: Select all

#include <algorithm>
#include <iostream>
#include <iterator>
#include <string>
#include <vector>

#include "MyService.hpp"

#include <RCF/RCF.hpp>

int main()
{
    RCF::RcfInitDeinit rcfInit;

    try
    {
        // Setup a vector of strings.
        std::vector<std::string> v;
        v.push_back("one");
        v.push_back("two");
        v.push_back("three");

        // Print them out.
        std::cout << "Before:\n";
        std::copy(
            v.begin(), 
            v.end(), 
            std::ostream_iterator<std::string>(std::cout, "\n"));

        // Make the call.
        RcfClient<MyService> Client( RCF::TcpEndpoint("server", 50001) ); // put server address here
        Client.reverse(v);

        // Print them out again. This time they are in reverse order.
        std::cout << "\nAfter:\n";
        std::copy(
            v.begin(), 
            v.end(), 
            std::ostream_iterator<std::string>(std::cout, "\n"));

	    std::cout << "Press Enter to exit..." << std::endl;
	    std::cin.get();
    }
    catch(const RCF::Exception & e)
    {
        std::cout << "Caught exception:\n";
        std::cout << e.getError().getErrorString() << std::endl;
        return 1;
    }

    return 0;
}

Code: Select all

C:\>netstat -n

...
  TCP    192.168.64.129:50001   192.168.64.128:1040    ESTABLISHED

Code: Select all

	RCF::RcfServer server;

	// Sessions idle for 5 minutes will be terminated.
	server.setSessionTimeoutMs(5*60*1000); 

	// Scan for idle sessions every 60 seconds.
	server.setSessionHarvestingIntervalMs(1*60*1000);

	server.start();

Code: Select all

#include <RCF/SessionTimeoutService.hpp>

            RCF::RcfServer(...);      

            const boost::uint32_t SessionTimeoutMs = 5*60*1000;
            const boost::uint32_t ReapingIntervalMs = 1*60*1000;

            RCF::SessionTimeoutServicePtr stsPtr( 
                new RCF::SessionTimeoutService(SessionTimeoutMs, ReapingIntervalMs) );

            server.addService(stsPtr);

            server.start();