summaryrefslogtreecommitdiff
path: root/libcult/examples/os/net/ipv4/multicast
diff options
context:
space:
mode:
Diffstat (limited to 'libcult/examples/os/net/ipv4/multicast')
-rw-r--r--libcult/examples/os/net/ipv4/multicast/client.cxx66
-rw-r--r--libcult/examples/os/net/ipv4/multicast/makefile55
-rw-r--r--libcult/examples/os/net/ipv4/multicast/protocol.hxx20
-rw-r--r--libcult/examples/os/net/ipv4/multicast/server.cxx134
4 files changed, 0 insertions, 275 deletions
diff --git a/libcult/examples/os/net/ipv4/multicast/client.cxx b/libcult/examples/os/net/ipv4/multicast/client.cxx
deleted file mode 100644
index 863fc25..0000000
--- a/libcult/examples/os/net/ipv4/multicast/client.cxx
+++ /dev/null
@@ -1,66 +0,0 @@
-// file : examples/os/net/ipv4/datagram/client.cxx
-// author : Boris Kolpackov <boris@kolpackov.net>
-// copyright : Copyright (c) 2005-2010 Boris Kolpackov
-// license : GNU GPL v2 + exceptions; see accompanying LICENSE file
-
-#include <cult/types.hxx>
-
-#include <cult/os/net/ipv4/address.hxx>
-#include <cult/os/net/ipv4/datagram-socket.hxx>
-
-#include <iostream>
-#include <unistd.h> // usleep
-
-#include "protocol.hxx"
-
-using std::cerr;
-using std::endl;
-
-using namespace Cult;
-using namespace OS::Net::IPv4;
-
-class Args {};
-
-Int
-main (Int argc, Char* argv[])
-{
- try
- {
- if (argc < 2)
- throw Args ();
-
- Address addr (argv[1], 10000);
-
- DatagramSocket socket;
-
- Message msg;
- msg.sn = 0;
-
- cerr << "message size : " << sizeof (msg) << " bytes" << endl;
- cerr << "send buffer : " << socket.send_buffer_size () << " bytes" << endl;
-
- for (Index i = 0; i < payload_size; i++)
- {
- msg.payload[i] = i;
- }
-
- for (; msg.sn < message_count; msg.sn++)
- {
- socket.send (&msg, sizeof (msg), addr);
-
- // ::usleep (10);
- }
-
- return 0;
- }
- catch (OS::Exception const& e)
- {
- cerr << "errno: " << strerror (e.code ()) << endl;
- }
- catch (Args const&)
- {
- cerr << "usage: client <IPv4 address>" << endl;
- }
-
- return 1;
-}
diff --git a/libcult/examples/os/net/ipv4/multicast/makefile b/libcult/examples/os/net/ipv4/multicast/makefile
deleted file mode 100644
index cb35bf6..0000000
--- a/libcult/examples/os/net/ipv4/multicast/makefile
+++ /dev/null
@@ -1,55 +0,0 @@
-# file : examples/os/net/ipv4/multicast/makefile
-# author : Boris Kolpackov <boris@kolpackov.net>
-# copyright : Copyright (c) 2005-2010 Boris Kolpackov
-# license : GNU GPL v2; see accompanying LICENSE file
-
-include $(dir $(lastword $(MAKEFILE_LIST)))../../../../../build/bootstrap.make
-
-client_cxx_tun := client.cxx
-server_cxx_tun := server.cxx
-
-client_cxx_obj := $(addprefix $(out_base)/,$(client_cxx_tun:.cxx=.o))
-server_cxx_obj := $(addprefix $(out_base)/,$(server_cxx_tun:.cxx=.o))
-
-cxx_obj := $(client_cxx_obj) $(server_cxx_obj)
-cxx_od := $(cxx_obj:.o=.o.d)
-
-cult.l := $(out_root)/cult/cult.l
-cult.l.cpp-options := $(out_root)/cult/cult.l.cpp-options
-
-client := $(out_base)/client
-server := $(out_base)/server
-clean := $(out_base)/.clean
-
-# Convenience alias for default target.
-#
-$(out_base)/: $(client) $(server)
-
-# Build.
-#
-
-$(client): $(client_cxx_obj) $(cult.l)
-$(server): $(server_cxx_obj) $(cult.l)
-
-$(cxx_obj) $(cxx_od): $(cult.l.cpp-options)
-
-$(call include-dep,$(cxx_od))
-
-
-# Clean.
-#
-$(clean): $(client).o.clean \
- $(server).o.clean \
- $(addsuffix .cxx.clean,$(cxx_obj)) \
- $(addsuffix .cxx.clean,$(cxx_od))
-
-
-# How to.
-#
-$(call include,$(bld_root)/cxx/o-e.make)
-$(call include,$(bld_root)/cxx/cxx-o.make)
-$(call include,$(bld_root)/cxx/cxx-d.make)
-
-# Dependencies.
-#
-$(call import,$(src_root)/cult/makefile)
diff --git a/libcult/examples/os/net/ipv4/multicast/protocol.hxx b/libcult/examples/os/net/ipv4/multicast/protocol.hxx
deleted file mode 100644
index a4057de..0000000
--- a/libcult/examples/os/net/ipv4/multicast/protocol.hxx
+++ /dev/null
@@ -1,20 +0,0 @@
-// file : examples/os/net/ipv4/multicast/protocol.hxx
-// author : Boris Kolpackov <boris@kolpackov.net>
-// copyright : Copyright (c) 2005-2010 Boris Kolpackov
-// license : GNU GPL v2 + exceptions; see accompanying LICENSE file
-
-#ifndef PROTOCOL_HXX
-#define PROTOCOL_HXX
-
-#include <cult/types.hxx>
-
-Cult::UnsignedShort const payload_size = 256;
-Cult::UnsignedLong const message_count = 100;
-
-struct Message
-{
- Cult::UnsignedLong sn;
- Cult::UnsignedShort payload[payload_size];
-};
-
-#endif // PROTOCOL_HXX
diff --git a/libcult/examples/os/net/ipv4/multicast/server.cxx b/libcult/examples/os/net/ipv4/multicast/server.cxx
deleted file mode 100644
index 5d8fe99..0000000
--- a/libcult/examples/os/net/ipv4/multicast/server.cxx
+++ /dev/null
@@ -1,134 +0,0 @@
-// file : examples/os/net/ipv4/datagram/server.cxx
-// author : Boris Kolpackov <boris@kolpackov.net>
-// copyright : Copyright (c) 2005-2010 Boris Kolpackov
-// license : GNU GPL v2 + exceptions; see accompanying LICENSE file
-
-#include <cult/types.hxx>
-#include <cult/containers/vector.hxx>
-
-#include <cult/os/net/ipv4/address.hxx>
-#include <cult/os/net/ipv4/multicast-socket.hxx>
-
-#include <iostream>
-#include <cstring> // memcmp
-
-#include "protocol.hxx"
-
-using std::cerr;
-using std::endl;
-
-using namespace Cult;
-using namespace OS::Net::IPv4;
-
-typedef Containers::Vector<Boolean> StatusList;
-
-class Args {};
-
-Int
-main (Int argc, Char* argv[])
-{
- try
- {
- if (argc < 2)
- throw Args ();
-
- Address addr (argv[1], 10000);
-
- MulticastSocket socket;
-
- socket.join (addr);
-
- Message expected_msg;
- expected_msg.sn = 0;
-
- for (UnsignedShort i = 0; i < payload_size; ++i)
- {
- expected_msg.payload[i] = i;
- }
-
- StatusList received (message_count, 0);
- StatusList damaged (message_count, 0);
- StatusList duplicate (message_count, 0);
-
- Message msg;
-
- while (true)
- {
- socket.recv (&msg, sizeof (msg));
-
- if (received[msg.sn])
- {
- duplicate[msg.sn] = true;
- }
- else
- {
- received[msg.sn] = true;
-
- if (std::memcmp (expected_msg.payload, msg.payload, payload_size) != 0)
- {
- damaged[msg.sn] = true;
- }
- }
-
- if (msg.sn + 1 == message_count) break;
- }
-
- UnsignedLong lost_count (0), damaged_count (0), duplicate_count (0);
-
- for (StatusList::Iterator i (received.begin ()), end (received.end ());
- i != end;
- ++i)
- if (!*i) ++lost_count;
-
- for (StatusList::Iterator i (damaged.begin ()), end (damaged.end ());
- i != end;
- ++i)
- if (*i) ++damaged_count;
-
- for (StatusList::Iterator i (duplicate.begin ()), end (duplicate.end ());
- i != end;
- ++i)
- if (*i) ++duplicate_count;
-
- cerr << "lost : " << lost_count << endl
- << "damaged : " << damaged_count << endl
- << "duplicate : " << duplicate_count << endl << endl;
-
- if (lost_count != 0)
- {
- cerr << "lost message dump:" << endl;
-
- UnsignedLong total = 0;
-
- for (StatusList::Iterator
- begin (received.begin ()), i (begin), end (received.end ());
- i != end;)
- {
- if (!*i)
- {
- UnsignedLong count = 1;
-
- for (StatusList::Iterator j = i + 1; j < end && !*j; j++, count++) ;
-
- cerr << '\t' << i - begin << " : " << count << endl;
-
- i += count;
- total += count;
- }
- else
- ++i;
- }
-
- if (total != lost_count)
- cerr << "trouble" << endl;
- }
- }
- catch (OS::Exception const& e)
- {
- cerr << "errno: " << e.code () << endl;
- }
- catch (Args const&)
- {
- cerr << "usage: client <IPv4 address>" << endl;
- }
-}
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-18 06:08:22 +0000