picotcp/stack/pico_socket_multicast.c

29  *   MCASTSources: RBTree(source)
233     /* remove from the interface EXCLUDE filter any source not in the socket EXCLUDE filter */
235     union pico_address *source = NULL;
239             source = pico_tree_findKey(&listen->MCASTSources, index->keyValue);
240             if (!source)
249             source = pico_tree_findKey(&listen->MCASTSources_ipv6, index->keyValue);
250             if (!source)
263     /* remove from the interface EXCLUDE filter any source in the socket INCLUDE filter */
265     union pico_address *source = NULL;
269             source = pico_tree_findKey(&MCASTFilter, index->keyValue);
270             if (source)
271                 pico_tree_delete(&MCASTFilter, source);
279             source = pico_tree_findKey(&MCASTFilter_ipv6, index->keyValue);
280             if (source)
281                 pico_tree_delete(&MCASTFilter_ipv6, source);
292     /* delete from the interface INCLUDE filter any source NOT in the socket EXCLUDE filter */
294     union pico_address *source = NULL;
298             source = pico_tree_findKey(&listen->MCASTSources, index->keyValue);
299             if (!source)
308             source = pico_tree_findKey(&listen->MCASTSources_ipv6, index->keyValue);
309             if (!source)
317     /* add to the interface EXCLUDE filter any socket source NOT in the former interface INCLUDE filter */
321             source = pico_tree_insert(&MCASTFilter, index->keyValue);
322             if (source) {
323                 if ((void *)source == (void *)&LEAF)
326                     pico_tree_delete(&MCASTFilter, source);
335             source = pico_tree_insert(&MCASTFilter_ipv6, index->keyValue);
336             if (source) {
337                 if ((void *)source == (void *)&LEAF)
340                     pico_tree_delete(&MCASTFilter_ipv6, source);
354     union pico_address *source = NULL;
359             source = index->keyValue;
360             if (pico_tree_insert(&MCASTFilter, source) == &LEAF)
369             source = index->keyValue;
370             if (pico_tree_insert(&MCASTFilter_ipv6, source) == &LEAF)
468                 so_mcast_dbg("MCAST: IP %08X in included socket source list\n", src->ip4.addr);
481                 so_mcast_dbg("MCAST: IP %s in included socket source list\n", tmp_string);
490     so_mcast_dbg("MCAST: IP %08X NOT in included socket source list\n", src->ip4.addr);
505                 so_mcast_dbg("MCAST: IP %08X in excluded socket source list\n", src->ip4.addr);
518                 so_mcast_dbg("MCAST: IP %s in excluded socket source list\n", tmp_string);
527     so_mcast_dbg("MCAST: IP %08X NOT in excluded socket source list\n", src->ip4.addr);
533     /* perform source filtering */
845     union pico_address *source = NULL;
859                     source = index2->keyValue;
860                     pico_tree_delete(tree, source);
861                     PICO_FREE(source);
964             so_mcast_dbg("pico_socket_setoption: ERROR any-source multicast (exclude) on source-specific multicast (include)\n");
1022     union pico_address *source = NULL;
1040         source = index->keyValue;
1041         pico_tree_delete(tree, source);
1068     union pico_address stest, *source = NULL;
1081         so_mcast_dbg("pico_socket_setoption: ERROR any-source multicast (exclude) on source-specific multicast (include)\n");
1088         source = pico_tree_findKey(&mcast.listen->MCASTSources, &stest);
1092         source = pico_tree_findKey(&mcast.listen->MCASTSources_ipv6, &stest);
1094     if (!source) {
1095         so_mcast_dbg("pico_socket_setoption: ERROR address to unblock not in source list\n");
1101         pico_tree_delete(&mcast.listen->MCASTSources, source);
1105         pico_tree_delete(&mcast.listen->MCASTSources_ipv6, source);
1125     union pico_address stest, *source = NULL;
1138         so_mcast_dbg("pico_socket_setoption: ERROR any-source multicast (exclude) on source-specific multicast (include)\n");
1145         source = pico_tree_findKey(&mcast.listen->MCASTSources, &stest);
1149         source = pico_tree_findKey(&mcast.listen->MCASTSources_ipv6, &stest);
1151     if (source) {
1152         so_mcast_dbg("pico_socket_setoption: ERROR address to block already in source list\n");
1157     source = PICO_ZALLOC(sizeof(union pico_address));
1158     if (!source) {
1163     *source = mcast.mreq_s->mcast_source_addr;
1165     	if (pico_tree_insert(&mcast.listen->MCASTSources, source)) {
1166     		PICO_FREE(source);
1173     	if (pico_tree_insert(&mcast.listen->MCASTSources_ipv6, source)) {
1174 			PICO_FREE(source);
1196     union pico_address stest, *source = NULL;
1207             so_mcast_dbg("pico_socket_setoption: ERROR source-specific multicast (include) on any-source multicast (exclude)\n");
1213         source = pico_tree_findKey(tree, &stest);
1214         if (source) {
1215             so_mcast_dbg("pico_socket_setoption: ERROR source address to allow already in source list\n");
1220         source = PICO_ZALLOC(sizeof(union pico_address));
1221         if (!source) {
1226         *source = mcast.mreq_s->mcast_source_addr;
1227         if (pico_tree_insert(tree, source)) {
1228 			PICO_FREE(source);
1244         source = PICO_ZALLOC(sizeof(union pico_address));
1245         if (!source) {
1256         *source = mcast.mreq_s->mcast_source_addr;
1257         if (pico_tree_insert(tree, source)) {
1259 			PICO_FREE(source);
1264             pico_tree_delete(tree, source);
1265             PICO_FREE(source);
1293     union pico_address stest, *source = NULL;
1308         so_mcast_dbg("pico_socket_setoption: ERROR source-specific multicast (include) on any-source multicast (exclude)\n");
1315     source = pico_tree_findKey(tree, &stest);
1316     if (!source) {
1317         so_mcast_dbg("pico_socket_setoption: ERROR address to drop not in source list\n");
1322     pico_tree_delete(tree, source);