Skip to content

C#: create the sender and receiver models on first use #114

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
jccarvalhosa wants to merge 1 commit into
base: main
Choose a base branch
from
+154 −290
Open

C#: create the sender and receiver models on first use #114

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions include/generator_csharp.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -89,6 +89,7 @@ class GeneratorCSharp : public Generator
bool IsKnownType(const std::string& type);
bool IsReferenceType(const std::string& type);

std::string ConvertToLower(const std::string& type);
std::string ConvertEnumRead(const std::string& type);
std::string ConvertEnumSize(const std::string& type);
std::string ConvertEnumType(const std::string& type);
Expand Down
159 changes: 54 additions & 105 deletions projects/CSharp/Proto/com.chronoxor.proto.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4709,21 +4709,18 @@ public interface ISenderListener : com.chronoxor.FBE.ISenderListener
public class Sender : com.chronoxor.FBE.Sender, ISenderListener
{
// Sender models accessors
public readonly OrderMessageModel OrderMessageModel;
public readonly BalanceMessageModel BalanceMessageModel;
public readonly AccountMessageModel AccountMessageModel;
private OrderMessageModel _orderMessageModel;
public OrderMessageModel OrderMessageModel => _orderMessageModel ?? (_orderMessageModel = new OrderMessageModel(Buffer));
private BalanceMessageModel _balanceMessageModel;
public BalanceMessageModel BalanceMessageModel => _balanceMessageModel ?? (_balanceMessageModel = new BalanceMessageModel(Buffer));
private AccountMessageModel _accountMessageModel;
public AccountMessageModel AccountMessageModel => _accountMessageModel ?? (_accountMessageModel = new AccountMessageModel(Buffer));

public Sender() : base(false)
{
OrderMessageModel = new OrderMessageModel(Buffer);
BalanceMessageModel = new BalanceMessageModel(Buffer);
AccountMessageModel = new AccountMessageModel(Buffer);
}
public Sender(com.chronoxor.FBE.Buffer buffer) : base(buffer, false)
{
OrderMessageModel = new OrderMessageModel(Buffer);
BalanceMessageModel = new BalanceMessageModel(Buffer);
AccountMessageModel = new AccountMessageModel(Buffer);
}

public long Send(object obj) { return SendListener(this, obj); }
Expand Down Expand Up @@ -4818,27 +4815,18 @@ public class Receiver : com.chronoxor.FBE.Receiver, IReceiverListener
private global::com.chronoxor.proto.AccountMessage AccountMessageValue;

// Receiver models accessors
private readonly OrderMessageModel OrderMessageModel;
private readonly BalanceMessageModel BalanceMessageModel;
private readonly AccountMessageModel AccountMessageModel;
private OrderMessageModel _orderMessageModel;
private OrderMessageModel OrderMessageModel => _orderMessageModel ?? (_orderMessageModel = new OrderMessageModel());
private BalanceMessageModel _balanceMessageModel;
private BalanceMessageModel BalanceMessageModel => _balanceMessageModel ?? (_balanceMessageModel = new BalanceMessageModel());
private AccountMessageModel _accountMessageModel;
private AccountMessageModel AccountMessageModel => _accountMessageModel ?? (_accountMessageModel = new AccountMessageModel());

public Receiver() : base(false)
{
OrderMessageValue = global::com.chronoxor.proto.OrderMessage.Default;
OrderMessageModel = new OrderMessageModel();
BalanceMessageValue = global::com.chronoxor.proto.BalanceMessage.Default;
BalanceMessageModel = new BalanceMessageModel();
AccountMessageValue = global::com.chronoxor.proto.AccountMessage.Default;
AccountMessageModel = new AccountMessageModel();
}
public Receiver(com.chronoxor.FBE.Buffer buffer) : base(buffer, false)
{
OrderMessageValue = global::com.chronoxor.proto.OrderMessage.Default;
OrderMessageModel = new OrderMessageModel();
BalanceMessageValue = global::com.chronoxor.proto.BalanceMessage.Default;
BalanceMessageModel = new BalanceMessageModel();
AccountMessageValue = global::com.chronoxor.proto.AccountMessage.Default;
AccountMessageModel = new AccountMessageModel();
}

internal override bool OnReceive(long type, byte[] buffer, long offset, long size) { return OnReceiveListener(this, type, buffer, offset, size); }
Expand Down Expand Up @@ -4927,21 +4915,18 @@ void OnProxy(AccountMessageModel model, long type, byte[] buffer, long offset, l
public class Proxy : com.chronoxor.FBE.Receiver, IProxyListener
{
// Proxy models accessors
private readonly OrderMessageModel OrderMessageModel;
private readonly BalanceMessageModel BalanceMessageModel;
private readonly AccountMessageModel AccountMessageModel;
private OrderMessageModel _orderMessageModel;
private OrderMessageModel OrderMessageModel => _orderMessageModel ?? (_orderMessageModel = new OrderMessageModel());
private BalanceMessageModel _balanceMessageModel;
private BalanceMessageModel BalanceMessageModel => _balanceMessageModel ?? (_balanceMessageModel = new BalanceMessageModel());
private AccountMessageModel _accountMessageModel;
private AccountMessageModel AccountMessageModel => _accountMessageModel ?? (_accountMessageModel = new AccountMessageModel());

public Proxy() : base(false)
{
OrderMessageModel = new OrderMessageModel();
BalanceMessageModel = new BalanceMessageModel();
AccountMessageModel = new AccountMessageModel();
}
public Proxy(com.chronoxor.FBE.Buffer buffer) : base(buffer, false)
{
OrderMessageModel = new OrderMessageModel();
BalanceMessageModel = new BalanceMessageModel();
AccountMessageModel = new AccountMessageModel();
}

internal override bool OnReceive(long type, byte[] buffer, long offset, long size) { return OnReceiveListener(this, type, buffer, offset, size); }
Expand Down Expand Up @@ -5011,43 +4996,31 @@ public interface IClientListener : com.chronoxor.FBE.IClientListener, ISenderLis
public class Client : com.chronoxor.FBE.Client, IClientListener
{
// Client sender models accessors
public readonly OrderMessageModel OrderMessageSenderModel;
public readonly BalanceMessageModel BalanceMessageSenderModel;
public readonly AccountMessageModel AccountMessageSenderModel;
private OrderMessageModel _orderMessageSenderModel;
public OrderMessageModel OrderMessageSenderModel => _orderMessageSenderModel ?? (_orderMessageSenderModel = new OrderMessageModel(SendBuffer));
private BalanceMessageModel _balanceMessageSenderModel;
public BalanceMessageModel BalanceMessageSenderModel => _balanceMessageSenderModel ?? (_balanceMessageSenderModel = new BalanceMessageModel(SendBuffer));
private AccountMessageModel _accountMessageSenderModel;
public AccountMessageModel AccountMessageSenderModel => _accountMessageSenderModel ?? (_accountMessageSenderModel = new AccountMessageModel(SendBuffer));

// Client receiver values accessors
private global::com.chronoxor.proto.OrderMessage OrderMessageReceiverValue;
private global::com.chronoxor.proto.BalanceMessage BalanceMessageReceiverValue;
private global::com.chronoxor.proto.AccountMessage AccountMessageReceiverValue;

// Client receiver models accessors
private readonly OrderMessageModel OrderMessageReceiverModel;
private readonly BalanceMessageModel BalanceMessageReceiverModel;
private readonly AccountMessageModel AccountMessageReceiverModel;
private OrderMessageModel _orderMessageReceiverModel;
private OrderMessageModel OrderMessageReceiverModel => _orderMessageReceiverModel ?? (_orderMessageReceiverModel = new OrderMessageModel());
private BalanceMessageModel _balanceMessageReceiverModel;
private BalanceMessageModel BalanceMessageReceiverModel => _balanceMessageReceiverModel ?? (_balanceMessageReceiverModel = new BalanceMessageModel());
private AccountMessageModel _accountMessageReceiverModel;
private AccountMessageModel AccountMessageReceiverModel => _accountMessageReceiverModel ?? (_accountMessageReceiverModel = new AccountMessageModel());

public Client() : base(false)
{
OrderMessageSenderModel = new OrderMessageModel(SendBuffer);
OrderMessageReceiverValue = global::com.chronoxor.proto.OrderMessage.Default;
OrderMessageReceiverModel = new OrderMessageModel();
BalanceMessageSenderModel = new BalanceMessageModel(SendBuffer);
BalanceMessageReceiverValue = global::com.chronoxor.proto.BalanceMessage.Default;
BalanceMessageReceiverModel = new BalanceMessageModel();
AccountMessageSenderModel = new AccountMessageModel(SendBuffer);
AccountMessageReceiverValue = global::com.chronoxor.proto.AccountMessage.Default;
AccountMessageReceiverModel = new AccountMessageModel();
}
public Client(com.chronoxor.FBE.Buffer sendBuffer, com.chronoxor.FBE.Buffer receiveBuffer) : base(sendBuffer, receiveBuffer, false)
{
OrderMessageSenderModel = new OrderMessageModel(SendBuffer);
OrderMessageReceiverValue = global::com.chronoxor.proto.OrderMessage.Default;
OrderMessageReceiverModel = new OrderMessageModel();
BalanceMessageSenderModel = new BalanceMessageModel(SendBuffer);
BalanceMessageReceiverValue = global::com.chronoxor.proto.BalanceMessage.Default;
BalanceMessageReceiverModel = new BalanceMessageModel();
AccountMessageSenderModel = new AccountMessageModel(SendBuffer);
AccountMessageReceiverValue = global::com.chronoxor.proto.AccountMessage.Default;
AccountMessageReceiverModel = new AccountMessageModel();
}

public long Send(object obj) { return SendListener(this, obj); }
Expand Down Expand Up @@ -5248,21 +5221,18 @@ public interface IFinalSenderListener : com.chronoxor.FBE.ISenderListener
public class FinalSender : com.chronoxor.FBE.Sender, IFinalSenderListener
{
// Sender models accessors
public readonly OrderMessageFinalModel OrderMessageModel;
public readonly BalanceMessageFinalModel BalanceMessageModel;
public readonly AccountMessageFinalModel AccountMessageModel;
private OrderMessageFinalModel _orderMessageModel;
public OrderMessageFinalModel OrderMessageModel => _orderMessageModel ?? (_orderMessageModel = new OrderMessageFinalModel(Buffer));
private BalanceMessageFinalModel _balanceMessageModel;
public BalanceMessageFinalModel BalanceMessageModel => _balanceMessageModel ?? (_balanceMessageModel = new BalanceMessageFinalModel(Buffer));
private AccountMessageFinalModel _accountMessageModel;
public AccountMessageFinalModel AccountMessageModel => _accountMessageModel ?? (_accountMessageModel = new AccountMessageFinalModel(Buffer));

public FinalSender() : base(true)
{
OrderMessageModel = new OrderMessageFinalModel(Buffer);
BalanceMessageModel = new BalanceMessageFinalModel(Buffer);
AccountMessageModel = new AccountMessageFinalModel(Buffer);
}
public FinalSender(com.chronoxor.FBE.Buffer buffer) : base(buffer, true)
{
OrderMessageModel = new OrderMessageFinalModel(Buffer);
BalanceMessageModel = new BalanceMessageFinalModel(Buffer);
AccountMessageModel = new AccountMessageFinalModel(Buffer);
}

public long Send(object obj) { return SendListener(this, obj); }
Expand Down Expand Up @@ -5357,27 +5327,18 @@ public class FinalReceiver : com.chronoxor.FBE.Receiver, IFinalReceiverListener
private global::com.chronoxor.proto.AccountMessage AccountMessageValue;

// Receiver models accessors
private readonly OrderMessageFinalModel OrderMessageModel;
private readonly BalanceMessageFinalModel BalanceMessageModel;
private readonly AccountMessageFinalModel AccountMessageModel;
private OrderMessageFinalModel _orderMessageModel;
private OrderMessageFinalModel OrderMessageModel => _orderMessageModel ?? (_orderMessageModel = new OrderMessageFinalModel());
private BalanceMessageFinalModel _balanceMessageModel;
private BalanceMessageFinalModel BalanceMessageModel => _balanceMessageModel ?? (_balanceMessageModel = new BalanceMessageFinalModel());
private AccountMessageFinalModel _accountMessageModel;
private AccountMessageFinalModel AccountMessageModel => _accountMessageModel ?? (_accountMessageModel = new AccountMessageFinalModel());

public FinalReceiver() : base(true)
{
OrderMessageValue = global::com.chronoxor.proto.OrderMessage.Default;
OrderMessageModel = new OrderMessageFinalModel();
BalanceMessageValue = global::com.chronoxor.proto.BalanceMessage.Default;
BalanceMessageModel = new BalanceMessageFinalModel();
AccountMessageValue = global::com.chronoxor.proto.AccountMessage.Default;
AccountMessageModel = new AccountMessageFinalModel();
}
public FinalReceiver(com.chronoxor.FBE.Buffer buffer) : base(buffer, true)
{
OrderMessageValue = global::com.chronoxor.proto.OrderMessage.Default;
OrderMessageModel = new OrderMessageFinalModel();
BalanceMessageValue = global::com.chronoxor.proto.BalanceMessage.Default;
BalanceMessageModel = new BalanceMessageFinalModel();
AccountMessageValue = global::com.chronoxor.proto.AccountMessage.Default;
AccountMessageModel = new AccountMessageFinalModel();
}

internal override bool OnReceive(long type, byte[] buffer, long offset, long size) { return OnReceiveListener(this, type, buffer, offset, size); }
Expand Down Expand Up @@ -5462,43 +5423,31 @@ public interface IFinalClientListener : com.chronoxor.FBE.IClientListener, IFina
public class FinalClient : com.chronoxor.FBE.Client, IFinalClientListener
{
// Client sender models accessors
public readonly OrderMessageFinalModel OrderMessageSenderModel;
public readonly BalanceMessageFinalModel BalanceMessageSenderModel;
public readonly AccountMessageFinalModel AccountMessageSenderModel;
private OrderMessageFinalModel _orderMessageSenderModel;
public OrderMessageFinalModel OrderMessageSenderModel => _orderMessageSenderModel ?? (_orderMessageSenderModel = new OrderMessageFinalModel(SendBuffer));
private BalanceMessageFinalModel _balanceMessageSenderModel;
public BalanceMessageFinalModel BalanceMessageSenderModel => _balanceMessageSenderModel ?? (_balanceMessageSenderModel = new BalanceMessageFinalModel(SendBuffer));
private AccountMessageFinalModel _accountMessageSenderModel;
public AccountMessageFinalModel AccountMessageSenderModel => _accountMessageSenderModel ?? (_accountMessageSenderModel = new AccountMessageFinalModel(SendBuffer));

// Client receiver values accessors
private global::com.chronoxor.proto.OrderMessage OrderMessageReceiverValue;
private global::com.chronoxor.proto.BalanceMessage BalanceMessageReceiverValue;
private global::com.chronoxor.proto.AccountMessage AccountMessageReceiverValue;

// Client receiver models accessors
private readonly OrderMessageFinalModel OrderMessageReceiverModel;
private readonly BalanceMessageFinalModel BalanceMessageReceiverModel;
private readonly AccountMessageFinalModel AccountMessageReceiverModel;
private OrderMessageFinalModel _orderMessageReceiverModel;
private OrderMessageFinalModel OrderMessageReceiverModel => _orderMessageReceiverModel ?? (_orderMessageReceiverModel = new OrderMessageFinalModel());
private BalanceMessageFinalModel _balanceMessageReceiverModel;
private BalanceMessageFinalModel BalanceMessageReceiverModel => _balanceMessageReceiverModel ?? (_balanceMessageReceiverModel = new BalanceMessageFinalModel());
private AccountMessageFinalModel _accountMessageReceiverModel;
private AccountMessageFinalModel AccountMessageReceiverModel => _accountMessageReceiverModel ?? (_accountMessageReceiverModel = new AccountMessageFinalModel());

public FinalClient() : base(true)
{
OrderMessageSenderModel = new OrderMessageFinalModel(SendBuffer);
OrderMessageReceiverValue = global::com.chronoxor.proto.OrderMessage.Default;
OrderMessageReceiverModel = new OrderMessageFinalModel();
BalanceMessageSenderModel = new BalanceMessageFinalModel(SendBuffer);
BalanceMessageReceiverValue = global::com.chronoxor.proto.BalanceMessage.Default;
BalanceMessageReceiverModel = new BalanceMessageFinalModel();
AccountMessageSenderModel = new AccountMessageFinalModel(SendBuffer);
AccountMessageReceiverValue = global::com.chronoxor.proto.AccountMessage.Default;
AccountMessageReceiverModel = new AccountMessageFinalModel();
}
public FinalClient(com.chronoxor.FBE.Buffer sendBuffer, com.chronoxor.FBE.Buffer receiveBuffer) : base(sendBuffer, receiveBuffer, true)
{
OrderMessageSenderModel = new OrderMessageFinalModel(SendBuffer);
OrderMessageReceiverValue = global::com.chronoxor.proto.OrderMessage.Default;
OrderMessageReceiverModel = new OrderMessageFinalModel();
BalanceMessageSenderModel = new BalanceMessageFinalModel(SendBuffer);
BalanceMessageReceiverValue = global::com.chronoxor.proto.BalanceMessage.Default;
BalanceMessageReceiverModel = new BalanceMessageFinalModel();
AccountMessageSenderModel = new AccountMessageFinalModel(SendBuffer);
AccountMessageReceiverValue = global::com.chronoxor.proto.AccountMessage.Default;
AccountMessageReceiverModel = new AccountMessageFinalModel();
}

public long Send(object obj) { return SendListener(this, obj); }
Expand Down
Loading