summaryrefslogtreecommitdiff
path: root/src/multicast.cc
diff options
context:
space:
mode:
authordeva <deva>2006-06-09 18:20:51 +0000
committerdeva <deva>2006-06-09 18:20:51 +0000
commit8f9101869f6b460f61033ce434bba0a793d25137 (patch)
treefd07cb44be0b01da339f79164c323793d72ab4a9 /src/multicast.cc
parent6c31ad03de714676516d69ae9114e8bdd67c0d96 (diff)
Moved files to other folder:
lib - Shared files between server and client client - Client files server - Server files
Diffstat (limited to 'src/multicast.cc')
-rw-r--r--src/multicast.cc178
1 files changed, 0 insertions, 178 deletions
diff --git a/src/multicast.cc b/src/multicast.cc
deleted file mode 100644
index 0072c19..0000000
--- a/src/multicast.cc
+++ /dev/null
@@ -1,178 +0,0 @@
-/* -*- Mode: C++; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
-/***************************************************************************
- * multicast.cc
- *
- * Mon Sep 26 12:25:22 CEST 2005
- * Copyright 2005 Bent Bisballe Nyeng
- * deva@aasimon.org
- ****************************************************************************/
-
-/*
- * This file is part of MIaV.
- *
- * MIaV is free software; you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation; either version 2 of the License, or
- * (at your option) any later version.
- *
- * MIaV is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with MIaV; if not, write to the Free Software
- * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
- */
-#include "config.h"
-#include "multicast.h"
-
-#include "multicast_configuration.h"
-
-#include "miav_config.h"
-
-#include <sys/socket.h>
-#include <netinet/in.h>
-#include <netdb.h>
-#include <sys/param.h>
-#include <arpa/inet.h>
-#include <sys/types.h>
-
-// For IP_MTU
-//#include <linux/in.h>
-//#ifndef IP_MTU
-//#define IP_MTU 14
-//#endif
-
-#include <errno.h>
-
-Multicast::Multicast(Info *i, mcastconf_t &mcclientconf)
-{
- info = i;
- udp_buffer = NULL;
-
- multicast_audio = mcclientconf.with_audio;
-
- // Open connection socket
- if(!UDPOpen(mcclientconf.addr.c_str(), mcclientconf.port))
- info->error("Error creating socket %s:%d",
- mcclientconf.addr.c_str(),
- mcclientconf.port);
-
- int mtu = config->readInt("udp_packet_size");
-
- // Create buffer with the size of MTU
- // socklen_t mtu_sz;
- // if(getsockopt(sock, SOL_IP, IP_MTU, &mtu, &mtu_sz) != -1) {
-
- udp_buffer_size = mtu - 28;
- if(udp_buffer_size < 1) udp_buffer_size = 1;
- udp_buffer = new char[udp_buffer_size];
- udp_buffer_pointer = udp_buffer;
- info->info("UDP packet buffer size %db", udp_buffer_size);
-
- //} else {
- // info->error("Error getting MTU size from socket: %s", strerror(errno));
- // return;
- //}
-}
-
-Multicast::~Multicast()
-{
- if(udp_buffer) delete udp_buffer;
-}
-
-int Multicast::Write(void* buf, int size)
-{
- if(!udp_buffer) return 0; // no buffer to write in... better break out!
-
- // info->info("To send: %d", size);
-
- char *p = (char*)buf;
- int left = udp_buffer_size - (udp_buffer_pointer - udp_buffer);
-
- while(size) {
- int to_copy = size > left ? left : size;
-
- memcpy(udp_buffer_pointer, p, to_copy);
-
- left-=to_copy;
- udp_buffer_pointer += to_copy;
-
- p+=to_copy;
- size-=to_copy;
-
- // info->info("Copied %d - %d to go", to_copy, size);
-
- if(left == 0) {
- // info->info("Sending full packet");
- write(sock, udp_buffer, udp_buffer_size);
- left = udp_buffer_size;
- udp_buffer_pointer = udp_buffer;
- }
- }
- return size;
-}
-
-bool Multicast::is_address_multicast(unsigned long address)
-{
- if((address & 255) >= 224 && (address & 255) <= 239) {
- info->info("Address is multicast.");
- return true;
- }
- info->info("Address is NOT multicast.");
- return false;
-}
-
-/*
- * open UDP socket
- */
-bool Multicast::UDPOpen(const char *address, int port)
-{
- int enable = 1L;
- struct sockaddr_in stAddr;
- struct sockaddr_in stLclAddr;
- struct hostent * host;
- // int sock;
-
- stAddr.sin_family = AF_INET;
- stAddr.sin_port = htons(port);
- if((host = gethostbyname(address)) == NULL) return false;
- stAddr.sin_addr = *((struct in_addr *) host->h_addr_list[0]);
-
- // Create a UDP socket
- if((sock = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
- return false;
-
- // Allow multiple instance of the client to share the same address and port
- if(setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (char *) &enable, sizeof(unsigned long int)) < 0)
- return false;
-
- // If the address is multicast, register to the multicast group
- if(is_address_multicast(stAddr.sin_addr.s_addr)) {
- struct ip_mreq stMreq;
-
- // Bind the socket to port
- stLclAddr.sin_family = AF_INET;
- stLclAddr.sin_addr.s_addr = htonl(INADDR_ANY);
- stLclAddr.sin_port = stAddr.sin_port;
- if(bind(sock, (struct sockaddr*) & stLclAddr, sizeof(stLclAddr)) < 0) return false;
-
- // Register to a multicast address
- stMreq.imr_multiaddr.s_addr = stAddr.sin_addr.s_addr;
- stMreq.imr_interface.s_addr = INADDR_ANY;
- if(setsockopt(sock, IPPROTO_IP, IP_ADD_MEMBERSHIP, (char *) & stMreq, sizeof(stMreq)) < 0)
- return false;
- } else {
- // Bind the socket to port
- stLclAddr.sin_family = AF_INET;
- stLclAddr.sin_addr.s_addr = htonl(INADDR_ANY);
- stLclAddr.sin_port = htons(0);
- if(bind(sock, (struct sockaddr*) & stLclAddr, sizeof(stLclAddr)) < 0)
- return false;
- }
-
- connect(sock, (struct sockaddr*) & stAddr, sizeof(stAddr));
-
- return true;
-}