Home | History | Annotate | Download | only in remote-processor 
      1 /*
      2  * Copyright (c) 2016, Intel Corporation
      3  * All rights reserved.
      4  *
      5  * Redistribution and use in source and binary forms, with or without modification,
      6  * are permitted provided that the following conditions are met:
      7  *
      8  * 1. Redistributions of source code must retain the above copyright notice, this
      9  * list of conditions and the following disclaimer.
     10  *
     11  * 2. Redistributions in binary form must reproduce the above copyright notice,
     12  * this list of conditions and the following disclaimer in the documentation and/or
     13  * other materials provided with the distribution.
     14  *
     15  * 3. Neither the name of the copyright holder nor the names of its contributors
     16  * may be used to endorse or promote products derived from this software without
     17  * specific prior written permission.
     18  *
     19  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
     20  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
     21  * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
     22  * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR
     23  * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
     24  * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
     25  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON
     26  * ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
     27  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
     28  * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
     29  */
     30 #include "BackgroundRemoteProcessorServer.h"
     31 #include "RemoteProcessorServer.h"
     32 
     33 BackgroundRemoteProcessorServer::BackgroundRemoteProcessorServer(
     34     std::string bindAddress, std::unique_ptr<IRemoteCommandHandler> &&commandHandler)
     35     : _server(new CRemoteProcessorServer(bindAddress)), mCommandHandler(std::move(commandHandler))
     36 {
     37 }
     38 
     39 bool BackgroundRemoteProcessorServer::start(std::string &error)
     40 {
     41     if (!_server->start(error)) {
     42         return false;
     43     }
     44     try {
     45         mServerSuccess = std::async(std::launch::async, &CRemoteProcessorServer::process,
     46                                     _server.get(), std::ref(*mCommandHandler));
     47     } catch (std::exception &e) {
     48         error = "Could not create a remote processor thread: " + std::string(e.what());
     49         return false;
     50     }
     51 
     52     return true;
     53 }
     54 
     55 bool BackgroundRemoteProcessorServer::stop()
     56 {
     57     _server->stop();
     58     return mServerSuccess.get();
     59 }
     60 
     61 BackgroundRemoteProcessorServer::~BackgroundRemoteProcessorServer()
     62 {
     63     stop();
     64 }
     65