Delta V Software Forums

Code: Select all

class HelloWorldImpl
{
public:

    typedef RCF::RemoteCallContext<int, const std::string&> PrintContext;

    int Print(const std::string & s)
    {
        // Capture current remote call context.
        PrintContext printContext(RCF::getCurrentRcfSession());

        // Create a new thread to dispatch the remote call.
        RCF::ThreadPtr threadPtr( new RCF::Thread( boost::bind(
            &HelloWorldImpl::threadFunc, 
            this, 
            printContext) ) );

        return 0;
    }

    void threadFunc(PrintContext printContext)
    {
        const std::string & s = printContext.parameters().a1.get();
        std::cout << "I_HelloWorld service: " << s << std::endl;
        RCF::sleepMs(200000);     // <===
        printContext.parameters().r.set( s.length() );
        printContext.commit();
    }
};

int main()
{
    ...
    RCF::RcfServer server( RCF::TcpEndpoint("0.0.0.0", 50001) );
    ...
    server.start();
    // remote client call remote method "Print"
    server.stop();   // <=== 
    ...
}