1

/* $Id$ */

     2

     3

/** @file cargopacket.cpp Implementation of the cargo packets */

     4

     5

#include "stdafx.h"

     6

#include "openttd.h"

     7

#include "station_base.h"

     8

#include "cargopacket.h"

     9

#include "saveload.h"

    10

#include "oldpool_func.h"

    11

    12

/* Initialize the cargopacket-pool */

    13

DEFINE_OLD_POOL_GENERIC(CargoPacket, CargoPacket)

    14

    15

void InitializeCargoPackets()

    16

{

    17

	/* Clean the cargo packet pool and create 1 block in it */

    18

	_CargoPacket_pool.CleanPool();

    19

	_CargoPacket_pool.AddBlockToPool();

    20

}

    21

    22

CargoPacket::CargoPacket(StationID source, uint16 count)

    23

{

    24

	if (source != INVALID_STATION) assert(count != 0);

    25

    26

	this->source          = source;

    27

	this->source_xy       = (source != INVALID_STATION) ? GetStation(source)->xy : 0;

    28

	this->loaded_at_xy    = this->source_xy;

    29

    30

	this->count           = count;

    31

	this->days_in_transit = 0;

    32

	this->feeder_share    = 0;

    33

	this->paid_for        = false;

    34

}

    35

    36

CargoPacket::~CargoPacket()

    37

{

    38

	this->count = 0;

    39

}

    40

    41

bool CargoPacket::SameSource(const CargoPacket *cp) const

    42

{

    43

	return this->source_xy == cp->source_xy && this->days_in_transit == cp->days_in_transit && this->paid_for == cp->paid_for;

    44

}

    45

    46

static const SaveLoad _cargopacket_desc[] = {

    47

	SLE_VAR(CargoPacket, source,          SLE_UINT16),

    48

	SLE_VAR(CargoPacket, source_xy,       SLE_UINT32),

    49

	SLE_VAR(CargoPacket, loaded_at_xy,    SLE_UINT32),

    50

	SLE_VAR(CargoPacket, count,           SLE_UINT16),

    51

	SLE_VAR(CargoPacket, days_in_transit, SLE_UINT8),

    52

	SLE_VAR(CargoPacket, feeder_share,    SLE_INT64),

    53

	SLE_VAR(CargoPacket, paid_for,        SLE_BOOL),

    54

    55

	SLE_END()

    56

};

    57

    58

static void Save_CAPA()

    59

{

    60

	CargoPacket *cp;

    61

    62

	FOR_ALL_CARGOPACKETS(cp) {

    63

		SlSetArrayIndex(cp->index);

    64

		SlObject(cp, _cargopacket_desc);

    65

	}

    66

}

    67

    68

static void Load_CAPA()

    69

{

    70

	int index;

    71

    72

	while ((index = SlIterateArray()) != -1) {

    73

		CargoPacket *cp = new (index) CargoPacket();

    74

		SlObject(cp, _cargopacket_desc);

    75

	}

    76

}

    77

    78

extern const ChunkHandler _cargopacket_chunk_handlers[] = {

    79

	{ 'CAPA', Save_CAPA, Load_CAPA, CH_ARRAY | CH_LAST},

    80

};

    81

    82

/*

    83

 *

    84

 * Cargo list implementation

    85

 *

    86

 */

    87

    88

CargoList::~CargoList()

    89

{

    90

	while (!packets.empty()) {

    91

		delete packets.front();

    92

		packets.pop_front();

    93

	}

    94

}

    95

    96

const CargoList::List *CargoList::Packets() const

    97

{

    98

	return &packets;

    99

}

   100

   101

void CargoList::AgeCargo()

   102

{

   103

	if (empty) return;

   104

   105

	uint dit = 0;

   106

	for (List::const_iterator it = packets.begin(); it != packets.end(); it++) {

   107

		if ((*it)->days_in_transit != 0xFF) (*it)->days_in_transit++;

   108

		dit += (*it)->days_in_transit * (*it)->count;

   109

	}

   110

	days_in_transit = dit / count;

   111

}

   112

   113

bool CargoList::Empty() const

   114

{

   115

	return empty;

   116

}

   117

   118

uint CargoList::Count() const

   119

{

   120

	return count;

   121

}

   122

   123

bool CargoList::UnpaidCargo() const

   124

{

   125

	return unpaid_cargo;

   126

}

   127

   128

Money CargoList::FeederShare() const

   129

{

   130

	return feeder_share;

   131

}

   132

   133

StationID CargoList::Source() const

   134

{

   135

	return source;

   136

}

   137

   138

uint CargoList::DaysInTransit() const

   139

{

   140

	return days_in_transit;

   141

}

   142

   143

void CargoList::Append(CargoPacket *cp)

   144

