summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/AV
diff options
context:
space:
mode:
authorOssama Othman <ossama-othman@users.noreply.github.com>2005-06-13 16:13:38 +0000
committerOssama Othman <ossama-othman@users.noreply.github.com>2005-06-13 16:13:38 +0000
commit53d5fd049c452b172cceea1d8dac748769034f08 (patch)
treec18c99f847624feb8fc6e4aecdf9e2596c4340bb /TAO/orbsvcs/orbsvcs/AV
parent303de1936216d9f9fc3d98f116fd1ecec5811572 (diff)
downloadATCD-53d5fd049c452b172cceea1d8dac748769034f08.tar.gz
ChangeLogTag:Mon Jun 13 05:07:32 2005 Ossama Othman <ossama@dre.vanderbilt.edu>
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/AV')
-rw-r--r--TAO/orbsvcs/orbsvcs/AV/AVStreams_i.h2
-rw-r--r--TAO/orbsvcs/orbsvcs/AV/FlowSpec_Entry.cpp258
-rw-r--r--TAO/orbsvcs/orbsvcs/AV/FlowSpec_Entry.h6
-rw-r--r--TAO/orbsvcs/orbsvcs/AV/FlowSpec_Entry.i18
4 files changed, 142 insertions, 142 deletions
diff --git a/TAO/orbsvcs/orbsvcs/AV/AVStreams_i.h b/TAO/orbsvcs/orbsvcs/AV/AVStreams_i.h
index 38562894bad..9abef1eada5 100644
--- a/TAO/orbsvcs/orbsvcs/AV/AVStreams_i.h
+++ b/TAO/orbsvcs/orbsvcs/AV/AVStreams_i.h
@@ -69,7 +69,7 @@ public:
protected:
virtual ~AV_Null_MediaCtrl (void);
-
+
};
/**
diff --git a/TAO/orbsvcs/orbsvcs/AV/FlowSpec_Entry.cpp b/TAO/orbsvcs/orbsvcs/AV/FlowSpec_Entry.cpp
index 671fd744b45..09d59636c1b 100644
--- a/TAO/orbsvcs/orbsvcs/AV/FlowSpec_Entry.cpp
+++ b/TAO/orbsvcs/orbsvcs/AV/FlowSpec_Entry.cpp
@@ -186,11 +186,11 @@ TAO_FlowSpec_Entry::set_protocol (void)
{
if (ACE_OS::strcasecmp (this->carrier_protocol_.c_str(),"UDP") == 0)
{
- if (ACE_OS::strncasecmp (this->flow_protocol_.c_str (),"sfp",3) == 0)
- {
- this->protocol_ = TAO_AV_Core::TAO_AV_SFP_UDP;
- }
- else this->protocol_ = TAO_AV_Core::TAO_AV_USERDEFINED_UDP;
+ if (ACE_OS::strncasecmp (this->flow_protocol_.c_str (),"sfp",3) == 0)
+ {
+ this->protocol_ = TAO_AV_Core::TAO_AV_SFP_UDP;
+ }
+ else this->protocol_ = TAO_AV_Core::TAO_AV_USERDEFINED_UDP;
}
else
{
@@ -255,42 +255,42 @@ TAO_FlowSpec_Entry::parse_address (const char *address,
if (protocol_tokenizer [1] != 0)
{
ACE_DEBUG ((LM_DEBUG,
- "Protocol tokenixer is not null\n"));
+ "Protocol tokenixer is not null\n"));
if ((flow_comp == TAO_AV_Core::TAO_AV_DATA) ||
- //(flow_comp == TAO_AV_Core::TAO_AV_BOTH) ||
- (flow_comp == TAO_AV_Core::TAO_AV_CONTROL) )
+ //(flow_comp == TAO_AV_Core::TAO_AV_BOTH) ||
+ (flow_comp == TAO_AV_Core::TAO_AV_CONTROL) )
{
ACE_CString addr;
- if (this->protocol_ == TAO_AV_Core::TAO_AV_SCTP_SEQ)
- {
- TAO_Tokenizer addr_token (protocol_tokenizer [1], ';');
-
- ACE_DEBUG ((LM_DEBUG,
- "Number of local sec addresses = %d\n",
- addr_token.num_tokens () - 1));
-
- if (addr_token.num_tokens () != 0)
- {
- addr += addr_token [0];
- ACE_NEW_RETURN (local_sec_addr_, char* [addr_token.num_tokens () - 1],-1);
- for (int j = 1; j <= addr_token.num_tokens () - 1; j++)
- {
- ACE_DEBUG ((LM_DEBUG,
- "adding addresses to sequence %s\n",
- addr_token [j]));
-
- local_sec_addr_ [j-1] = CORBA::string_dup (addr_token [j]);
- }
- num_local_sec_addrs_ = addr_token.num_tokens () - 1;
- }
- }
- else addr += protocol_tokenizer[1];
+ if (this->protocol_ == TAO_AV_Core::TAO_AV_SCTP_SEQ)
+ {
+ TAO_Tokenizer addr_token (protocol_tokenizer [1], ';');
+
+ ACE_DEBUG ((LM_DEBUG,
+ "Number of local sec addresses = %d\n",
+ addr_token.num_tokens () - 1));
+
+ if (addr_token.num_tokens () != 0)
+ {
+ addr += addr_token [0];
+ ACE_NEW_RETURN (local_sec_addr_, char* [addr_token.num_tokens () - 1],-1);
+ for (int j = 1; j <= addr_token.num_tokens () - 1; j++)
+ {
+ ACE_DEBUG ((LM_DEBUG,
+ "adding addresses to sequence %s\n",
+ addr_token [j]));
+
+ local_sec_addr_ [j-1] = CORBA::string_dup (addr_token [j]);
+ }
+ num_local_sec_addrs_ = addr_token.num_tokens () - 1;
+ }
+ }
+ else addr += protocol_tokenizer[1];
switch (this->protocol_)
{
case TAO_AV_Core::TAO_AV_SFP_UDP:
- case TAO_AV_Core::TAO_AV_USERDEFINED_UDP:
+ case TAO_AV_Core::TAO_AV_USERDEFINED_UDP:
case TAO_AV_Core::TAO_AV_RTP_UDP:
case TAO_AV_Core::TAO_AV_TCP:
case TAO_AV_Core::TAO_AV_SCTP_SEQ:
@@ -306,12 +306,12 @@ TAO_FlowSpec_Entry::parse_address (const char *address,
if (flow_comp == TAO_AV_Core::TAO_AV_DATA)
{
this->clean_up_address_ = 1;
- this->address_ = inet_addr;
+ this->address_ = inet_addr;
}
else
{
this->clean_up_control_address_ = 1;
- this->control_address_ = inet_addr;
+ this->control_address_ = inet_addr;
}
if (IN_CLASSD (inet_addr->get_ip_address ()))
@@ -331,9 +331,9 @@ TAO_FlowSpec_Entry::parse_address (const char *address,
case TAO_AV_Core::TAO_AV_SFP_UDP:
this->protocol_ = TAO_AV_Core::TAO_AV_SFP_UDP_MCAST;
break;
- case TAO_AV_Core::TAO_AV_USERDEFINED_UDP:
- this->protocol_ = TAO_AV_Core::TAO_AV_USERDEFINED_UDP_MCAST;
- break;
+ case TAO_AV_Core::TAO_AV_USERDEFINED_UDP:
+ this->protocol_ = TAO_AV_Core::TAO_AV_USERDEFINED_UDP_MCAST;
+ break;
default:
break;
}
@@ -346,9 +346,9 @@ TAO_FlowSpec_Entry::parse_address (const char *address,
}
else
{
- ACE_DEBUG ((LM_DEBUG,
- "AV BOTH %s \n",
- protocol_tokenizer[1]));
+ ACE_DEBUG ((LM_DEBUG,
+ "AV BOTH %s \n",
+ protocol_tokenizer[1]));
TAO_Tokenizer address_tokenizer (protocol_tokenizer[1], ':');
TAO_Tokenizer port_tokenizer (address_tokenizer[1], ';');
@@ -357,27 +357,27 @@ TAO_FlowSpec_Entry::parse_address (const char *address,
addr += ":";
addr += port_tokenizer[0];
- if (this->protocol_ == TAO_AV_Core::TAO_AV_SCTP_SEQ)
- {
-
- ACE_DEBUG ((LM_DEBUG,
- "Number of local sec addresses = %d\n",
- port_tokenizer.num_tokens () - 1));
-
- if (port_tokenizer.num_tokens () - 1 != 0)
- {
- ACE_NEW_RETURN (local_sec_addr_, char* [port_tokenizer.num_tokens () - 1],-1);
- for (int j = 1; j <= port_tokenizer.num_tokens () - 1; j++)
- {
- ACE_DEBUG ((LM_DEBUG,
- "adding addresses to sequence %s\n",
- port_tokenizer [j]));
+ if (this->protocol_ == TAO_AV_Core::TAO_AV_SCTP_SEQ)
+ {
- local_sec_addr_ [j-1] = CORBA::string_dup (port_tokenizer [j]);
- }
- num_local_sec_addrs_ = port_tokenizer.num_tokens () - 1;
- }
- }
+ ACE_DEBUG ((LM_DEBUG,
+ "Number of local sec addresses = %d\n",
+ port_tokenizer.num_tokens () - 1));
+
+ if (port_tokenizer.num_tokens () - 1 != 0)
+ {
+ ACE_NEW_RETURN (local_sec_addr_, char* [port_tokenizer.num_tokens () - 1],-1);
+ for (int j = 1; j <= port_tokenizer.num_tokens () - 1; j++)
+ {
+ ACE_DEBUG ((LM_DEBUG,
+ "adding addresses to sequence %s\n",
+ port_tokenizer [j]));
+
+ local_sec_addr_ [j-1] = CORBA::string_dup (port_tokenizer [j]);
+ }
+ num_local_sec_addrs_ = port_tokenizer.num_tokens () - 1;
+ }
+ }
short control_port = ACE_OS::atoi(port_tokenizer[0]) + 1;
char control_port_str[6];
@@ -454,7 +454,7 @@ TAO_FlowSpec_Entry::parse_address (const char *address,
}
}
ACE_DEBUG ((LM_DEBUG,
- "Return from parse address\n"));
+ "Return from parse address\n"));
return 0;
}
@@ -561,45 +561,45 @@ TAO_Forward_FlowSpec_Entry::parse (const char *flowSpec_entry)
if (this->protocol_ == TAO_AV_Core::TAO_AV_SCTP_SEQ)
- {
- TAO_Tokenizer addr_token (tokenizer [TAO_AV_PEER_ADDR], ';');
-
- ACE_DEBUG ((LM_DEBUG,
- "Number of peer sec addresses = %d\n",
- addr_token.num_tokens () - 1));
-
- if (addr_token.num_tokens () != 0)
- {
- ACE_NEW_RETURN (addr,
- ACE_INET_Addr (addr_token [0]),
- 0);
-
- ACE_NEW_RETURN (peer_sec_addr_, char* [addr_token.num_tokens () - 1],-1);
- for (int j = 1; j <= addr_token.num_tokens () - 1; j++)
- {
- ACE_DEBUG ((LM_DEBUG,
- "adding addresses to sequence %s\n",
- addr_token [j]));
-
- peer_sec_addr_ [j-1] = CORBA::string_dup (addr_token [j]);
- }
- num_peer_sec_addrs_ = addr_token.num_tokens () - 1;
- }
- }
+ {
+ TAO_Tokenizer addr_token (tokenizer [TAO_AV_PEER_ADDR], ';');
+
+ ACE_DEBUG ((LM_DEBUG,
+ "Number of peer sec addresses = %d\n",
+ addr_token.num_tokens () - 1));
+
+ if (addr_token.num_tokens () != 0)
+ {
+ ACE_NEW_RETURN (addr,
+ ACE_INET_Addr (addr_token [0]),
+ 0);
+
+ ACE_NEW_RETURN (peer_sec_addr_, char* [addr_token.num_tokens () - 1],-1);
+ for (int j = 1; j <= addr_token.num_tokens () - 1; j++)
+ {
+ ACE_DEBUG ((LM_DEBUG,
+ "adding addresses to sequence %s\n",
+ addr_token [j]));
+
+ peer_sec_addr_ [j-1] = CORBA::string_dup (addr_token [j]);
+ }
+ num_peer_sec_addrs_ = addr_token.num_tokens () - 1;
+ }
+ }
else
- {
- ACE_NEW_RETURN (addr,
- ACE_INET_Addr (tokenizer [TAO_AV_PEER_ADDR]),
- 0);
- }
+ {
+ ACE_NEW_RETURN (addr,
+ ACE_INET_Addr (tokenizer [TAO_AV_PEER_ADDR]),
+ 0);
+ }
this->delete_peer_addr_ = true;
this->peer_addr_ = addr;
char buf [BUFSIZ];
addr->addr_to_string (buf, BUFSIZ);
ACE_DEBUG ((LM_DEBUG,
- "Peer Address %s \n",
- buf));
+ "Peer Address %s \n",
+ buf));
}
@@ -669,13 +669,13 @@ TAO_Forward_FlowSpec_Entry::entry_to_string (void)
address_str += cstring;
if (this->protocol_ == TAO_AV_Core::TAO_AV_SCTP_SEQ)
- {
- for (int i = 0; i < this->num_local_sec_addrs_; i++)
- {
- address_str += ";";
- address_str += this->local_sec_addr_ [i];
- }
- }
+ {
+ for (int i = 0; i < this->num_local_sec_addrs_; i++)
+ {
+ address_str += ";";
+ address_str += this->local_sec_addr_ [i];
+ }
+ }
}
else
@@ -702,7 +702,7 @@ TAO_Forward_FlowSpec_Entry::entry_to_string (void)
case TAO_AV_Core::TAO_AV_QOS_UDP:
case TAO_AV_Core::TAO_AV_UDP_MCAST:
case TAO_AV_Core::TAO_AV_TCP:
- case TAO_AV_Core::TAO_AV_SCTP_SEQ:
+ case TAO_AV_Core::TAO_AV_SCTP_SEQ:
{
ACE_INET_Addr *inet_addr = dynamic_cast<ACE_INET_Addr*> (this->address_);
control_port = inet_addr->get_port_number() + 1;
@@ -733,13 +733,13 @@ TAO_Forward_FlowSpec_Entry::entry_to_string (void)
case TAO_AV_Core::TAO_AV_QOS_UDP:
case TAO_AV_Core::TAO_AV_UDP_MCAST:
case TAO_AV_Core::TAO_AV_TCP:
- case TAO_AV_Core::TAO_AV_SCTP_SEQ:
+ case TAO_AV_Core::TAO_AV_SCTP_SEQ:
{
- ACE_INET_Addr *inet_addr = dynamic_cast<ACE_INET_Addr*> (this->peer_addr_);
+ ACE_INET_Addr *inet_addr = dynamic_cast<ACE_INET_Addr*> (this->peer_addr_);
inet_addr->addr_to_string (address,BUFSIZ);
- //inet_addr->get_host_name (address, BUFSIZ);
+ //inet_addr->get_host_name (address, BUFSIZ);
- //cstring += ACE_OS::itoa (address, BUFSIZ, inet_addr->get_port_number ());
+ //cstring += ACE_OS::itoa (address, BUFSIZ, inet_addr->get_port_number ());
}
break;
@@ -747,20 +747,20 @@ TAO_Forward_FlowSpec_Entry::entry_to_string (void)
break;
}
- ACE_CString cstring (address);
+ ACE_CString cstring (address);
- //peer_address_str = this->carrier_protocol_;
- //peer_address_str += "=";
- peer_address_str += cstring;
+ //peer_address_str = this->carrier_protocol_;
+ //peer_address_str += "=";
+ peer_address_str += cstring;
- if (this->protocol_ == TAO_AV_Core::TAO_AV_SCTP_SEQ)
- {
- for (int i = 0; i < this->num_peer_sec_addrs_; i++)
- {
- peer_address_str += ";";
- peer_address_str += this->peer_sec_addr_ [i];
- }
- }
+ if (this->protocol_ == TAO_AV_Core::TAO_AV_SCTP_SEQ)
+ {
+ for (int i = 0; i < this->num_peer_sec_addrs_; i++)
+ {
+ peer_address_str += ";";
+ peer_address_str += this->peer_sec_addr_ [i];
+ }
+ }
}
@@ -780,7 +780,7 @@ TAO_Forward_FlowSpec_Entry::entry_to_string (void)
case TAO_AV_Core::TAO_AV_QOS_UDP:
case TAO_AV_Core::TAO_AV_UDP_MCAST:
case TAO_AV_Core::TAO_AV_TCP:
- case TAO_AV_Core::TAO_AV_SCTP_SEQ:
+ case TAO_AV_Core::TAO_AV_SCTP_SEQ:
{
ACE_INET_Addr *inet_addr = dynamic_cast<ACE_INET_Addr*> (this->control_address_);
control_port = inet_addr->get_port_number();
@@ -812,7 +812,7 @@ TAO_Forward_FlowSpec_Entry::entry_to_string (void)
this->entry_ += peer_address_str;
}
else ACE_DEBUG ((LM_DEBUG,
- "No peer address specified\n"));
+ "No peer address specified\n"));
if (TAO_debug_level > 0)
ACE_DEBUG ((LM_DEBUG,"Forward entry_to_string: entry = %s\n",this->entry_.c_str()));
@@ -933,7 +933,7 @@ TAO_Reverse_FlowSpec_Entry::entry_to_string (void)
case TAO_AV_Core::TAO_AV_QOS_UDP:
case TAO_AV_Core::TAO_AV_UDP_MCAST:
case TAO_AV_Core::TAO_AV_TCP:
- case TAO_AV_Core::TAO_AV_SCTP_SEQ:
+ case TAO_AV_Core::TAO_AV_SCTP_SEQ:
case TAO_AV_Core::TAO_AV_SFP_UDP:
case TAO_AV_Core::TAO_AV_USERDEFINED_UDP:
{
@@ -951,13 +951,13 @@ TAO_Reverse_FlowSpec_Entry::entry_to_string (void)
address_str += cstring;
if (this->protocol_ == TAO_AV_Core::TAO_AV_SCTP_SEQ)
- {
- for (int i = 0; i < this->num_local_sec_addrs_; i++)
- {
- address_str += ";";
- address_str += this->local_sec_addr_ [i];
- }
- }
+ {
+ for (int i = 0; i < this->num_local_sec_addrs_; i++)
+ {
+ address_str += ";";
+ address_str += this->local_sec_addr_ [i];
+ }
+ }
}
else
@@ -982,7 +982,7 @@ TAO_Reverse_FlowSpec_Entry::entry_to_string (void)
case TAO_AV_Core::TAO_AV_QOS_UDP:
case TAO_AV_Core::TAO_AV_UDP_MCAST:
case TAO_AV_Core::TAO_AV_TCP:
- case TAO_AV_Core::TAO_AV_SCTP_SEQ:
+ case TAO_AV_Core::TAO_AV_SCTP_SEQ:
{
ACE_INET_Addr *inet_addr = dynamic_cast<ACE_INET_Addr*> (this->control_address_);
control_port = inet_addr->get_port_number();
diff --git a/TAO/orbsvcs/orbsvcs/AV/FlowSpec_Entry.h b/TAO/orbsvcs/orbsvcs/AV/FlowSpec_Entry.h
index b605ebe401b..f55250dbbb3 100644
--- a/TAO/orbsvcs/orbsvcs/AV/FlowSpec_Entry.h
+++ b/TAO/orbsvcs/orbsvcs/AV/FlowSpec_Entry.h
@@ -33,7 +33,7 @@ public:
TAO_Tokenizer (const char *string,char delimiter);
/// destructor.
- ~TAO_Tokenizer ();
+ ~TAO_Tokenizer (void);
/// parses the string and tokenizes it.
int parse (const char *string,char delimiter);
@@ -159,7 +159,7 @@ public:
int set_peer_sec_addr (char** peer_sec_addr, int size);
char** get_peer_sec_addr (void);
int num_peer_sec_addrs (void);
-
+
int set_local_addr (ACE_Addr *local_addr);
ACE_Addr *get_local_addr (void);
char *get_local_addr_str (void);
@@ -271,7 +271,7 @@ public:
TAO_AV_FORMAT = 2,
TAO_AV_FLOW_PROTOCOL = 3,
TAO_AV_ADDRESS = 4,
- TAO_AV_PEER_ADDR = 5};
+ TAO_AV_PEER_ADDR = 5};
/// default constructor.
TAO_Forward_FlowSpec_Entry (void);
diff --git a/TAO/orbsvcs/orbsvcs/AV/FlowSpec_Entry.i b/TAO/orbsvcs/orbsvcs/AV/FlowSpec_Entry.i
index fcc386e30d5..7d02df695ea 100644
--- a/TAO/orbsvcs/orbsvcs/AV/FlowSpec_Entry.i
+++ b/TAO/orbsvcs/orbsvcs/AV/FlowSpec_Entry.i
@@ -31,7 +31,7 @@ TAO_FlowSpec_Entry::parse_flow_protocol_string (const char *flow_string)
return 0;
if (ACE_OS::strcmp (flow_string,"") == 0)
- return 0;
+ return 0;
this->use_flow_protocol_ = 1;
// do some flow protocol processing.
@@ -185,9 +185,9 @@ TAO_FlowSpec_Entry::get_local_control_addr (void)
}
ACE_INLINE
-int
+int
TAO_FlowSpec_Entry::set_local_sec_addr (char** local_sec_addr,
- int size)
+ int size)
{
this->local_sec_addr_ = local_sec_addr;
this->num_local_sec_addrs_ = size;
@@ -195,23 +195,23 @@ TAO_FlowSpec_Entry::set_local_sec_addr (char** local_sec_addr,
}
ACE_INLINE
-char**
+char**
TAO_FlowSpec_Entry::get_local_sec_addr (void)
{
return this->local_sec_addr_;
}
ACE_INLINE
-int
+int
TAO_FlowSpec_Entry::num_local_sec_addrs (void)
{
return this->num_local_sec_addrs_;
}
ACE_INLINE
-int
+int
TAO_FlowSpec_Entry::set_peer_sec_addr (char** peer_sec_addr,
- int size)
+ int size)
{
this->peer_sec_addr_ = peer_sec_addr;
this->num_peer_sec_addrs_ = size;
@@ -219,14 +219,14 @@ TAO_FlowSpec_Entry::set_peer_sec_addr (char** peer_sec_addr,
}
ACE_INLINE
-char**
+char**
TAO_FlowSpec_Entry::get_peer_sec_addr (void)
{
return this->peer_sec_addr_;
}
ACE_INLINE
-int
+int
TAO_FlowSpec_Entry::num_peer_sec_addrs (void)
{
return this->num_peer_sec_addrs_;