aboutsummaryrefslogtreecommitdiff
path: root/advtrains
Commit message (Collapse)AuthorAge
...
* | Remove zip release files, move mod to root, exclude assets from Makefile (#92)rubenwardy2017-09-20
| |
* | Merge PR from mbb - Improve models and texturesMBB2017-08-24
| |
* | Added command to reroute trainsGabriel Pérez-Cerezo2017-08-15
| |
* | Fixed #86Gabriel Pérez-Cerezo2017-08-15
|/
* Add command to throw all players out of trains, fixes #78orwell962017-06-12
|
* Fix broken door animations caused by continuous set_object_properties() ↵orwell962017-06-08
| | | | | | messages sent to client ... which each time caused the animation to be reset
* lower capacity of freight carsorwell962017-06-08
|
* Change log level of save_all message to atprint()orwell962017-06-08
|
* Do not clear the F table when running the init code failsorwell962017-06-08
|
* Merge pull request #67 from AntumDeluge/settingsorwell962017-06-08
|\ | | | | Replace deprecated methods
| * Replace deprecated methods:AntumDeluge2017-06-07
| | | | | | | | - 'setting_get' with 'settings:get' - 'setting_getbool' with 'settings:get_bool'
* | Check if 'digtron' global exists before calling in condition:AntumDeluge2017-06-07
|/ | | Fixes 'Undeclared global variable "digtron"'.
* Add loading/unloading rails (#63)gpcf2017-05-31
| | | | Pull request by gpcf Will update zip file with next release
* Fix still broken ndb restoring, and make sid() honor nil valuesorwell962017-05-31
|
* Fix detector rails changing to default orientationorwell962017-05-30
| | | | Release 1.8.1
* Re-add option for debugging features and add option to disable collisionsorwell962017-05-30
|
* Fix collision bug (trains driving through each other)orwell962017-05-30
|
* Re-add debug ring buffer and print its contents on a lua crashorwell962017-05-30
| | | | | When the crash on linuxworks has been fixed, the ringbuffer will go into master and behind an option also fix last commit
* Fix command + Update zip file - Version 1.8orwell962017-05-22
|
* Add Digtron compatibilityorwell962017-05-22
| | | | Override digtron's item-place function to be able to place tracks with digtrons.
* Fix some 'undeclared assignment' warningsorwell962017-05-22
|
* Fix Syntax Errororwell962017-05-22
|
* Fix issue #40orwell962017-05-22
| | | | Was caused by arrowconn not being set. Instructs user to revisit.
* Remove the debug settingorwell962017-05-22
|
* Fix a series of bugsorwell962017-05-22
| | | | | | | | - Prevent min_iot from becoming a comma value, which caused a major problem on the linuxworks server - Fix previous commit - also restore the nodedb file after a crash Other changes: - add chatcommand to update the nodedb after using WorldEdit
* Don't invoke conway on a path item that has been over-generatedorwell962017-05-15
| | | | This breaks ATC systems that are based on wronly switched switches, but fixes a series of bugs (esp. setting train recovery positions at a place where no tracks are)
* write the saved nodedb state back to the map when restoring after a crashorwell962017-05-12
| | | | | also, print a complete stack trace when an error happens also, don't replace nodes in the nodedb when worldedit has been used
* Remove pos_to_string whereever possible to prevent crashesorwell962017-05-12
|
* Relicensing media under CC-BY-SAorwell962017-05-04
|
* Performance improvements: Don't clear paths unless absolutely necessaryorwell962017-05-03
| | | | | instead delete path elements that are too far from the train one-by-one Also when switching a switch or changing rails, only clear train paths of trains that are nearby.
* Merge nocrash branch into master and merging it with the unified functions ↵orwell962017-04-29
|\ | | | | | | | | | | so that restoring works how it should Also fix minor bugs and an occasional crash with couples
| * Add pcall wrapper to prevent server crashes when advtrains throws an errororwell962017-04-29
| | | | | | | | | | Instead, read save files again and restore state before the crash Rebased to latest commit
* | Unify globalstep, load and save of all components into single functionsorwell962017-04-29
|/
* Add Andrew's Crossorwell962017-04-27
|
* Fix bug introduced by last commit (revert change)orwell962017-04-12
|
* Add privilege for basic train operation.orwell962017-04-09
| | | | This privilege is granted to singleplayer by default, but is not granted on servers. This prevents unexperienced or evil players from breaking automatic train operation on servers.
* record_protection_violation: fix player name not being passedorwell962017-04-07
|
* Fix #59orwell962017-04-05
|
* Actually check for protection when placing trains and use the train_place ↵orwell962017-04-02
| | | | privilege
* Assert some variable types obtained from lua automationorwell962017-03-30
|
* Add support to display text to passengers and on the outside of the trainorwell962017-03-30
| | | | | Outside is currently displayed as infotext. TODO: signs-like draw it on the wagon FIXME: When object properties are set, for some reason the animation restarts
* Respect protection_bypass privilege, fix crash with areas and properly ↵orwell962017-03-30
| | | | record protection violations
* Fix privilege enforcement being uselessorwell962017-03-16
| | | | Privilege violations caused an error message but didn't abort the operation
* Fix Atc arrows pointing into wrong directionorwell962017-03-12
|
* Screw buttonlike rules for wall signals and use regular rules.orwell962017-03-12
|
* Redo rail modelsorwell962017-03-12
| | | | Use multiple textures for slope objects, include mbb's rail textures and make curves and switches look better. Also add cable template.
* Don't drop items in creative mode when player gets overrun by trainorwell962017-03-11
|
* "Sneak" instead of "Shift" for the sneak keyorwell962017-03-09
|
* Update manual and include everything in repoorwell962017-03-09
|
* Improve debug outputs of couples and increase maximum distanceorwell962017-03-03
|
generated by cgit v1.2.3 (git 2.39.1) at 2025-02-09 03:07:01 +0000
='#n849'>849 850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917 918 919 920 921 922 923 924 925 926 927 928 929 930 931 932 933 934 935 936 937 938 939 940 941 942 943 944 945 946 947 948 949 950 951 952 953 954 955 956 957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 991 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032 1033 1034 1035 1036 1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052 1053 1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081 1082 1083 1084 1085 1086 1087 1088 1089 1090 1091 1092 1093 1094 1095 1096 1097 1098 
/*
Minetest
Copyright (C) 2013 celeron55, Perttu Ahola <celeron55@gmail.com>

This program is free software; you can redistribute it and/or modify
it under the terms of the GNU Lesser General Public License as published by
the Free Software Foundation; either version 2.1 of the License, or
(at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU Lesser General Public License for more details.

You should have received a copy of the GNU Lesser General Public License along
with this program; if not, write to the Free Software Foundation, Inc.,
51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
*/

#ifndef CONNECTION_HEADER
#define CONNECTION_HEADER

#include "irrlichttypes_bloated.h"
#include "socket.h"
#include "exceptions.h"
#include "constants.h"
#include "util/pointer.h"
#include "util/container.h"
#include "util/thread.h"
#include "util/numeric.h"
#include <iostream>
#include <fstream>
#include <list>
#include <map>

namespace con
{

/*
	Exceptions
*/
class NotFoundException : public BaseException
{
public:
	NotFoundException(const char *s):
		BaseException(s)
	{}
};

class PeerNotFoundException : public BaseException
{
public:
	PeerNotFoundException(const char *s):
		BaseException(s)
	{}
};

class ConnectionException : public BaseException
{
public:
	ConnectionException(const char *s):
		BaseException(s)
	{}
};

class ConnectionBindFailed : public BaseException
{
public:
	ConnectionBindFailed(const char *s):
		BaseException(s)
	{}
};

class InvalidIncomingDataException : public BaseException
{
public:
	InvalidIncomingDataException(const char *s):
		BaseException(s)
	{}
};

class InvalidOutgoingDataException : public BaseException
{
public:
	InvalidOutgoingDataException(const char *s):
		BaseException(s)
	{}
};

class NoIncomingDataException : public BaseException
{
public:
	NoIncomingDataException(const char *s):
		BaseException(s)
	{}
};

class ProcessedSilentlyException : public BaseException
{
public:
	ProcessedSilentlyException(const char *s):
		BaseException(s)
	{}
};

class ProcessedQueued : public BaseException
{
public:
	ProcessedQueued(const char *s):
		BaseException(s)
	{}
};

class IncomingDataCorruption : public BaseException
{
public:
	IncomingDataCorruption(const char *s):
		BaseException(s)
	{}
};

typedef enum MTProtocols {
	MTP_PRIMARY,
	MTP_UDP,
	MTP_MINETEST_RELIABLE_UDP
} MTProtocols;

#define SEQNUM_MAX 65535
inline bool seqnum_higher(u16 totest, u16 base)
{
	if (totest > base)
	{
		if((totest - base) > (SEQNUM_MAX/2))
			return false;
		else
			return true;
	}
	else
	{
		if((base - totest) > (SEQNUM_MAX/2))
			return true;
		else
			return false;
	}
}

inline bool seqnum_in_window(u16 seqnum, u16 next,u16 window_size)
{
	u16 window_start = next;
	u16 window_end   = ( next + window_size ) % (SEQNUM_MAX+1);

	if (window_start < window_end)
	{
		return ((seqnum >= window_start) && (seqnum < window_end));
	}
	else
	{
		return ((seqnum < window_end) || (seqnum >= window_start));
	}
}

struct BufferedPacket
{
	BufferedPacket(u8 *a_data, u32 a_size):
		data(a_data, a_size), time(0.0), totaltime(0.0), absolute_send_time(-1),
		resend_count(0)
	{}
	BufferedPacket(u32 a_size):
		data(a_size), time(0.0), totaltime(0.0), absolute_send_time(-1),
		resend_count(0)
	{}
	SharedBuffer<u8> data; // Data of the packet, including headers
	float time; // Seconds from buffering the packet or re-sending
	float totaltime; // Seconds from buffering the packet
	unsigned int absolute_send_time;
	Address address; // Sender or destination
	unsigned int resend_count;
};

// This adds the base headers to the data and makes a packet out of it
BufferedPacket makePacket(Address &address, u8 *data, u32 datasize,
		u32 protocol_id, u16 sender_peer_id, u8 channel);
BufferedPacket makePacket(Address &address, SharedBuffer<u8> &data,
		u32 protocol_id, u16 sender_peer_id, u8 channel);