aboutsummaryrefslogtreecommitdiff
path: root/src/server.cpp
Commit message (Expand)AuthorAge
* Fixed/extended/modified ban stuff to be good for inclusionPerttu Ahola2011-08-12
* added ipban supportConstantin Wenger2011-08-12
* Notify other players of wielded item changeGiuseppe Bilotta2011-08-11
* Clients inform server on wielded itemGiuseppe Bilotta2011-08-11
* Server should use the same eye position as the clientGiuseppe Bilotta2011-08-11
* Fixes a bug that made the server to deny non-empty passwords from players con...Perttu Ahola2011-07-31
* Fixed problem of server always receiving an empty password from the clientPerttu Ahola2011-07-31
* Made stricter handling for old clients because now they are not compatible at...Perttu Ahola2011-07-31
* Fixed handling of inventory in creative mode (normal inventory is not trashed...Perttu Ahola2011-07-30
* fix to the formerPerttu Ahola2011-07-30
* easier notice on old versionPerttu Ahola2011-07-30
* Added network protocol version number in protocolPerttu Ahola2011-07-30
* Server configuration is now written when "/#setting whatever = whatever" is i...Perttu Ahola2011-07-30
* Added message of the day and made it properly configurable using /#setting (n...Perttu Ahola2011-07-30
* Made picking items up in creative mode delete them (because they usually are ...Perttu Ahola2011-07-30
* Rats are now eatable. Also made their selection box move smoothly.Perttu Ahola2011-07-30
* Added a mapblock analyzing function for debugging use and fixed remaining map...Perttu Ahola2011-07-24
* extended content-type rangePerttu Ahola2011-07-23
* Fixed objects being sometimes not able to be stored statically in a block whe...Perttu Ahola2011-07-01
* map unloading is now a whole lot betterPerttu Ahola2011-06-27
* fixed block unloading from memory (a better fix coming next)Perttu Ahola2011-06-26
* Added CPT_FACEDIR_SIMPLE calculation, finally, as figured out by spongiePerttu Ahola2011-06-26
* reorganized a lot of stuff and modified mapgen and objects slightly while doi...Perttu Ahola2011-06-26
* added and commented out some debug outputPerttu Ahola2011-06-26
* even more code refactoringPerttu Ahola2011-06-26
* moved map generator to separate source filesPerttu Ahola2011-06-25
* mapgen stuffPerttu Ahola2011-06-25
* New map generator added (and SQLite, messed up the commits at that time...) (...Perttu Ahola2011-06-25
* Changed MapBlockObjects to be never written anymore. Incremented version number.Perttu Ahola2011-06-18
* Created and moved stuff to content_nodemeta.{h,cpp}Perttu Ahola2011-06-18
* Moved some mapnode content stuff from mapnode.{h,cpp} and digging property st...Perttu Ahola2011-06-17
* made server to send map seed for testingPerttu Ahola2011-06-05
* removed a debug print that would flood a lot in some kind of a timeoutPerttu Ahola2011-06-02
* Fixed the password crash on WindowsPerttu Ahola2011-06-02
* Reduced server CPU usage on NodeMetadata step()s. Also furnace now cooks whil...Perttu Ahola2011-05-31
* Updated licenses of CiaranG's contributions to be in line with the new contri...celeron552011-05-31
* auth stuff is now saved only when modifiedPerttu Ahola2011-05-31
* removed some debug printsPerttu Ahola2011-05-31
* Reduced the CPU usage of the sent block selector algorithmPerttu Ahola2011-05-31
* hopefully fixed the privilege problemsPerttu Ahola2011-05-29
* player passwords and privileges in world/auth.txtPerttu Ahola2011-05-29
* Merged CiaranG's fence and fixed two thingsPerttu Ahola2011-05-24
|\
| * Added fences (but still needs an icon or something to display in inventory)Ciaran Gultnieks2011-05-24
| * Added 'shout' player privilegeCiaran Gultnieks2011-05-23
| * Allow default privileges for new players to be set in the server configCiaran Gultnieks2011-05-22
|/
* Added the ability to change your password (via pause menu)Ciaran Gultnieks2011-05-22
* Preliminary "active block" stuff + set up test code to grow grass.Perttu Ahola2011-05-22
* Passwords - a few corrections to the previous commitCiaran Gultnieks2011-05-20
* Passwords - password entry at main menu, stored and checked by serverCiaran Gultnieks2011-05-20
* Restored the auto-admin powers of the local user (via name= in the config)Ciaran Gultnieks2011-05-16
generated by cgit v1.2.3 (git 2.39.1) at 2025-01-17 02:20:32 +0000
n> #endif #include "constants.h" #include "debug.h" #include <stdio.h> #include <iostream> #include <stdlib.h> #include <errno.h> #include "util/string.h" #include "util/numeric.h" bool socket_enable_debug_output = false; #define DP socket_enable_debug_output // This is prepended to everything printed here #define DPS "" bool g_sockets_initialized = false; void sockets_init() { #ifdef _WIN32 WSADATA WsaData; if(WSAStartup( MAKEWORD(2,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(" "); unsigned int a = ((const unsigned char*)data)[i]; DEBUGPRINT("%.2X", a); } 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; socklen_t address_len = sizeof(address); int received = recvfrom(m_handle, (char*)data, size, 0, (sockaddr*)&address, &address_len); if(received < 0) return -1; unsigned int address_ip = ntohl(address.sin_addr.s_addr); unsigned int address_port = ntohs(address.sin_port); sender = Address(address_ip, address_port); if(DP){ //dstream<<DPS<<"UDPSocket("<<(int)m_handle<<")::Receive(): sender="; dstream<<DPS<<(int)m_handle<<" <- "; sender.print(); //dstream<<", received="<<received<<std::endl; dstream<<", size="<<received<<", data="; for(int i=0; i<received && i<20; i++){ if(i%2==0) DEBUGPRINT(" "); unsigned int a = ((const unsigned char*)data)[i]; DEBUGPRINT("%.2X", a); } if(received>20) dstream<<"..."; dstream<<std::endl; } return received; } int UDPSocket::GetHandle() { return m_handle; } void UDPSocket::setTimeoutMs(int timeout_ms) { m_timeout_ms = timeout_ms; } bool UDPSocket::WaitData(int timeout_ms) { fd_set readset; int result; // Initialize the set FD_ZERO(&readset); FD_SET(m_handle, &readset); // Initialize time out struct struct timeval tv; tv.tv_sec = 0; tv.tv_usec = timeout_ms * 1000; // select() result = select(m_handle+1, &readset, NULL, NULL, &tv); if(result == 0){ // Timeout /*dstream<<"Select timed out (timeout_ms=" <<timeout_ms<<")"<<std::endl;*/ return false; } else if(result < 0 && errno == EINTR){ return false; } else if(result < 0){ // Error #ifndef DISABLE_ERRNO dstream<<(int)m_handle<<": Select failed: "<<strerror(errno)<<std::endl; #endif #ifdef _WIN32 int e = WSAGetLastError(); dstream<<(int)m_handle<<": WSAGetLastError()="<<e<<std::endl; if(e == 10004 /*=WSAEINTR*/) { dstream<<"WARNING: Ignoring WSAEINTR."<<std::endl; return false; } #endif throw SocketException("Select failed"); } else if(FD_ISSET(m_handle, &readset) == false){ // No data //dstream<<"Select reported no data in m_handle"<<std::endl; return false; } // There is data //dstream<<"Select reported data in m_handle"<<std::endl; return true; }
generated by cgit v1.2.3 (git 2.39.1) at 2025-01-17 02:20:31 +0000