lukasz-pyrzyk

using System;
using System.Net;

namespace XGain
{
    public class StartArgs : EventArgs
    {
        public StartArgs(ProcessingType processingType, EndPoint localEndpoint)
        {
            ProcessingType = processingType;

lukasz-pyrzyk

using System;

namespace XGain
{
    public class ErrorArgs : EventArgs
    {
        public ErrorArgs(Exception ex)
        {
            Date = DateTime.Now;
            Exception = ex;

lukasz-pyrzyk

using System;
using XGain.Sockets;

namespace XGain
{
    public class MessageArgs : EventArgs
    {
        public MessageArgs()
        {
        }

lukasz-pyrzyk

[..]
namespace XGain
{
    public class XGainServer : IServer
    {
        public event EventHandler<StartArgs> OnStart;
        public event EventHandler<MessageArgs> OnNewMessage;
        public event EventHandler<ErrorArgs> OnError;

        private readonly Func<IProcessor<MessageArgs>> _requestProcessorResolver;

lukasz-pyrzyk

<configuration>
   <runtime>
      <gcServer enabled="true"/>
   </runtime>
</configuration>

lukasz-pyrzyk

using ProtoBuf;

namespace Kronos.Core.Requests
{
    [ProtoContract]
    public enum RequestType : ushort
    {
        [ProtoEnum]
        Unknown = 0,

lukasz-pyrzyk

using ProtoBuf;

namespace Kronos.Core.StatusCodes
{
    [ProtoContract]
    public enum RequestStatusCode : ushort
    {
        [ProtoEnum]
        Unknown = 0,

lukasz-pyrzyk

    [ProtoContract]
    public class InsertRequest : Request
    {
        public override RequestType RequestType { get; set; } = RequestType.Insert;

        [ProtoMember(1)]
        public string Key { get; set; }

        [ProtoMember(2)]
        public byte[] Object { get; set; }

lukasz-pyrzyk

    [ProtoContract]
    [ProtoInclude(500, typeof(InsertRequest))]
    public abstract class Request
    {
        public virtual RequestType RequestType { get; set; }
    }

lukasz-pyrzyk

    public class SerializationUtils
    {
        public const PrefixStyle Style = PrefixStyle.Fixed32;

        public static int GetLengthOfPackage(byte[] buffer)
        {
            int size;
            Serializer.TryReadLengthPrefix(buffer, 0, buffer.Length, Style, out size);
            return size;
        }