mirror of
https://github.com/MariaDB/server.git
synced 2025-01-19 21:42:35 +01:00
153 lines
3.7 KiB
C++
153 lines
3.7 KiB
C++
/* Copyright (C) 2003 MySQL AB
|
|
|
|
This program is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation; either version 2 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 General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, write to the Free Software
|
|
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
|
|
|
|
#ifndef TransporterDefinitions_H
|
|
#define TransporterDefinitions_H
|
|
|
|
#include <ndb_global.h>
|
|
#include <kernel_types.h>
|
|
#include <NdbOut.hpp>
|
|
|
|
/**
|
|
* The maximum number of transporters allowed
|
|
* A maximum is needed to be able to allocate the array of transporters
|
|
*/
|
|
const int MAX_NTRANSPORTERS = 128;
|
|
|
|
/**
|
|
* The sendbuffer limit after which the contents of the buffer is sent
|
|
*/
|
|
const int TCP_SEND_LIMIT = 64000;
|
|
|
|
enum SendStatus {
|
|
SEND_OK = 0,
|
|
SEND_BLOCKED = 1,
|
|
SEND_DISCONNECTED = 2,
|
|
SEND_BUFFER_FULL = 3,
|
|
SEND_MESSAGE_TOO_BIG = 4,
|
|
SEND_UNKNOWN_NODE = 5
|
|
};
|
|
|
|
/**
|
|
* Protocol6 Header +
|
|
* (optional signal id) + (optional checksum) + (signal data)
|
|
*/
|
|
//const Uint32 MAX_MESSAGE_SIZE = (12+4+4+(4*25));
|
|
const Uint32 MAX_MESSAGE_SIZE = (12+4+4+(4*25)+(3*4)+4*4096);
|
|
|
|
/**
|
|
* TCP Transporter Configuration
|
|
*/
|
|
struct TCP_TransporterConfiguration {
|
|
Uint32 port;
|
|
const char *remoteHostName;
|
|
const char *localHostName;
|
|
NodeId remoteNodeId;
|
|
NodeId localNodeId;
|
|
Uint32 sendBufferSize; // Size of SendBuffer of priority B
|
|
Uint32 maxReceiveSize; // Maximum no of bytes to receive
|
|
Uint32 byteOrder;
|
|
bool compression;
|
|
bool checksum;
|
|
bool signalId;
|
|
};
|
|
|
|
/**
|
|
* SHM Transporter Configuration
|
|
*/
|
|
struct SHM_TransporterConfiguration {
|
|
Uint32 port;
|
|
NodeId remoteNodeId;
|
|
NodeId localNodeId;
|
|
bool compression;
|
|
bool checksum;
|
|
bool signalId;
|
|
int byteOrder;
|
|
|
|
Uint32 shmKey;
|
|
Uint32 shmSize;
|
|
};
|
|
|
|
/**
|
|
* OSE Transporter Configuration
|
|
*/
|
|
struct OSE_TransporterConfiguration {
|
|
const char *remoteHostName;
|
|
const char *localHostName;
|
|
NodeId remoteNodeId;
|
|
NodeId localNodeId;
|
|
bool compression;
|
|
bool checksum;
|
|
bool signalId;
|
|
int byteOrder;
|
|
|
|
Uint32 prioASignalSize;
|
|
Uint32 prioBSignalSize;
|
|
Uint32 receiveBufferSize; // In number of signals
|
|
};
|
|
|
|
/**
|
|
* SCI Transporter Configuration
|
|
*/
|
|
struct SCI_TransporterConfiguration {
|
|
Uint32 sendLimit; // Packet size
|
|
Uint32 bufferSize; // Buffer size
|
|
|
|
Uint32 nLocalAdapters; // 1 or 2, the number of adapters on local host
|
|
|
|
Uint32 nRemoteAdapters;
|
|
Uint32 remoteSciNodeId0; // SCInodeId for adapter 1
|
|
Uint32 remoteSciNodeId1; // SCInodeId for adapter 2
|
|
|
|
NodeId localNodeId; // Local node Id
|
|
NodeId remoteNodeId; // Remote node Id
|
|
|
|
Uint32 byteOrder;
|
|
bool compression;
|
|
bool checksum;
|
|
bool signalId;
|
|
|
|
};
|
|
|
|
struct SignalHeader {
|
|
Uint32 theVerId_signalNumber; // 4 bit ver id - 16 bit gsn
|
|
Uint32 theReceiversBlockNumber; // Only 16 bit blocknum
|
|
Uint32 theSendersBlockRef;
|
|
Uint32 theLength;
|
|
Uint32 theSendersSignalId;
|
|
Uint32 theSignalId;
|
|
Uint16 theTrace;
|
|
Uint8 m_noOfSections;
|
|
Uint8 m_fragmentInfo;
|
|
}; /** 7x4 = 28 Bytes */
|
|
|
|
struct LinearSectionPtr {
|
|
Uint32 sz;
|
|
Uint32 * p;
|
|
};
|
|
|
|
struct SegmentedSectionPtr {
|
|
Uint32 sz;
|
|
Uint32 i;
|
|
struct SectionSegment * p;
|
|
|
|
void setNull() { p = 0;}
|
|
bool isNull() const { return p == 0;}
|
|
};
|
|
|
|
class NdbOut & operator <<(class NdbOut & out, SignalHeader & sh);
|
|
|
|
#endif // Define of TransporterDefinitions_H
|