Gocrazy

#pragma once
#include <string>

#include "soa/service/http_endpoint.h"
#include "soa/service/json_endpoint.h"
#include "soa/service/zmq_named_pub_sub.h"
#include "adserver_connector.h"

namespace RTBKIT {

Gocrazy

var child_process = require('child_process');
var net = require('net');
 
var tcpSrv = net.createServer();
tcpSrv.listen(3000, function() {
            for (var i = 1; i <= 4; i++) {
                            var worker = child_process.fork('worker.js');
                            worker.send(i, tcpSrv._handle);
            }
            tcpSrv.close();

Gocrazy

#pragma once
#include <vector>
#include "soa/types/id.h"
#include "soa/types/string.h"
#include "soa/types/url.h"
#include "jml/utils/compact_vector.h"
#include "soa/jsoncpp/value.h"
#include "openrtb/openrtb.h"
#include "openrtb/openrtb_parsing.h"

Gocrazy

#pragma once

#include "soa/types/value_description.h"
#include "soa/types/basic_value_descriptions.h"
#include "soa/types/json_parsing.h"
#include "smaato.h"
#include <boost/lexical_cast.hpp>

namespace Datacratic {
template<>

Gocrazy

#include "smaato_parsing.h"
#include "soa/types/json_parsing.h"

using namespace Smaato;
using namespace std;

namespace Datacratic {

DefaultDescription<BidRequest>::
DefaultDescription()

Gocrazy

#include "smaato_bid_request.h"
#include "smaato.h"
#include "smaato_parsing.h"
#include "jml/utils/json_parsing.h"

using namespace std;

namespace RTBKIT {

BidRequest *

Gocrazy

#pragma once

#include "rtbkit/common/bid_request.h"
#include "smaato.h"
#include "jml/utils/parse_context.h"

namespace RTBKIT {

BidRequest *
fromSmaato(Smaato::BidRequest && req,

Gocrazy

{
  "at": 2,
  "device": {
    "connectiontype": 0,
    "devicetype": 1,
    "geo": {
      "lat": 42.357777,
      "lon": -71.06167,
      "type": 3
    },

Gocrazy

#include "smaato_exchange_connector.h"
#include "rtbkit/plugins/bid_request/openrtb_bid_request.h"
#include "rtbkit/plugins/exchange/http_auction_handler.h"
#include "rtbkit/core/agent_configuration/agent_config.h"
#include "rtbkit/plugins/bid_request/smaato_parsing.h"
#include "rtbkit/plugins/bid_request/smaato_bid_request.h"
#include "openrtb/openrtb_parsing.h"
#include "soa/types/json_printing.h"
#include <boost/any.hpp>
#include <boost/lexical_cast.hpp>

Gocrazy

#pragma once

#include "rtbkit/plugins/exchange/http_exchange_connector.h"

namespace RTBKIT {
	struct SmaatoExchangeConnector : public HttpExchangeConnector {
	SmaatoExchangeConnector(ServiceBase & owner, const std::string & name);
	SmaatoExchangeConnector(const std::string & name,
                            std::shared_ptr<ServiceProxies> proxies);