aboutsummaryrefslogtreecommitdiff
path: root/src/script/cpp_api
ModeNameSize
-rw-r--r--CMakeLists.txt639logplain
-rw-r--r--s_async.cpp7789logplain
-rw-r--r--s_async.h4193logplain
-rw-r--r--s_base.cpp9040logplain
-rw-r--r--s_base.h3644logplain
-rw-r--r--s_client.cpp5084logplain
-rw-r--r--s_client.h1678logplain
-rw-r--r--s_entity.cpp7992logplain
-rw-r--r--s_entity.h1554logplain
-rw-r--r--s_env.cpp7320logplain
-rw-r--r--s_env.h1505logplain
-rw-r--r--s_internal.h2878logplain
-rw-r--r--s_inventory.cpp7745logplain
-rw-r--r--s_inventory.h2342logplain
-rw-r--r--s_item.cpp7582logplain
-rw-r--r--s_item.h1952logplain
-rw-r--r--s_mainmenu.cpp2665logplain
-rw-r--r--s_mainmenu.h1454logplain
-rw-r--r--s_node.cpp7340logplain
-rw-r--r--s_node.h1955logplain
-rw-r--r--s_nodemeta.cpp8155logplain
-rw-r--r--s_nodemeta.h2220logplain
-rw-r--r--s_player.cpp5481logplain
-rw-r--r--s_player.h1830logplain
-rw-r--r--s_security.cpp17683logplain
-rw-r--r--s_security.h2599logplain
-rw-r--r--s_server.cpp4532logplain
-rw-r--r--s_server.h1559logplain
="hl num">2), &WsaData ) != NO_ERROR) throw SocketException("WSAStartup failed"); #else #endif g_sockets_initialized = true; } void sockets_cleanup() { #ifdef _WIN32 WSACleanup(); #endif } Address::Address() { m_address = 0; m_port = 0; } Address::Address(unsigned int address, unsigned short port) { m_address = address; m_port = port; } Address::Address(unsigned int a, unsigned int b, unsigned int c, unsigned int d, unsigned short port) { m_address = (a<<24) | (b<<16) | ( c<<8) | d; m_port = port; } bool Address::operator==(Address &address) { return (m_address == address.m_address && m_port == address.m_port); } bool Address::operator!=(Address &address) { return !(*this == address); } void Address::Resolve(const char *name) { struct addrinfo *resolved; int e = getaddrinfo(name, NULL, NULL, &resolved); if(e != 0) throw ResolveError(""); /* FIXME: This is an ugly hack; change the whole class to store the address as sockaddr */ struct sockaddr_in *t = (struct sockaddr_in*)resolved->ai_addr; m_address = ntohl(t->sin_addr.s_addr); freeaddrinfo(resolved); } std::string Address::serializeString() const { unsigned int a, b, c, d; a = (m_address & 0xFF000000)>>24; b = (m_address & 0x00FF0000)>>16; c = (m_address & 0x0000FF00)>>8; d = (m_address & 0x000000FF); return itos(a)+"."+itos(b)+"."+itos(c)+"."+itos(d); } unsigned int Address::getAddress() const { return m_address; } unsigned short Address::getPort() const { return m_port; } void Address::setAddress(unsigned int address) { m_address = address; } void Address::setAddress(unsigned int a, unsigned int b, unsigned int c, unsigned int d) { m_address = (a<<24) | (b<<16) | ( c<<8) | d; } void Address::setPort(unsigned short port) { m_port = port; } void Address::print(std::ostream *s) const { (*s)<<((m_address>>24)&0xff)<<"." <<((m_address>>16)&0xff)<<"." <<((m_address>>8)&0xff)<<"." <<((m_address>>0)&0xff)<<":" <<m_port; } void Address::print() const { print(&dstream); } UDPSocket::UDPSocket() { if(g_sockets_initialized == false) throw SocketException("Sockets not initialized"); m_handle = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP); if(DP) dstream<<DPS<<"UDPSocket("<<(int)m_handle<<")::UDPSocket()"<<std::endl; if(m_handle <= 0) { throw SocketException("Failed to create socket"); } /*#ifdef _WIN32 DWORD nonblocking = 0; if(ioctlsocket(m_handle, FIONBIO, &nonblocking) != 0) { throw SocketException("Failed set non-blocking mode"); } #else int nonblocking = 0; if(fcntl(m_handle, F_SETFL, O_NONBLOCK, nonblocking) == -1) { throw SocketException("Failed set non-blocking mode"); } #endif*/ setTimeoutMs(0); } UDPSocket::~UDPSocket() { if(DP) dstream<<DPS<<"UDPSocket("<<(int)m_handle<<")::~UDPSocket()"<<std::endl; #ifdef _WIN32 closesocket(m_handle); #else close(m_handle); #endif } void UDPSocket::Bind(unsigned short port) { if(DP) dstream<<DPS<<"UDPSocket("<<(int)m_handle <<")::Bind(): port="<<port<<std::endl; sockaddr_in address; address.sin_family = AF_INET; address.sin_addr.s_addr = INADDR_ANY; address.sin_port = htons(port); if(bind(m_handle, (const sockaddr*)&address, sizeof(sockaddr_in)) < 0) { #ifndef DISABLE_ERRNO dstream<<(int)m_handle<<": Bind failed: "<<strerror(errno)<<std::endl; #endif throw SocketException("Failed to bind socket"); } } void UDPSocket::Send(const Address & destination, const void * data, int size) { bool dumping_packet = false; if(INTERNET_SIMULATOR) dumping_packet = (myrand()%10==0); //easy //dumping_packet = (myrand()%4==0); // hard if(DP){ /*dstream<<DPS<<"UDPSocket("<<(int)m_handle <<")::Send(): destination=";*/ dstream<<DPS; dstream<<(int)m_handle<<" -> "; destination.print(); dstream<<", size="<<size<<", data="; for(int i=0; i<size && i<20; i++){ if(i%2==0) DEBUGPRINT(" "); DEBUGPRINT("%.2X", ((int)((const char*)data)[i])&0xff); } if(size>20) dstream<<"..."; if(dumping_packet) dstream<<" (DUMPED BY INTERNET_SIMULATOR)"; dstream<<std::endl; } else if(dumping_packet) { // Lol let's forget it dstream<<"UDPSocket::Send(): " "INTERNET_SIMULATOR: dumping packet." <<std::endl; } if(dumping_packet) return; sockaddr_in address; address.sin_family = AF_INET; address.sin_addr.s_addr = htonl(destination.getAddress()); address.sin_port = htons(destination.getPort()); int sent = sendto(m_handle, (const char*)data, size, 0, (sockaddr*)&address, sizeof(sockaddr_in)); if(sent != size) { throw SendFailedException("Failed to send packet"); } } int UDPSocket::Receive(Address & sender, void * data, int size) { if(WaitData(m_timeout_ms) == false) { return -1; } sockaddr_in address;