comparison libpurple/protocols/zephyr/zephyr.c @ 25362:65cfc59858cf

propagate from branch 'im.pidgin.pidgin' (head d5bb29138cbe033bbfd8ec689203d73818765327) to branch 'im.pidgin.pidgin.next.minor' (head 35ee8e40db640867e5b9239030cdc326e7f0a005)

25361:d9da15c9e2a1

typedef enum {
	PURPLE_ZEPHYR_NONE, /* Non-kerberized ZEPH0.2 */
	PURPLE_ZEPHYR_KRB4, /* ZEPH0.2 w/ KRB4 support */
	PURPLE_ZEPHYR_TZC,  /* tzc executable proxy */
	PURPLE_ZEPHYR_INTERGALACTIC_KRB4, /* Kerberized ZEPH0.3 */
} zephyr_connection_type;

struct _zephyr_account {
	PurpleAccount* account;
	char *username;

		if (pid == 0) {
			unsigned int i=0;
			gboolean found_ps = FALSE;
			gchar ** tzc_cmd_array = g_strsplit(purple_account_get_string(gc->account,"tzc_command","/usr/bin/tzc -e %s")," ",0);
			if (close(1) == -1) {
				purple_debug_error("zephyr", "stdout couldn't be closed. dying\n");
				exit(-1);
			}
			if (dup2(zephyr->fromtzc[1], 1) == -1) {
				purple_debug_error("zephyr", "dup2 of stdout failed \n");
				exit(-1);
			}
			if (close(zephyr->fromtzc[1]) == -1) {
				purple_debug_error("zephyr", "closing of piped stdout failed\n");
				exit(-1);
			}
			if (close(0) == -1) {
				purple_debug_error("zephyr", "stdin couldn't be closed. dying\n");
				exit(-1);
			}
			if (dup2(zephyr->totzc[0], 0) == -1) {
				purple_debug_error("zephyr", "dup2 of stdin failed \n");
				exit(-1);
			}
			if (close(zephyr->totzc[0]) == -1) {
				purple_debug_error("zephyr", "closing of piped stdin failed\n");
				exit(-1);
			}
			/* tzc_command should really be of the form 
			   path/to/tzc -e %s
			   or

				}
				i++;
			}

			if (!found_ps) {
				purple_connection_error(gc,"Tzc command needs %s to set the exposure\n");
				return;
			}

			execvp(tzc_cmd_array[0], tzc_cmd_array);
		}
		else {
			fd_set rfds;
			int bufsize = 2048;
			char *buf = (char *)calloc(bufsize, 1);

			struct timeval tv;
			char *ptr;
			int parenlevel=0;
			char* tempstr;
			int tempstridx;

			zephyr->tzc_pid = pid;
			/* wait till we have data to read from ssh */
			FD_ZERO(&rfds);
			FD_SET(zephyr->fromtzc[ZEPHYR_FD_READ], &rfds);

			tv.tv_sec = 10;
			tv.tv_usec = 0;

			purple_debug_info("zephyr", "about to read from tzc\n");

			select(zephyr->fromtzc[ZEPHYR_FD_READ] + 1, &rfds, NULL, NULL, NULL);

			FD_ZERO(&rfds);
			FD_SET(zephyr->fromtzc[ZEPHYR_FD_READ], &rfds);
			while (select(zephyr->fromtzc[ZEPHYR_FD_READ] + 1, &rfds, NULL, NULL, &tv)) {
				read(zephyr->fromtzc[ZEPHYR_FD_READ], bufcur, 1);
				bufcur++;
				if ((bufcur - buf) > (bufsize - 1)) {
					if ((buf = realloc(buf, bufsize * 2)) == NULL) {
						exit(-1);

25362:65cfc59858cf

typedef enum {
	PURPLE_ZEPHYR_NONE, /* Non-kerberized ZEPH0.2 */
	PURPLE_ZEPHYR_KRB4, /* ZEPH0.2 w/ KRB4 support */
	PURPLE_ZEPHYR_TZC,  /* tzc executable proxy */
	PURPLE_ZEPHYR_INTERGALACTIC_KRB4 /* Kerberized ZEPH0.3 */
} zephyr_connection_type;

struct _zephyr_account {
	PurpleAccount* account;
	char *username;

		if (pid == 0) {
			unsigned int i=0;
			gboolean found_ps = FALSE;
			gchar ** tzc_cmd_array = g_strsplit(purple_account_get_string(gc->account,"tzc_command","/usr/bin/tzc -e %s")," ",0);
			if (close(1) == -1) {
				exit(-1);
			}
			if (dup2(zephyr->fromtzc[1], 1) == -1) {
				exit(-1);
			}
			if (close(zephyr->fromtzc[1]) == -1) {
				exit(-1);
			}
			if (close(0) == -1) {
				exit(-1);
			}
			if (dup2(zephyr->totzc[0], 0) == -1) {
				exit(-1);
			}
			if (close(zephyr->totzc[0]) == -1) {
				exit(-1);
			}
			/* tzc_command should really be of the form 
			   path/to/tzc -e %s
			   or

				}
				i++;
			}

			if (!found_ps) {
				exit(-1);
			}

			execvp(tzc_cmd_array[0], tzc_cmd_array);
			exit(-1);
		}
		else {
			fd_set rfds;
			int bufsize = 2048;
			char *buf = (char *)calloc(bufsize, 1);

			struct timeval tv;
			char *ptr;
			int parenlevel=0;
			char* tempstr;
			int tempstridx;
			int select_status;

			zephyr->tzc_pid = pid;
			/* wait till we have data to read from ssh */
			FD_ZERO(&rfds);
			FD_SET(zephyr->fromtzc[ZEPHYR_FD_READ], &rfds);

			tv.tv_sec = 10;
			tv.tv_usec = 0;

			purple_debug_info("zephyr", "about to read from tzc\n");

			if (waitpid(pid, NULL, WNOHANG) == 0) { /* Only select if tzc is still running */
				purple_debug_info("zephyr", "about to read from tzc\n");
				select_status = select(zephyr->fromtzc[ZEPHYR_FD_READ] + 1, &rfds, NULL, NULL, NULL);
			}
			else {
				purple_debug_info("zephyr", "tzc exited early\n");
				select_status = -1;
			}

			FD_ZERO(&rfds);
			FD_SET(zephyr->fromtzc[ZEPHYR_FD_READ], &rfds);
			while (select_status > 0 &&
			       select(zephyr->fromtzc[ZEPHYR_FD_READ] + 1, &rfds, NULL, NULL, &tv) > 0) {
				read(zephyr->fromtzc[ZEPHYR_FD_READ], bufcur, 1);
				bufcur++;
				if ((bufcur - buf) > (bufsize - 1)) {
					if ((buf = realloc(buf, bufsize * 2)) == NULL) {
						exit(-1);