// stdafx.h : 標準のシステム インクルード ファイルのインクルード ファイル、または
// 参照回数が多く、かつあまり変更されない、プロジェクト専用のインクルード ファイル
// を記述します。
//

#pragma once

#include "targetver.h"

#include
#include 

#include
#include
#include
#include
#include

// RTCConnector.cpp : コンソール アプリケーションのエントリ ポイントを定義します。
//

#include "stdafx.h"

int main(int argc, char* argv[])
{
	// ORBを取得
	CORBA::ORB_var orb = CORBA::ORB_init(argc, argv);
	RTC::CorbaNaming naming(orb, "localhost:2809");

	// それぞれのコンポーネントを取得
	RTC::CorbaConsumer consoleIn0, consoleOut0;
	consoleIn0.setObject(naming.resolve("ConsoleIn0.rtc"));
	consoleOut0.setObject(naming.resolve("ConsoleOut0.rtc"));

	// それぞれのコンポーネントからポートのリストを取得
	RTC::PortServiceList *portIn, *portOut;
	portIn = consoleIn0->get_ports();
	portOut = consoleOut0->get_ports();
	assert(portIn->length() > 0);
	assert(portOut->length() > 0);

	// とりあえず全部切断
	(*portIn)[0]->disconnect_all();
	(*portOut)[0]->disconnect_all();

	// 接続のためのコネクションプロファイルを作成
	RTC::ConnectorProfile prof;
	prof.connector_id = "cn0";
	prof.name = CORBA::string_dup("connector0");
	prof.ports.length(2);
	prof.ports[0] = (*portIn)[0];
	prof.ports[1] = (*portOut)[0];

	// 接続のプロパティを追加
	CORBA_SeqUtil::push_back(prof.properties,
		   NVUtil::newNV("dataport.interface_type",
				 "corba_cdr"));
	CORBA_SeqUtil::push_back(prof.properties,
		   NVUtil::newNV("dataport.dataflow_type",
				 "push"));
	CORBA_SeqUtil::push_back(prof.properties,
		   NVUtil::newNV("dataport.subscription_type",
				 "new"));

	// 接続を確立
	RTC::ReturnCode_t ret;
	ret = (*portIn)[0]->connect(prof);
	assert(ret == RTC::RTC_OK);
	std::cout << "Connector ID: " << prof.connector_id << std::endl;
　　　　 NVUtil::dump(prof.properties);
        //Console**コンポーネントのインスタンスをアクティブ化
        RTC::ExecutionContextList_var ExecutionContextListOut = consoleOut0->get_owned_contexts();
	ExecutionContextListOut[0]->activate_component(RTC::RTObject::_duplicate(consoleOut0._ptr()));
	RTC::ExecutionContextList_var ExecutionContextListIn = consoleIn0->get_owned_contexts();
	ExecutionContextListIn[0]->activate_component(RTC::RTObject::_duplicate(consoleIn0._ptr()));

	orb->destroy();
	return 0;
}