.. _program_listing_file_src_o3ds_async_pipeline.cpp:

Program Listing for File async_pipeline.cpp
===========================================

|exhale_lsh| :ref:`Return to documentation for file <file_src_o3ds_async_pipeline.cpp>` (``src/o3ds/async_pipeline.cpp``)

.. |exhale_lsh| unicode:: U+021B0 .. UPWARDS ARROW WITH TIP LEFTWARDS

.. code-block:: cpp

   #include "async_pipeline.h"
   
   namespace O3DS
   {
       bool AsyncClient::start(const char *url)
       {
           int ret;
   
           ret = nng_pair1_open(&mSocket);
           if (ret != 0) { return false; }
   
           ret = nng_aio_alloc(&aio, AsyncPipeline::Callback, this);
           if (ret != 0) { return false; }
   
           ret = nng_dial(mSocket, url, 0, 0);
           if (ret != 0) { return false; }
   
           nng_recv_aio(mSocket, aio);
   
           return true;
       }
   
       bool AsyncServer::start(const char *url)
       {
           int ret;
   
           ret = nng_pair1_open(&mSocket);
           if (ret != 0) { return false; }
   
           ret = nng_aio_alloc(&aio, AsyncPipeline::Callback, this);
           if (ret != 0) { return false; }
   
           ret = nng_listen(mSocket, url, NULL, 0);
           if (ret != 0) return false;
   
           nng_recv_aio(mSocket, aio);
   
           return true;
       }
   
       void AsyncPipeline::Callback_()
       {
           int ret;
   
           ret = nng_aio_result(aio);
           if (ret != 0) return;
   
           char *buf = NULL;
           size_t sz;
           ret = nng_recv(mSocket, &buf, &sz, NNG_FLAG_ALLOC);
           if (ret != 0) return;
   
           if (mInDataFunc) mInDataFunc(mContext, (void*)buf, sz);
   
           nng_free(buf, sz);
   
           nng_recv_aio(mSocket, aio);
       }
   }