1
2
3
4
5
6

/usr/local/share/dotnet/dotnet /Users/e165729/konoLab/Christie_net/bin/Debug/netcoreapp3.1/Christie_net.dll
ChristieDaemon, listen: bind to [::1]:10000
HelloWorldCodeGear Take => 
HelloWorldCodeGear Take => 

Process finished with exit code 0.

1
2
3
4
5
6
7

public static void Main(string[] args) {
  CodeGearManager cgm = CreateCgm(10000);
  cgm.Setup(new HelloWorldCodeGear());
  cgm.Setup(new FinishHelloWorld());
  cgm.GetLocalDGM().Put("helloWorld", "hello");
  cgm.GetLocalDGM().Put("helloWorld", "world");
    }

1
2
3
4
5
6
7
8
9

public class HelloWorldCodeGear : CodeGear {
    [Take] private string helloWorld;
    
    public override void Run(CodeGearManager cgm) {
        Console.WriteLine("HelloWorldCodeGear Take => " +helloWorld);
        cgm.Setup(new HelloWorldCodeGear());
        cgm.GetLocalDGM().Put(helloWorld, helloWorld);
    }
}

1
2
3
4
5
6
7
8
9

public class FinishHelloWorld : CodeGear {
    [Take] private string hello;
    [Take] private string world;

    public override void Run(CodeGearManager cgm) {
        Console.WriteLine("fin:" + hello + " " + world);
        cgm.GetLocalDGM().Finish();
    }
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14

foreach (var field in this.GetType().GetFields(BindingFlags.Public | BindingFlags.NonPublic | 
                                                       BindingFlags.DeclaredOnly | BindingFlags.Instance)) {
            if (Attribute.IsDefined(field, typeof(Take))) {
                SetCommand(CommandType.TAKE, "local", field.Name, new DataGear<object>(field.FieldType));
            } else if (Attribute.IsDefined(field, typeof(Peek))) {
                SetCommand(CommandType.PEEK, "local", field.Name, new DataGear<object>(field.FieldType));
            } else if (Attribute.IsDefined(field, typeof(TakeFrom))) {
                TakeFrom attri = (TakeFrom) field.GetCustomAttribute(typeof(TakeFrom));
                SetCommand(CommandType.TAKE, attri.name, field.Name, new DataGear<object>(field.FieldType));
            } else if (Attribute.IsDefined(field, typeof(PeekFrom))) {
                PeekFrom attri = (PeekFrom) field.GetCustomAttribute(typeof(PeekFrom));
                SetCommand(CommandType.PEEK, attri.name, field.Name, new DataGear<object>(field.FieldType));
            }
        }

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

// listen on any address ipv4/ipv6
            IPHostEntry host = Dns.GetHostEntry("::");
            IPAddress ipAddress = host.AddressList[0];
            IPEndPoint localEndPoint = new IPEndPoint(ipAddress, localPort);

            Socket socket = new Socket(ipAddress.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
            socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
            Console.WriteLine("ChristieDaemon, listen: bind to " + localEndPoint);
            socket.Bind(localEndPoint);
            socket.Listen((int)SocketOptionName.MaxConnections);