package rep;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.channels.SocketChannel;

import rep.channel.REPSocketChannel;

public class SMConnector {
	private REPSocketChannel<REPCommand> sessionchannel;
	
	public void connectSession(String host) {
		int port = 8765;
		//int port = Integer.parseInt(args[2]);
		InetSocketAddress addr = new InetSocketAddress(host, port);
		try {
			sessionchannel = REPSocketChannel.<REPCommand>create();
			sessionchannel.configureBlocking(true);
			sessionchannel.connect(addr);
			System.out.println("connect");
			//sessionchannel.configureBlocking(false);
			while(!sessionchannel.finishConnect()){
				System.out.println("afro");
			}
			//registerChannel(selector, sessionchannel, SelectionKey.OP_READ);
		}catch (IOException e) {
			e.printStackTrace();
		}
	}
}