changeset 26221:1cf212ba3926

Remove some bugs related to inserting some data into hash table, data for connected peers
author Sulabh Mahajan <sulabh@soc.pidgin.im>
date Mon, 21 Jul 2008 09:07:42 +0000
parents 9a5da524fba9
children c031f88aa026
files libpurple/protocols/yahoo/yahoo.c
diffstat 1 files changed, 33 insertions(+), 25 deletions(-) [+]
line wrap: on
line diff
--- a/libpurple/protocols/yahoo/yahoo.c	Sun Jul 20 17:37:46 2008 +0000
+++ b/libpurple/protocols/yahoo/yahoo.c	Mon Jul 21 09:07:42 2008 +0000
@@ -2377,6 +2377,7 @@
 	PurpleAccount *account;
 	int val_13_to_send = 0;
 	struct yahoo_data *yd;
+	YahooFriend *f;
 
 	if(!(p2p_data = data))
 		return ;
@@ -2433,6 +2434,21 @@
 	/* build the raw packet and send it to the host */
 	yahoo_p2p_write_pkt(source, pkt_to_send);
 	yahoo_packet_free(pkt_to_send);
+
+	if( val_13_to_send == 7 )
+		if( !g_hash_table_lookup(yd->peers, p2p_data->host_username) )	{
+			g_hash_table_insert(yd->peers, g_strdup(p2p_data->host_username), p2p_data);
+			/* If the peer is a friend, set him connected */
+			f = yahoo_friend_find(p2p_data->gc, p2p_data->host_username);
+			if (f)	{
+				if(p2p_data->connection_type == YAHOO_P2P_WE_ARE_SERVER)	{
+					p2p_data->session_id = f->session_id;
+					yahoo_friend_set_p2p_status(f, YAHOO_P2PSTATUS_WE_ARE_SERVER);
+				}
+				else
+					yahoo_friend_set_p2p_status(f, YAHOO_P2PSTATUS_WE_ARE_CLIENT);
+			}
+		}
 }
 
 /* callback function associated with receiving of data, not considering receipt of multiple YMSG packets in a single TCP packet */
@@ -2458,7 +2474,10 @@
 	{
 		purple_debug_warning("yahoo","p2p: Error in connection, or host disconnected\n");
 		/* remove from p2p connection lists, also calls yahoo_p2p_disconnect_destroy_data */
-		g_hash_table_remove(yd->peers,p2p_data->host_username);
+		if( g_hash_table_lookup(yd->peers, p2p_data->host_username) )
+			g_hash_table_remove(yd->peers,p2p_data->host_username);
+		else
+			yahoo_p2p_disconnect_destroy_data(data);
 		return;
 	}
 	
@@ -2516,7 +2535,6 @@
 {
 	int acceptfd;
 	struct yahoo_p2p_data *p2p_data;
-	YahooFriend *f;
 	struct yahoo_data *yd;
 
 	if(!(p2p_data = data))
@@ -2537,16 +2555,9 @@
 	close(yd->yahoo_local_p2p_server_fd);
 	yd->yahoo_local_p2p_server_fd = -1;
 
-	if( (f = yahoo_friend_find(p2p_data->gc, p2p_data->host_username)) )	{
-		p2p_data->session_id = f->session_id;
-		yahoo_friend_set_p2p_status(f, YAHOO_P2PSTATUS_WE_ARE_SERVER);
-	}
-
 	/* Add an Input Read event to the file descriptor */
 	p2p_data->input_event = purple_input_add(acceptfd, PURPLE_INPUT_READ, yahoo_p2p_read_pkt_cb, data);
 	p2p_data->source = acceptfd;
-
-	g_hash_table_insert(yd->peers, g_strdup(p2p_data->host_username), p2p_data);
 }
 
 static void yahoo_p2p_server_listen_cb(int listenfd, gpointer data)
@@ -2582,7 +2593,13 @@
 	struct yahoo_packet *pkt;
 	PurpleAccount *account;
 	struct yahoo_data *yd = gc->proto_data;
-	struct yahoo_p2p_data *p2p_data = g_new0(struct yahoo_p2p_data, 1);
+	struct yahoo_p2p_data *p2p_data;
+
+	f = yahoo_friend_find(gc, who);
+	account = purple_connection_get_account(gc);
+	/* send packet to only those friends who arent p2p connected and to whom we havent already sent. Do not send if this condition doesn't hold good */ 
+	if( !( f && (yahoo_friend_get_p2p_status(f) == YAHOO_P2PSTATUS_NOT_CONNECTED) && (f->p2p_packet_sent == 0)) )
+		return;
 
 	public_ip = purple_network_get_public_ip();
 	if( (sscanf(public_ip, "%u.%u.%u.%u", &temp[0], &temp[1], &temp[2], &temp[3])) !=4 )
@@ -2592,13 +2609,6 @@
 	sprintf(temp_str, "%d", ip);
 	base64_ip = purple_base64_encode( (guchar *)temp_str, strlen(temp_str) );
 
-	f = yahoo_friend_find(gc, who);
-	account = purple_connection_get_account(gc);
-
-	/* send packet to only those friends who arent p2p connected and to whom we havent already sent. Do not send if this condition doesn't hold good */ 
-	if( !( f && (yahoo_friend_get_p2p_status(f) == YAHOO_P2PSTATUS_NOT_CONNECTED) && (f->p2p_packet_sent == 0)) )
-		return;
-
 	pkt = yahoo_packet_new(YAHOO_SERVICE_PEERTOPEER, YAHOO_STATUS_AVAILABLE, 0);
 	yahoo_packet_hash(pkt, "sssissis",
 		1, purple_normalize(account, purple_account_get_username(account)),
@@ -2613,6 +2623,8 @@
 
 	f->p2p_packet_sent = 1;	/* set p2p_packet_sent to sent */
 
+	p2p_data = g_new0(struct yahoo_p2p_data, 1);
+
 	p2p_data->gc = gc;
 	p2p_data->host_ip = NULL;
 	p2p_data->host_username = (char *)g_malloc(strlen(who));
@@ -2631,7 +2643,6 @@
 	struct yahoo_p2p_data *p2p_data;
 	struct yahoo_packet *pkt_to_send;
 	PurpleAccount *account;
-	YahooFriend *f;
 	struct yahoo_data *yd;
 
 	if(!(p2p_data = data))
@@ -2650,13 +2661,6 @@
 	p2p_data->input_event = purple_input_add(source, PURPLE_INPUT_READ, yahoo_p2p_read_pkt_cb, data);
 	p2p_data->source = source;
 
-	g_hash_table_insert(yd->peers, g_strdup(p2p_data->host_username), p2p_data);
-	
-	/* If the peer is a friend, set him connected */
-	f = yahoo_friend_find(p2p_data->gc, p2p_data->host_username);
-	if (f)
-		yahoo_friend_set_p2p_status(f, YAHOO_P2PSTATUS_WE_ARE_CLIENT);
-
 	account = purple_connection_get_account(p2p_data->gc);
 
 	/* Build the yahoo packet */
@@ -2684,6 +2688,10 @@
 	PurpleAccount *account;
 	YahooFriend *f;
 
+	/* if status is YAHOO_STATUS_BUSY, don't do anything, peer wont connect */
+	if(pkt->status == YAHOO_STATUS_BUSY)
+		return ;
+
 	while (l) {
 		struct yahoo_pair *pair = l->data;