// $Id$ // Defines the Internet domain address family address format. #include "ace/ATM_Addr.h" #if defined (ACE_HAS_FORE_ATM_WS2) #include "forews2.h" #endif /* ACE_HAS_FORE_ATM_WS2 */ #if !defined (__ACE_INLINE__) #include "ace/ATM_Addr.i" #endif /* __ACE_INLINE__ */ ACE_RCSID(ace, ATM_Addr, "$Id$") ACE_ALLOC_HOOK_DEFINE(ACE_ATM_Addr) #if defined (ACE_HAS_FORE_ATM_XTI) || defined (ACE_HAS_FORE_ATM_WS2) #define BHLI_MAGIC "FORE_ATM" // This is line rate in cells/s for an OC-3 MM interface. const long ACE_ATM_Addr::LINE_RATE = 353207; const int ACE_ATM_Addr::OPT_FLAGS_CPID = 0x1; const int ACE_ATM_Addr::OPT_FLAGS_PMP = 0x2; const int ACE_ATM_Addr::DEFAULT_SELECTOR = 0x99; #else const long ACE_ATM_Addr::LINE_RATE = 0L; const int ACE_ATM_Addr::OPT_FLAGS_CPID = 0; const int ACE_ATM_Addr::OPT_FLAGS_PMP = 0; const int ACE_ATM_Addr::DEFAULT_SELECTOR = 0x0; #endif /* ACE_HAS_FORE_ATM_XTI || ACE_HAS_FORE_ATM_WS2 */ // Default constructor ACE_ATM_Addr::ACE_ATM_Addr (unsigned char selector) #if defined (ACE_HAS_FORE_ATM_XTI) || defined (ACE_HAS_FORE_ATM_WS2) : ACE_Addr (AF_ATM, #else : ACE_Addr (AF_UNSPEC, #endif /* ACE_HAS_FORE_ATM_XTI || ACE_HAS_FORE_ATM_WS2 */ sizeof this->atm_addr_) { // ACE_TRACE ("ACE_ATM_Addr::ACE_ATM_Addr"); (void) ACE_OS::memset ((void *) &this->atm_addr_, 0, sizeof this->atm_addr_); this->init (selector); } // Copy constructor. ACE_ATM_Addr::ACE_ATM_Addr (const ACE_ATM_Addr &sap, unsigned char selector) #if defined (ACE_HAS_FORE_ATM_XTI) || defined (ACE_HAS_FORE_ATM_WS2) : ACE_Addr (AF_ATM, #else : ACE_Addr (AF_UNSPEC, #endif /* ACE_HAS_FORE_ATM_XTI || ACE_HAS_FORE_ATM_WS2 */ sizeof this->atm_addr_) { ACE_TRACE ("ACE_ATM_Addr::ACE_ATM_Addr"); this->set (sap, selector); } ACE_ATM_Addr::ACE_ATM_Addr (const ATM_Addr *sap, unsigned char selector) #if defined (ACE_HAS_FORE_ATM_XTI) || defined (ACE_HAS_FORE_ATM_WS2) : ACE_Addr (AF_ATM, #else : ACE_Addr (AF_UNSPEC, #endif /* ACE_HAS_FORE_ATM_XTI || ACE_HAS_FORE_ATM_WS2 */ sizeof this->atm_addr_) { ACE_TRACE ("ACE_ATM_Addr::ACE_ATM_Addr"); this->set (sap, selector); } ACE_ATM_Addr::ACE_ATM_Addr (const ACE_TCHAR sap[], unsigned char selector) #if defined (ACE_HAS_FORE_ATM_XTI) || defined (ACE_HAS_FORE_ATM_WS2) : ACE_Addr (AF_ATM, #else : ACE_Addr (AF_UNSPEC, #endif /* ACE_HAS_FORE_ATM_XTI || ACE_HAS_FORE_ATM_WS2 */ sizeof this->atm_addr_) { ACE_TRACE ("ACE_ATM_Addr::ACE_ATM_Addr"); this->set (sap, selector); } void ACE_ATM_Addr::init (unsigned char selector) { #if defined (ACE_HAS_FORE_ATM_XTI) // Note: this approach may be FORE implementation-specific. When we // bind with tag_addr ABSENT and tag_selector PRESENT, only the // selector (i.e. address[19]) is used by the TP. The rest of the // local address is filled in by the TP and can be obtained via the // 'ret' parameter or with t_getname()/t_getprotaddr(). atm_addr_.addressType = (u_int16_t) AF_ATM; atm_addr_.sap.t_atm_sap_addr.SVE_tag_addr = (int8_t) T_ATM_ABSENT; atm_addr_.sap.t_atm_sap_addr.SVE_tag_selector = (int8_t) T_ATM_PRESENT; atm_addr_.sap.t_atm_sap_addr.address_format = (u_int8_t) T_ATM_ENDSYS_ADDR; atm_addr_.sap.t_atm_sap_addr.address_length = ATMNSAP_ADDR_LEN; atm_addr_.sap.t_atm_sap_addr.address[ATMNSAP_ADDR_LEN - 1] = selector; atm_addr_.sap.t_atm_sap_layer2.SVE_tag = (int8_t) T_ATM_ABSENT; atm_addr_.sap.t_atm_sap_layer3.SVE_tag = (int8_t) T_ATM_ABSENT; atm_addr_.sap.t_atm_sap_appl.SVE_tag = (int8_t) T_ATM_PRESENT; atm_addr_.sap.t_atm_sap_appl.ID_type = (u_int8_t) T_ATM_USER_APP_ID; ACE_OS::memcpy (atm_addr_.sap.t_atm_sap_appl.ID.user_defined_ID, BHLI_MAGIC, sizeof atm_addr_.sap.t_atm_sap_appl.ID); #elif defined (ACE_HAS_FORE_ATM_WS2) ACE_OS::memset(( void *)&atm_addr_, 0, sizeof atm_addr_ ); atm_addr_.satm_number.Addr[ ATM_ADDR_SIZE - 1 ] = ( char )selector; atm_addr_.satm_family = AF_ATM; atm_addr_.satm_number.AddressType = ATM_NSAP; atm_addr_.satm_number.NumofDigits = ATM_ADDR_SIZE; atm_addr_.satm_blli.Layer2Protocol = SAP_FIELD_ABSENT; atm_addr_.satm_blli.Layer3Protocol = SAP_FIELD_ABSENT; atm_addr_.satm_bhli.HighLayerInfoType = SAP_FIELD_ABSENT; // Need to know the correspondence. //atm_addr_.sap.t_atm_sap_appl.SVE_tag = (int8_t) T_ATM_PRESENT; //atm_addr_.sap.t_atm_sap_appl.ID_type = (u_int8_t) T_ATM_USER_APP_ID; //ACE_OS::memcpy (atm_addr_.sap.t_atm_sap_appl.ID.user_defined_ID, // BHLI_MAGIC, // sizeof atm_addr_.sap.t_atm_sap_appl.ID); #else ACE_UNUSED_ARG (selector); #endif /* ACE_HAS_FORE_ATM_XTI && ACE_HAS_FORE_ATM_WS2 */ } int ACE_ATM_Addr::set (const ACE_ATM_Addr &sap, unsigned char selector) { ACE_TRACE ("ACE_ATM_Addr::set"); this->init (selector); this->ACE_Addr::base_set (sap.get_type (), sap.get_size ()); #if defined (ACE_HAS_FORE_ATM_XTI) || defined (ACE_HAS_FORE_ATM_WS2) ACE_ASSERT (sap.get_type () == AF_ATM); #endif /* ACE_HAS_FORE_ATM_XTI || ACE_HAS_FORE_ATM_WS2 */ (void) ACE_OS::memcpy ((void *) &this->atm_addr_, (void *) &sap.atm_addr_, sizeof this->atm_addr_); return 0; } int ACE_ATM_Addr::set (const ATM_Addr *sap, unsigned char selector) { ACE_TRACE ("ACE_ATM_Addr::set"); this->init (selector); #if defined (ACE_HAS_FORE_ATM_XTI) || defined (ACE_HAS_FORE_ATM_WS2) this->ACE_Addr::base_set (AF_ATM, #else this->ACE_Addr::base_set (AF_UNSPEC, #endif /* ACE_HAS_FORE_ATM_XTI || ACE_HAS_FORE_ATM_WS2 */ sizeof (*sap)); (void) ACE_OS::memcpy ((void *) &this->atm_addr_, (void *) sap, sizeof this->atm_addr_); return 0; } int ACE_ATM_Addr::set (const ACE_TCHAR address[], unsigned char selector) { ACE_TRACE ("ACE_ATM_Addr::set"); int ret; this->init (selector); #if defined (ACE_HAS_FORE_ATM_XTI) atm_addr_.sap.t_atm_sap_addr.SVE_tag_addr = (int8_t) T_ATM_PRESENT; #endif /* ACE_HAS_FORE_ATM_XTI */ ret = this -> string_to_addr( address ); this -> set_selector( selector ); return ret; } // Transform the string into the current addressing format. int ACE_ATM_Addr::string_to_addr (const ACE_TCHAR sap[]) { ACE_TRACE ("ACE_ATM_Addr::string_to_addr"); #if defined (ACE_HAS_FORE_ATM_XTI) || defined (ACE_HAS_FORE_ATM_WS2) this->ACE_Addr::base_set (AF_ATM, #else this->ACE_Addr::base_set (AF_UNSPEC, #endif /* ACE_HAS_FORE_ATM_XTI || ACE_HAS_FORE_ATM_WS2 */ sizeof this->atm_addr_); #if defined (ACE_HAS_FORE_ATM_XTI) struct hostent *entry; struct atmnsap_addr *nsap; // Yow, someone gave us a NULL ATM address! if (sap == 0) { errno = EINVAL; return -1; } else if ((entry = gethostbyname_atmnsap((ACE_TCHAR *)sap)) != 0) { ACE_OS::memcpy (atm_addr_.sap.t_atm_sap_addr.address, entry->h_addr_list[0], ATMNSAP_ADDR_LEN - 1); } else if ((nsap = atmnsap_addr (sap)) != 0) { ACE_OS::memcpy (atm_addr_.sap.t_atm_sap_addr.address, nsap->atmnsap, ATMNSAP_ADDR_LEN); } else { errno = EINVAL; return -1; } #elif defined (ACE_HAS_FORE_ATM_WS2) DWORD dwValue; HANDLE hLookup; WSAQUERYSETW qsRestrictions; CSADDR_INFO csaBuffer; WCHAR tmpWStr[100]; MultiByteToWideChar(CP_ACP, MB_PRECOMPOSED, sap, -1, tmpWStr, 100); csaBuffer.LocalAddr.iSockaddrLength = sizeof (struct sockaddr_atm); csaBuffer.LocalAddr.lpSockaddr = (struct sockaddr *)&atm_addr_; csaBuffer.RemoteAddr.iSockaddrLength = sizeof (struct sockaddr_atm); csaBuffer.RemoteAddr.lpSockaddr = (struct sockaddr *)&atm_addr_; qsRestrictions.dwSize = sizeof (WSAQUERYSETW); qsRestrictions.lpszServiceInstanceName = NULL; qsRestrictions.lpServiceClassId = &FORE_NAME_CLASS; qsRestrictions.lpVersion = NULL; qsRestrictions.lpszComment = NULL; qsRestrictions.dwNameSpace = FORE_NAME_SPACE; qsRestrictions.lpNSProviderId = NULL; qsRestrictions.lpszContext = L""; qsRestrictions.dwNumberOfProtocols = 0; qsRestrictions.lpafpProtocols = NULL; qsRestrictions.lpszQueryString = tmpWStr; qsRestrictions.dwNumberOfCsAddrs = 1; qsRestrictions.lpcsaBuffer = &csaBuffer; qsRestrictions.lpBlob = NULL; //&blob; if ( ::WSALookupServiceBeginW(&qsRestrictions, LUP_RETURN_ALL, &hLookup) == SOCKET_ERROR) { ACE_OS::printf( "Error: WSALookupServiceBeginW failed! %d\n", ::WSAGetLastError()); return -1; } dwValue = sizeof (WSAQUERYSETW); if ( ::WSALookupServiceNextW( hLookup, 0, &dwValue, &qsRestrictions) == SOCKET_ERROR) { if ( WSAGetLastError() != WSA_E_NO_MORE ) { ACE_OS::printf( "Error: WSALookupServiceNextW failed! %d\n", ::WSAGetLastError()); return -1; } } if (WSALookupServiceEnd (hLookup) == SOCKET_ERROR) { ACE_OS::printf( "Error : WSALookupServiceEnd failed! %d \n", ::WSAGetLastError()); errno = EINVAL; return -1; } #else ACE_UNUSED_ARG (sap); return 0; #endif /* ACE_HAS_FORE_ATM_XTI && ACE_HAS_FORE_ATM_WS2 */ #if defined (ACE_HAS_FORE_ATM_XTI) || defined (ACE_HAS_FORE_ATM_WS2) return 0; #endif /* ACE_HAS_FORE_ATM_XTI || ACE_HAS_FORE_ATM_WS2 */ } // Transform the current address into string format. int ACE_ATM_Addr::addr_to_string (ACE_TCHAR addr[], size_t addrlen) const { ACE_TRACE ("ACE_ATM_Addr::addr_to_string"); #if defined (ACE_HAS_FORE_ATM_XTI) ACE_TCHAR buffer[MAXNAMELEN + 1]; struct atmnsap_addr nsap; ACE_OS::memcpy (nsap.atmnsap, atm_addr_.sap.t_atm_sap_addr.address, ATMNSAP_ADDR_LEN); ACE_OS::sprintf (buffer, ACE_TEXT ("%s"), atmnsap_ntoa (nsap)); size_t total_len = ACE_OS::strlen (buffer) + sizeof ('\0'); // For trailing '\0'. if (addrlen < total_len) return -1; else ACE_OS::strcpy(addr, buffer); return 0; #elif defined (ACE_HAS_FORE_ATM_WS2) ACE_TCHAR buffer[MAXNAMELEN + 1]; int i; if ( addrlen < ATM_ADDR_SIZE + 1 ) return -1; for ( i = 0; i < ATM_ADDR_SIZE; i++ ) { buffer[ i * 3 ] = '\0'; ACE_OS::sprintf( buffer, ACE_TEXT( "%s%02x." ), buffer, atm_addr_.satm_number.Addr[ i ]); } buffer[ ATM_ADDR_SIZE * 3 - 1 ] = '\0'; ACE_OS::strcpy( addr, buffer ); return 0; #else ACE_UNUSED_ARG (addr); ACE_UNUSED_ARG (addrlen); return -1; #endif /* ACE_HAS_FORE_ATM_XTI && ACE_HAS_FORE_ATM_WS2 */ } const ACE_TCHAR * ACE_ATM_Addr::addr_to_string (void) const { ACE_TRACE ("ACE_ATM_Addr::addr_to_string"); static ACE_TCHAR addr[MAXHOSTNAMELEN + 1]; this->addr_to_string (addr, MAXHOSTNAMELEN + 1); return addr; } // Set a pointer to the address. void ACE_ATM_Addr::set_addr (void *addr, int len) { ACE_TRACE ("ACE_ATM_Addr::set_addr"); #if defined (ACE_HAS_FORE_ATM_XTI) || defined (ACE_HAS_FORE_ATM_WS2) this->ACE_Addr::base_set (AF_ATM, #else this->ACE_Addr::base_set (AF_UNSPEC, #endif /* ACE_HAS_FORE_ATM_XTI || ACE_HAS_FORE_WS2 */ len); ACE_OS::memcpy ((void *) &this->atm_addr_, (void *) addr, len); } // Compare two addresses for inequality. int ACE_ATM_Addr::operator != (const ACE_ATM_Addr &sap) const { ACE_TRACE ("ACE_ATM_Addr::operator !="); return !((*this) == sap); } // Compare two addresses for equality. int ACE_ATM_Addr::operator == (const ACE_ATM_Addr &sap) const { ACE_TRACE ("ACE_ATM_Addr::operator =="); return ACE_OS::memcmp (&atm_addr_, &sap.atm_addr_, sizeof (ATM_Addr)) == 0; } void ACE_ATM_Addr::dump (void) const { ACE_TRACE ("ACE_ATM_Addr::dump"); ACE_DEBUG ((LM_DEBUG, ACE_BEGIN_DUMP, this)); ACE_TCHAR s[ACE_MAX_FULLY_QUALIFIED_NAME_LEN + 16]; ACE_OS::sprintf (s, ACE_TEXT ("%s"), this->addr_to_string ()); ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("%s"), s)); ACE_DEBUG ((LM_DEBUG, ACE_END_DUMP)); } // char * // ACE_ATM_Addr::construct_options(ACE_HANDLE fd, // int qos_kb, // int flags, // long *optsize) // { // #if defined (ACE_HAS_FORE_ATM_XTI) // struct t_opthdr *popt; // char *buf; // int qos_cells; // struct t_info info; // if (ACE_OS::t_getinfo (fd, &info) == -1) // { // ACE_OS::t_error ("t_getinfo"); // return 0; // } // buf = (char *) ACE_OS::malloc (info.options); // if (buf == 0) // ACE_ERROR_RETURN ((LM_ERROR, // ACE_TEXT ("Unable to allocate %d bytes for options\n"), // info.options), // 0); // popt = (struct t_opthdr *) buf; // if (flags & OPT_FLAGS_CPID) // { // // This constructs the T_ATM_ORIG_ADDR option, which is used to // // signal the UNI 3.1 Calling Party ID Information Element. // t_atm_addr *source_addr; // popt->len = sizeof (struct t_opthdr) + sizeof (t_atm_addr); // popt->level = T_ATM_SIGNALING; // popt->name = T_ATM_ORIG_ADDR; // popt->status = 0; // source_addr = // (t_atm_addr *)((char *) popt + sizeof (struct t_opthdr)); // source_addr->address_format = T_ATM_ENDSYS_ADDR; // source_addr->address_length = ATMNSAP_ADDR_LEN; // ACE_OS::memcpy(source_addr->address, // atm_addr_.sap.t_atm_sap_addr.address, // 20); // //if (get_local_address (fd, source_addr->address)) // // { // // ACE_ERROR ((LM_ERROR, // // ACE_TEXT ("Can't get local address!\n"))); // // ACE_OS::free (buf); // // return 0; // // } // popt = T_OPT_NEXTHDR (buf, info.options , popt); // } // // This constructs all options necessary (bearer cap., QoS, and // // Traffic Descriptor) to signal for a CBR connection with the // // specified QoS in kbit/sec., and/or specify a PMP connection. // // For FORE 200e cards, the adapter shapes traffic to CBR with rate // // equal to PCR CLP=0+1 (traffic.forward.PCR_all_traffic) // qos_cells = (qos_kb * 1000) / (48*8); // if ((qos_cells > 0 && qos_cells < LINE_RATE) // || (ACE_BIT_ENABLED (flags, OPT_FLAGS_PMP))) // { // struct t_atm_bearer *bearer; // struct t_atm_traffic *traffic; // // T_ATM_BEARER_CAP: Broadband bearer capability // popt->len = sizeof (struct t_opthdr) + sizeof (struct t_atm_bearer); // popt->level = T_ATM_SIGNALING; // popt->name = T_ATM_BEARER_CAP; // popt->status = 0; // bearer = (struct t_atm_bearer *)((char *) popt + sizeof (struct t_opthdr)); // bearer->bearer_class = T_ATM_CLASS_X; // if (qos_cells) // { // bearer->traffic_type = T_ATM_CBR; // bearer->timing_requirements = T_ATM_END_TO_END; // } // else // { // bearer->traffic_type = 0; // UBR // bearer->timing_requirements = 0; // } // bearer->clipping_susceptibility = T_ATM_NULL; // if (ACE_BIT_ENABLED (flags, OPT_FLAGS_PMP)) // bearer->connection_configuration = T_ATM_1_TO_MANY; // else // bearer->connection_configuration = T_ATM_1_TO_1; // popt = T_OPT_NEXTHDR (buf, info.options, popt); // // T_ATM_TRAFFIC: traffic descriptor // popt->len = sizeof (struct t_opthdr) + sizeof (struct t_atm_traffic); // popt->level = T_ATM_SIGNALING; // popt->name = T_ATM_TRAFFIC; // popt->status = 0; // traffic = (struct t_atm_traffic *)((char *) popt + sizeof (struct t_opthdr)); // traffic->forward.PCR_high_priority = T_ATM_ABSENT; // traffic->forward.PCR_all_traffic = qos_cells ? qos_cells : LINE_RATE; // traffic->forward.SCR_high_priority = T_ATM_ABSENT; // traffic->forward.SCR_all_traffic = T_ATM_ABSENT; // traffic->forward.MBS_high_priority = T_ATM_ABSENT; // traffic->forward.MBS_all_traffic = T_ATM_ABSENT; // traffic->forward.tagging = T_NO; // traffic->backward.PCR_high_priority = T_ATM_ABSENT; // traffic->backward.PCR_all_traffic = // (ACE_BIT_ENABLED (flags, OPT_FLAGS_PMP)) // ? 0 : qos_cells ? qos_cells : LINE_RATE; // traffic->backward.SCR_high_priority = T_ATM_ABSENT; // traffic->backward.SCR_all_traffic = T_ATM_ABSENT; // traffic->backward.MBS_high_priority = T_ATM_ABSENT; // traffic->backward.MBS_all_traffic = T_ATM_ABSENT; // traffic->backward.tagging = T_NO; // traffic->best_effort = qos_cells ? T_NO : T_YES; // popt = T_OPT_NEXTHDR (buf, // info.options, // popt); // } // if (qos_cells > 0 && qos_cells < LINE_RATE) // { // struct t_atm_qos *qos; // // T_ATM_QOS: Quality of Service // popt->len = sizeof (struct t_opthdr) + sizeof (struct t_atm_qos); // popt->level = T_ATM_SIGNALING; // popt->name = T_ATM_QOS; // popt->status = 0; // qos = (struct t_atm_qos *)((char *) popt + sizeof (struct t_opthdr)); // qos->coding_standard = T_ATM_ITU_CODING; // qos->forward.qos_class = T_ATM_QOS_CLASS_1; // qos->backward.qos_class = T_ATM_QOS_CLASS_1; // popt = T_OPT_NEXTHDR (buf, info.options, popt); // } // // return actual size of options and option buffer to user // *optsize = (char *) popt - buf; // return buf; // #elif defined (ACE_HAS_FORE_ATM_WS2) // // WinSock Part // // Unlike XTI, WinSock does QoS with a QoS class passed into // // connect call, so it may be better to do this in XXX_Connector // #else // ACE_UNUSED_ARG (fd); // ACE_UNUSED_ARG (qos_kb); // ACE_UNUSED_ARG (flags); // ACE_UNUSED_ARG (optsize); // return 0; // #endif /* ACE_HAS_FORE_ATM_XTI && ACE_HAS_FORE_ATM_WS2 */ // }