&idata, 0, &threadid)) { fprintf(stderr, "Unable to create second thread\n");
&idata, 0, &in_threadid)) { fprintf(stderr, "Unable to create input thread\n");
int main(int argc, char **argv){    WSADATA wsadata;    WORD winsock_ver;    WSAEVENT stdinevent;    HANDLE handles[2];    DWORD threadid;    struct input_data idata;    int sending;    int portnumber = -1;    SOCKET *sklist;    int skcount, sksize;    int connopen;    ssh_get_line = get_line;    sklist = NULL;    skcount = sksize = 0;    /*     * Initialise port and protocol to sensible defaults. (These     * will be overridden by more or less anything.)     */    default_protocol = PROT_SSH;    default_port = 22;    flags = FLAG_STDERR;    /*     * Process the command line.     */    do_defaults(NULL, &cfg);    default_protocol = cfg.protocol;    default_port = cfg.port;    {	/*	 * Override the default protocol if PLINK_PROTOCOL is set.	 */	char *p = getenv("PLINK_PROTOCOL");	int i;	if (p) {	    for (i = 0; backends[i].backend != NULL; i++) {		if (!strcmp(backends[i].name, p)) {		    default_protocol = cfg.protocol = backends[i].protocol;		    default_port = cfg.port =			backends[i].backend->default_port;		    break;		}	    }	}    }    while (--argc) {	char *p = *++argv;	if (*p == '-') {	    if (!strcmp(p, "-ssh")) {		default_protocol = cfg.protocol = PROT_SSH;		default_port = cfg.port = 22;	    } else if (!strcmp(p, "-telnet")) {		default_protocol = cfg.protocol = PROT_TELNET;		default_port = cfg.port = 23;	    } else if (!strcmp(p, "-raw")) {		default_protocol = cfg.protocol = PROT_RAW;	    } else if (!strcmp(p, "-v")) {		flags |= FLAG_VERBOSE;	    } else if (!strcmp(p, "-log")) {		logfile = "putty.log";	    } else if (!strcmp(p, "-pw") && argc > 1) {		--argc, password = *++argv;	    } else if (!strcmp(p, "-l") && argc > 1) {		char *username;		--argc, username = *++argv;		strncpy(cfg.username, username, sizeof(cfg.username));		cfg.username[sizeof(cfg.username) - 1] = '\0';	    } else if (!strcmp(p, "-m") && argc > 1) {		char *filename, *command;		int cmdlen, cmdsize;		FILE *fp;		int c, d;		--argc, filename = *++argv;		cmdlen = cmdsize = 0;		command = NULL;		fp = fopen(filename, "r");		if (!fp) {		    fprintf(stderr, "plink: unable to open command "			    "file \"%s\"\n", filename);		    return 1;		}		do {		    c = fgetc(fp);		    d = c;		    if (c == EOF)			d = 0;		    if (cmdlen >= cmdsize) {			cmdsize = cmdlen + 512;			command = srealloc(command, cmdsize);		    }		    command[cmdlen++] = d;		} while (c != EOF);		cfg.remote_cmd_ptr = command;		cfg.nopty = TRUE;      /* command => no terminal */	    } else if (!strcmp(p, "-P") && argc > 1) {		--argc, portnumber = atoi(*++argv);	    }	} else if (*p) {	    if (!*cfg.host) {		char *q = p;		/*		 * If the hostname starts with "telnet:", set the		 * protocol to Telnet and process the string as a		 * Telnet URL.		 */		if (!strncmp(q, "telnet:", 7)) {		    char c;		    q += 7;		    if (q[0] == '/' && q[1] == '/')			q += 2;		    cfg.protocol = PROT_TELNET;		    p = q;		    while (*p && *p != ':' && *p != '/')			p++;		    c = *p;		    if (*p)			*p++ = '\0';		    if (c == ':')			cfg.port = atoi(p);		    else			cfg.port = -1;		    strncpy(cfg.host, q, sizeof(cfg.host) - 1);		    cfg.host[sizeof(cfg.host) - 1] = '\0';		} else {		    char *r;		    /*		     * Before we process the [user@]host string, we		     * first check for the presence of a protocol		     * prefix (a protocol name followed by ",").		     */		    r = strchr(p, ',');		    if (r) {			int i, j;			for (i = 0; backends[i].backend != NULL; i++) {			    j = strlen(backends[i].name);			    if (j == r - p &&				!memcmp(backends[i].name, p, j)) {				default_protocol = cfg.protocol =				    backends[i].protocol;				portnumber =				    backends[i].backend->default_port;				p = r + 1;				break;			    }			}		    }		    /*		     * Three cases. Either (a) there's a nonzero		     * length string followed by an @, in which		     * case that's user and the remainder is host.		     * Or (b) there's only one string, not counting		     * a potential initial @, and it exists in the		     * saved-sessions database. Or (c) only one		     * string and it _doesn't_ exist in the		     * database.		     */		    r = strrchr(p, '@');		    if (r == p)			p++, r = NULL; /* discount initial @ */		    if (r == NULL) {			/*			 * One string.			 */			Config cfg2;			do_defaults(p, &cfg2);			if (cfg2.host[0] == '\0') {			    /* No settings for this host; use defaults */			    strncpy(cfg.host, p, sizeof(cfg.host) - 1);			    cfg.host[sizeof(cfg.host) - 1] = '\0';			    cfg.port = default_port;			} else {			    cfg = cfg2;			    cfg.remote_cmd_ptr = cfg.remote_cmd;			}		    } else {			*r++ = '\0';			strncpy(cfg.username, p, sizeof(cfg.username) - 1);			cfg.username[sizeof(cfg.username) - 1] = '\0';			strncpy(cfg.host, r, sizeof(cfg.host) - 1);			cfg.host[sizeof(cfg.host) - 1] = '\0';			cfg.port = default_port;		    }		}	    } else {		int len = sizeof(cfg.remote_cmd) - 1;		char *cp = cfg.remote_cmd;		int len2;		strncpy(cp, p, len);		cp[len] = '\0';		len2 = strlen(cp);		len -= len2;		cp += len2;		while (--argc) {		    if (len > 0)			len--, *cp++ = ' ';		    strncpy(cp, *++argv, len);		    cp[len] = '\0';		    len2 = strlen(cp);		    len -= len2;		    cp += len2;		}		cfg.nopty = TRUE;      /* command => no terminal */		break;		       /* done with cmdline */	    }	}    }    if (!*cfg.host) {	usage();    }    if (!*cfg.remote_cmd_ptr)	flags |= FLAG_INTERACTIVE;    /*     * Select protocol. This is farmed out into a table in a     * separate file to enable an ssh-free variant.     */    {	int i;	back = NULL;	for (i = 0; backends[i].backend != NULL; i++)	    if (backends[i].protocol == cfg.protocol) {		back = backends[i].backend;		break;	    }	if (back == NULL) {	    fprintf(stderr,		    "Internal fault: Unsupported protocol found\n");	    return 1;	}    }    /*     * Select port.     */    if (portnumber != -1)	cfg.port = portnumber;    /*     * Initialise WinSock.     */    winsock_ver = MAKEWORD(2, 0);    if (WSAStartup(winsock_ver, &wsadata)) {	MessageBox(NULL, "Unable to initialise WinSock", "WinSock Error",		   MB_OK | MB_ICONEXCLAMATION);	return 1;    }    if (LOBYTE(wsadata.wVersion) != 2 || HIBYTE(wsadata.wVersion) != 0) {	MessageBox(NULL, "WinSock version is incompatible with 2.0",		   "WinSock Error", MB_OK | MB_ICONEXCLAMATION);	WSACleanup();	return 1;    }    sk_init();    /*     * Start up the connection.     */    netevent = CreateEvent(NULL, FALSE, FALSE, NULL);    {	char *error;	char *realhost;	error = back->init(cfg.host, cfg.port, &realhost);	if (error) {	    fprintf(stderr, "Unable to open connection:\n%s", error);	    return 1;	}	sfree(realhost);    }    connopen = 1;    stdinevent = CreateEvent(NULL, FALSE, FALSE, NULL);    inhandle = GetStdHandle(STD_INPUT_HANDLE);    outhandle = GetStdHandle(STD_OUTPUT_HANDLE);    errhandle = GetStdHandle(STD_ERROR_HANDLE);    GetConsoleMode(inhandle, &orig_console_mode);    SetConsoleMode(inhandle, ENABLE_PROCESSED_INPUT);    /*     * Turn off ECHO and LINE input modes. We don't care if this     * call fails, because we know we aren't necessarily running in     * a console.     */    handles[0] = netevent;    handles[1] = stdinevent;    sending = FALSE;    while (1) {	int n;	if (!sending && back->sendok()) {	    /*	     * Create a separate thread to read from stdin. This is	     * a total pain, but I can't find another way to do it:	     *	     *  - an overlapped ReadFile or ReadFileEx just doesn't	     *    happen; we get failure from ReadFileEx, and	     *    ReadFile blocks despite being given an OVERLAPPED	     *    structure. Perhaps we can't do overlapped reads	     *    on consoles. WHY THE HELL NOT?	     * 	     *  - WaitForMultipleObjects(netevent, console) doesn't	     *    work, because it signals the console when	     *    _anything_ happens, including mouse motions and	     *    other things that don't cause data to be readable	     *    - so we're back to ReadFile blocking.	     */	    idata.event = stdinevent;	    idata.eventback = CreateEvent(NULL, FALSE, FALSE, NULL);	    if (!CreateThread(NULL, 0, stdin_read_thread,			      &idata, 0, &threadid)) {		fprintf(stderr, "Unable to create second thread\n");		exit(1);	    }	    sending = TRUE;	}	n = WaitForMultipleObjects(2, handles, FALSE, INFINITE);	if (n == 0) {	    WSANETWORKEVENTS things;	    SOCKET socket;	    extern SOCKET first_socket(int *), next_socket(int *);	    extern int select_result(WPARAM, LPARAM);	    int i, socketstate;	    /*	     * We must not call select_result() for any socket	     * until we have finished enumerating within the tree.	     * This is because select_result() may close the socket	     * and modify the tree.	     */	    /* Count the active sockets. */	    i = 0;	    for (socket = first_socket(&socketstate);		 socket != INVALID_SOCKET;		 socket = next_socket(&socketstate)) i++;	    /* Expand the buffer if necessary. */	    if (i > sksize) {		sksize = i + 16;		sklist = srealloc(sklist, sksize * sizeof(*sklist));	    }	    /* Retrieve the sockets into sklist. */	    skcount = 0;	    for (socket = first_socket(&socketstate);		 socket != INVALID_SOCKET;		 socket = next_socket(&socketstate)) {		sklist[skcount++] = socket;	    }	    /* Now we're done enumerating; go through the list. */	    for (i = 0; i < skcount; i++) {		WPARAM wp;		socket = sklist[i];		wp = (WPARAM) socket;		if (!WSAEnumNetworkEvents(socket, NULL, &things)) {		    noise_ultralight(socket);		    noise_ultralight(things.lNetworkEvents);		    if (things.lNetworkEvents & FD_READ)			connopen &= select_result(wp, (LPARAM) FD_READ);		    if (things.lNetworkEvents & FD_CLOSE)			connopen &= select_result(wp, (LPARAM) FD_CLOSE);		    if (things.lNetworkEvents & FD_OOB)			connopen &= select_result(wp, (LPARAM) FD_OOB);		    if (things.lNetworkEvents & FD_WRITE)			connopen &= select_result(wp, (LPARAM) FD_WRITE);    		    if (things.lNetworkEvents & FD_ACCEPT)			connopen &= select_result(wp, (LPARAM) FD_ACCEPT);		}	    }	} else if (n == 1) {	    noise_ultralight(idata.len);	    if (idata.len > 0) {		back->send(idata.buffer, idata.len);	    } else {		back->special(TS_EOF);	    }	    SetEvent(idata.eventback);	}	if (!connopen || back->socket() == NULL)	    break;		       /* we closed the connection */    }    WSACleanup();    return 0;}