{

   145

	assert(cp != NULL);

   146

	assert(cp->IsValid());

   147

   148

	for (List::iterator it = packets.begin(); it != packets.end(); it++) {

   149

		if ((*it)->SameSource(cp) && (*it)->count + cp->count <= 65535) {

   150

			(*it)->count        += cp->count;

   151

			(*it)->feeder_share += cp->feeder_share;

   152

			delete cp;

   153

   154

			InvalidateCache();

   155

			return;

   156

		}

   157

	}

   158

   159

	/* The packet could not be merged with another one */

   160

	packets.push_back(cp);

   161

	InvalidateCache();

   162

}

   163

   164

   165

void CargoList::Truncate(uint count)

   166

{

   167

	for (List::iterator it = packets.begin(); it != packets.end(); it++) {

   168

		uint local_count = (*it)->count;

   169

		if (local_count <= count) {

   170

			count -= local_count;

   171

			continue;

   172

		}

   173

   174

		(*it)->count = count;

   175

		count = 0;

   176

	}

   177

   178

	while (!packets.empty()) {

   179

		CargoPacket *cp = packets.back();

   180

		if (cp->count != 0) break;

   181

		delete cp;

   182

		packets.pop_back();

   183

	}

   184

   185

	InvalidateCache();

   186

}

   187

   188

bool CargoList::MoveTo(CargoList *dest, uint count, CargoList::MoveToAction mta, uint data)

   189

{

   190

	assert(mta == MTA_FINAL_DELIVERY || dest != NULL);

   191

	CargoList tmp;

   192

   193

	while (!packets.empty() && count > 0) {

   194

		CargoPacket *cp = *packets.begin();

   195

		if (cp->count <= count) {

   196

			/* Can move the complete packet */

   197

			packets.remove(cp);

   198

			switch (mta) {

   199

				case MTA_FINAL_DELIVERY:

   200

					if (cp->source == data) {

   201

						tmp.Append(cp);

   202

					} else {

   203

						count -= cp->count;

   204

						delete cp;

   205

					}

   206

					break;

   207

				case MTA_CARGO_LOAD:

   208

					cp->loaded_at_xy = data;

   209

					/* When cargo is moved into another vehicle you have *always* paid for it */

   210

					cp->paid_for     = false;

   211

					/* FALL THROUGH */

   212

				case MTA_OTHER:

   213

					count -= cp->count;

   214

					dest->packets.push_back(cp);

   215

					break;

   216

			}

   217

		} else {

   218

			/* Can move only part of the packet, so split it into two pieces */

   219

			if (mta != MTA_FINAL_DELIVERY) {

   220

				CargoPacket *cp_new = new CargoPacket();

   221

   222

				Money fs = cp->feeder_share * count / static_cast<uint>(cp->count);

   223

				cp->feeder_share -= fs;

   224

   225

				cp_new->source          = cp->source;

   226

				cp_new->source_xy       = cp->source_xy;

   227

				cp_new->loaded_at_xy    = (mta == MTA_CARGO_LOAD) ? data : cp->loaded_at_xy;

   228

   229

				cp_new->days_in_transit = cp->days_in_transit;

   230

				cp_new->feeder_share    = fs;

   231

				/* When cargo is moved into another vehicle you have *always* paid for it */

   232

				cp_new->paid_for        = (mta == MTA_CARGO_LOAD) ? false : cp->paid_for;

   233

   234

				cp_new->count = count;

   235

				dest->packets.push_back(cp_new);

   236

			}

   237

			cp->count -= count;

   238

   239

			count = 0;

   240

		}

   241

	}

   242

   243

	bool remaining = !packets.empty();

   244

   245

	if (mta == MTA_FINAL_DELIVERY && !tmp.Empty()) {

   246

		/* There are some packets that could not be delivered at the station, put them back */

   247

		tmp.MoveTo(this, UINT_MAX);

   248

		tmp.packets.clear();

   249

	}

   250

   251

	if (dest != NULL) dest->InvalidateCache();

   252

	InvalidateCache();

   253

   254

	return remaining;

   255

}

   256

   257

void CargoList::InvalidateCache()

   258

{

   259

	empty = packets.empty();

   260

	count = 0;

   261

	unpaid_cargo = false;

   262

	feeder_share = 0;

   263

	source = INVALID_STATION;

   264

	days_in_transit = 0;

   265

   266

	if (empty) return;

   267

   268

	uint dit = 0;

   269

	for (List::const_iterator it = packets.begin(); it != packets.end(); it++) {

   270

		count        += (*it)->count;

   271

		unpaid_cargo |= !(*it)->paid_for;

   272

		dit          += (*it)->days_in_transit * (*it)->count;

   273

		feeder_share += (*it)->feeder_share;

   274

	}

   275

	days_in_transit = dit / count;

   276

	source = (*packets.begin())->source;

   277

}

   278