diff options
-rw-r--r-- | toxav/toxav.c | 2 | ||||
-rw-r--r-- | toxcore/Messenger.c | 5 | ||||
-rw-r--r-- | toxcore/group.c | 6 | ||||
-rw-r--r-- | toxcore/net_crypto.c | 10 | ||||
-rw-r--r-- | toxcore/onion_announce.c | 3 | ||||
-rw-r--r-- | toxcore/util.c | 37 | ||||
-rw-r--r-- | toxcore/util.h | 5 |
7 files changed, 56 insertions, 12 deletions
diff --git a/toxav/toxav.c b/toxav/toxav.c index 7cba031e..8549bc05 100644 --- a/toxav/toxav.c +++ b/toxav/toxav.c | |||
@@ -588,6 +588,8 @@ int toxav_kill_transmission ( ToxAv *av, int32_t call_index ) | |||
588 | codec_terminate_session(call->cs); | 588 | codec_terminate_session(call->cs); |
589 | call->cs = NULL; | 589 | call->cs = NULL; |
590 | 590 | ||
591 | free(call->frame_buf); | ||
592 | |||
591 | pthread_mutex_unlock(&call->mutex); | 593 | pthread_mutex_unlock(&call->mutex); |
592 | pthread_mutex_destroy(&call->mutex); | 594 | pthread_mutex_destroy(&call->mutex); |
593 | 595 | ||
diff --git a/toxcore/Messenger.c b/toxcore/Messenger.c index 4841cbd9..eaf87179 100644 --- a/toxcore/Messenger.c +++ b/toxcore/Messenger.c | |||
@@ -2648,10 +2648,9 @@ uint32_t messenger_size(const Messenger *m) | |||
2648 | 2648 | ||
2649 | static uint8_t *z_state_save_subheader(uint8_t *data, uint32_t len, uint16_t type) | 2649 | static uint8_t *z_state_save_subheader(uint8_t *data, uint32_t len, uint16_t type) |
2650 | { | 2650 | { |
2651 | memcpy(data, &len, sizeof(uint32_t)); | 2651 | host_to_lendian32(data, len); |
2652 | data += sizeof(uint32_t); | 2652 | data += sizeof(uint32_t); |
2653 | uint32_t temp = (MESSENGER_STATE_COOKIE_TYPE << 16) | type; | 2653 | host_to_lendian32(data, (host_tolendian16(MESSENGER_STATE_COOKIE_TYPE) << 16) | host_tolendian16(type)); |
2654 | memcpy(data, &temp, sizeof(uint32_t)); | ||
2655 | data += sizeof(uint32_t); | 2654 | data += sizeof(uint32_t); |
2656 | return data; | 2655 | return data; |
2657 | } | 2656 | } |
diff --git a/toxcore/group.c b/toxcore/group.c index 26df82bd..24f0b72e 100644 --- a/toxcore/group.c +++ b/toxcore/group.c | |||
@@ -190,7 +190,7 @@ static int get_peer_index(Group_c *g, uint16_t peer_number) | |||
190 | 190 | ||
191 | static uint16_t calculate_comp_value(const uint8_t *pk1, const uint8_t *pk2) | 191 | static uint16_t calculate_comp_value(const uint8_t *pk1, const uint8_t *pk2) |
192 | { | 192 | { |
193 | uint8_t cmp1, cmp2; | 193 | uint8_t cmp1, cmp2 = 0; |
194 | 194 | ||
195 | for (cmp1 = crypto_box_PUBLICKEYBYTES; cmp1 != 0; --cmp1) { | 195 | for (cmp1 = crypto_box_PUBLICKEYBYTES; cmp1 != 0; --cmp1) { |
196 | uint8_t index = crypto_box_PUBLICKEYBYTES - cmp1; | 196 | uint8_t index = crypto_box_PUBLICKEYBYTES - cmp1; |
@@ -1025,7 +1025,7 @@ static void handle_friend_invite_packet(Messenger *m, int32_t friendnumber, cons | |||
1025 | return; | 1025 | return; |
1026 | 1026 | ||
1027 | uint16_t peer_number = rand(); /* TODO: what if two people enter the group at the same time and | 1027 | uint16_t peer_number = rand(); /* TODO: what if two people enter the group at the same time and |
1028 | are given the same peer_number by different nodes? */ | 1028 | are given the same peer_number by different nodes? */ |
1029 | unsigned int tries = 0; | 1029 | unsigned int tries = 0; |
1030 | 1030 | ||
1031 | while (get_peer_index(g, peer_number) != -1) { | 1031 | while (get_peer_index(g, peer_number) != -1) { |
@@ -1282,6 +1282,8 @@ static void handle_direct_packet(Group_Chats *g_c, int groupnumber, const uint8_ | |||
1282 | } | 1282 | } |
1283 | } | 1283 | } |
1284 | 1284 | ||
1285 | break; | ||
1286 | |||
1285 | case PEER_QUERY_ID: { | 1287 | case PEER_QUERY_ID: { |
1286 | Group_c *g = get_group_c(g_c, groupnumber); | 1288 | Group_c *g = get_group_c(g_c, groupnumber); |
1287 | 1289 | ||
diff --git a/toxcore/net_crypto.c b/toxcore/net_crypto.c index 63012ce6..c83c5d54 100644 --- a/toxcore/net_crypto.c +++ b/toxcore/net_crypto.c | |||
@@ -835,8 +835,9 @@ static int64_t send_lossless_packet(Net_Crypto *c, int crypt_connection_id, cons | |||
835 | 835 | ||
836 | if (send_data_packet_helper(c, crypt_connection_id, conn->recv_array.buffer_start, packet_num, data, length) == 0) { | 836 | if (send_data_packet_helper(c, crypt_connection_id, conn->recv_array.buffer_start, packet_num, data, length) == 0) { |
837 | Packet_Data *dt1 = NULL; | 837 | Packet_Data *dt1 = NULL; |
838 | get_data_pointer(&conn->send_array, &dt1, packet_num); | 838 | |
839 | dt1->time = temp_time; | 839 | if (get_data_pointer(&conn->send_array, &dt1, packet_num) == 1) |
840 | dt1->time = temp_time; | ||
840 | } else { | 841 | } else { |
841 | conn->maximum_speed_reached = 1; | 842 | conn->maximum_speed_reached = 1; |
842 | LOGGER_ERROR("send_data_packet failed\n"); | 843 | LOGGER_ERROR("send_data_packet failed\n"); |
@@ -1322,8 +1323,10 @@ static int create_crypto_connection(Net_Crypto *c) | |||
1322 | ++c->crypto_connections_length; | 1323 | ++c->crypto_connections_length; |
1323 | memset(&(c->crypto_connections[id]), 0, sizeof(Crypto_Connection)); | 1324 | memset(&(c->crypto_connections[id]), 0, sizeof(Crypto_Connection)); |
1324 | 1325 | ||
1325 | if (pthread_mutex_init(&c->crypto_connections[id].mutex, NULL) != 0) | 1326 | if (pthread_mutex_init(&c->crypto_connections[id].mutex, NULL) != 0) { |
1327 | pthread_mutex_unlock(&c->connections_mutex); | ||
1326 | return -1; | 1328 | return -1; |
1329 | } | ||
1327 | } | 1330 | } |
1328 | 1331 | ||
1329 | pthread_mutex_unlock(&c->connections_mutex); | 1332 | pthread_mutex_unlock(&c->connections_mutex); |
@@ -1817,6 +1820,7 @@ static int tcp_oob_callback(void *object, const uint8_t *public_key, const uint8 | |||
1817 | 1820 | ||
1818 | if (crypt_connection_id == -1) { | 1821 | if (crypt_connection_id == -1) { |
1819 | IP_Port source; | 1822 | IP_Port source; |
1823 | source.port = 0; | ||
1820 | source.ip.family = TCP_FAMILY; | 1824 | source.ip.family = TCP_FAMILY; |
1821 | source.ip.ip6.uint32[0] = location; | 1825 | source.ip.ip6.uint32[0] = location; |
1822 | 1826 | ||
diff --git a/toxcore/onion_announce.c b/toxcore/onion_announce.c index b25b6b11..2b0de595 100644 --- a/toxcore/onion_announce.c +++ b/toxcore/onion_announce.c | |||
@@ -178,6 +178,9 @@ int send_data_request(Networking_Core *net, const Onion_Path *path, IP_Port dest | |||
178 | uint8_t packet[ONION_MAX_PACKET_SIZE]; | 178 | uint8_t packet[ONION_MAX_PACKET_SIZE]; |
179 | len = create_onion_packet(packet, sizeof(packet), path, dest, request, len); | 179 | len = create_onion_packet(packet, sizeof(packet), path, dest, request, len); |
180 | 180 | ||
181 | if (len == -1) | ||
182 | return -1; | ||
183 | |||
181 | if (sendpacket(net, path->ip_port1, packet, len) != len) | 184 | if (sendpacket(net, path->ip_port1, packet, len) != len) |
182 | return -1; | 185 | return -1; |
183 | 186 | ||
diff --git a/toxcore/util.c b/toxcore/util.c index ee4fa3b2..3d444b07 100644 --- a/toxcore/util.c +++ b/toxcore/util.c | |||
@@ -84,6 +84,35 @@ void host_to_net(uint8_t *num, uint16_t numbytes) | |||
84 | return; | 84 | return; |
85 | } | 85 | } |
86 | 86 | ||
87 | uint16_t lendian_to_host16(uint16_t lendian) | ||
88 | { | ||
89 | #ifdef WORDS_BIGENDIAN | ||
90 | return (lendian << 8) | (lendian >> 8 ); | ||
91 | #else | ||
92 | return lendian; | ||
93 | #endif | ||
94 | } | ||
95 | |||
96 | void host_to_lendian32(uint8_t *dest, uint32_t num) | ||
97 | { | ||
98 | #ifdef WORDS_BIGENDIAN | ||
99 | num = ((num << 8) & 0xFF00FF00 ) | ((num >> 8) & 0xFF00FF ); | ||
100 | num = (num << 16) | (num >> 16); | ||
101 | #endif | ||
102 | memcpy(dest, &num, sizeof(uint32_t)); | ||
103 | } | ||
104 | |||
105 | void lendian_to_host32(uint32_t *dest, const uint8_t *lendian) | ||
106 | { | ||
107 | uint32_t d; | ||
108 | memcpy(&d, lendian, sizeof(uint32_t)); | ||
109 | #ifdef WORDS_BIGENDIAN | ||
110 | d = ((d << 8) & 0xFF00FF00 ) | ((d >> 8) & 0xFF00FF ); | ||
111 | d = (d << 16) | (d >> 16); | ||
112 | #endif | ||
113 | *dest = d; | ||
114 | } | ||
115 | |||
87 | /* state load/save */ | 116 | /* state load/save */ |
88 | int load_state(load_state_callback_func load_state_callback, void *outer, | 117 | int load_state(load_state_callback_func load_state_callback, void *outer, |
89 | const uint8_t *data, uint32_t length, uint16_t cookie_inner) | 118 | const uint8_t *data, uint32_t length, uint16_t cookie_inner) |
@@ -101,8 +130,8 @@ int load_state(load_state_callback_func load_state_callback, void *outer, | |||
101 | uint32_t size_head = sizeof(uint32_t) * 2; | 130 | uint32_t size_head = sizeof(uint32_t) * 2; |
102 | 131 | ||
103 | while (length >= size_head) { | 132 | while (length >= size_head) { |
104 | memcpy(&length_sub, data, sizeof(length_sub)); | 133 | lendian_to_host32(&length_sub, data); |
105 | memcpy(&cookie_type, data + sizeof(length_sub), sizeof(cookie_type)); | 134 | lendian_to_host32(&cookie_type, data + sizeof(length_sub)); |
106 | data += size_head; | 135 | data += size_head; |
107 | length -= size_head; | 136 | length -= size_head; |
108 | 137 | ||
@@ -114,7 +143,7 @@ int load_state(load_state_callback_func load_state_callback, void *outer, | |||
114 | return -1; | 143 | return -1; |
115 | } | 144 | } |
116 | 145 | ||
117 | if ((cookie_type >> 16) != cookie_inner) { | 146 | if (lendian_to_host16((cookie_type >> 16)) != cookie_inner) { |
118 | /* something is not matching up in a bad way, give up */ | 147 | /* something is not matching up in a bad way, give up */ |
119 | #ifdef DEBUG | 148 | #ifdef DEBUG |
120 | fprintf(stderr, "state file garbeled: %04hx != %04hx\n", (cookie_type >> 16), cookie_inner); | 149 | fprintf(stderr, "state file garbeled: %04hx != %04hx\n", (cookie_type >> 16), cookie_inner); |
@@ -122,7 +151,7 @@ int load_state(load_state_callback_func load_state_callback, void *outer, | |||
122 | return -1; | 151 | return -1; |
123 | } | 152 | } |
124 | 153 | ||
125 | type = cookie_type & 0xFFFF; | 154 | type = lendian_to_host16(cookie_type & 0xFFFF); |
126 | 155 | ||
127 | if (-1 == load_state_callback(outer, data, length_sub, type)) | 156 | if (-1 == load_state_callback(outer, data, length_sub, type)) |
128 | return -1; | 157 | return -1; |
diff --git a/toxcore/util.h b/toxcore/util.h index 7992a985..e90eee0f 100644 --- a/toxcore/util.h +++ b/toxcore/util.h | |||
@@ -42,6 +42,11 @@ uint32_t id_copy(uint8_t *dest, const uint8_t *src); /* return value is CLIENT_I | |||
42 | void host_to_net(uint8_t *num, uint16_t numbytes); | 42 | void host_to_net(uint8_t *num, uint16_t numbytes); |
43 | #define net_to_host(x, y) host_to_net(x, y) | 43 | #define net_to_host(x, y) host_to_net(x, y) |
44 | 44 | ||
45 | uint16_t lendian_to_host16(uint16_t lendian); | ||
46 | #define host_tolendian16(x) lendian_to_host16(x) | ||
47 | |||
48 | void host_to_lendian32(uint8_t *dest, uint32_t num); | ||
49 | |||
45 | /* state load/save */ | 50 | /* state load/save */ |
46 | typedef int (*load_state_callback_func)(void *outer, const uint8_t *data, uint32_t len, uint16_t type); | 51 | typedef int (*load_state_callback_func)(void *outer, const uint8_t *data, uint32_t len, uint16_t type); |
47 | int load_state(load_state_callback_func load_state_callback, void *outer, | 52 | int load_state(load_state_callback_func load_state_callback, void *outer, |