<commit_before>﻿using System;
using System.Collections;

namespace gate
{
	public class client_msg_handle
	{
		public client_msg_handle(clientmanager _clientmanager_, logicmanager _logicmanager_, service.timerservice _timerservice_)
		{
			_clientmanager = _clientmanager_;
			_logicmanager = _logicmanager_;
			_timerservice = _timerservice_;
		}

		public void connect_server(string uuid, long tick)
		{
			logicproxy _logicproxy = _logicmanager.get_logic();

			if (!_clientmanager.has_client(uuid)) {
				System.Console.WriteLine("client " + uuid + " connected");

				_clientmanager.reg_client(uuid, juggle.Imodule.current_ch, _timerservice.Tick, tick);

				_logicproxy.client_connect (uuid);
			}
		}

		public void cancle_server()
		{
			logicproxy _logicproxy = _clientmanager.get_clientproxy_logicproxy (juggle.Imodule.current_ch);
			if (_logicproxy != null)
			{
				string uuid = _clientmanager.get_client_uuid(
					_clientmanager.get_clientproxy(juggle.Imodule.current_ch));

				_logicproxy.client_disconnect (uuid);
			}
		}

		public void forward_client_call_logic(string module, string func, ArrayList argv)
		{
			logicproxy _logicproxy = _clientmanager.get_clientproxy_logicproxy (juggle.Imodule.current_ch);
			if (_logicproxy != null)
			{
				string uuid = _clientmanager.get_client_uuid(
					_clientmanager.get_clientproxy(juggle.Imodule.current_ch));
				
				_logicproxy.client_call_logic (uuid, module, func, argv);
			}
		}

		public void heartbeats(long clockt)
		{
			_clientmanager.refresh_and_check_client(juggle.Imodule.current_ch, _timerservice.Tick, clockt);
		}

		private clientmanager _clientmanager;
		private logicmanager _logicmanager;
		private service.timerservice _timerservice;
	}
}
<commit_msg>Signed-off-by: qianqians <<EMAIL>><commit_after>﻿using System;
using System.Collections;

namespace gate
{
	public class client_msg_handle
	{
		public client_msg_handle(clientmanager _clientmanager_, logicmanager _logicmanager_, service.timerservice _timerservice_)
		{
			_clientmanager = _clientmanager_;
			_logicmanager = _logicmanager_;
			_timerservice = _timerservice_;
		}

		public void connect_server(string uuid, long tick)
		{
			logicproxy _logicproxy = _logicmanager.get_logic();

			if (!_clientmanager.has_client(uuid)) {
				System.Console.WriteLine("client " + uuid + " connected");

				_clientmanager.reg_client(uuid, juggle.Imodule.current_ch, _timerservice.Tick, tick);

				_logicproxy.client_connect (uuid);
			}
		}

		public void cancle_server()
		{
			logicproxy _logicproxy = _clientmanager.get_clientproxy_logicproxy (juggle.Imodule.current_ch);
			if (_logicproxy != null)
			{
				string uuid = _clientmanager.get_client_uuid(
					_clientmanager.get_clientproxy(juggle.Imodule.current_ch));

				_logicproxy.client_disconnect (uuid);
			}

            _clientmanager.unreg_client(juggle.Imodule.current_ch);
        }

		public void forward_client_call_logic(string module, string func, ArrayList argv)
		{
			logicproxy _logicproxy = _clientmanager.get_clientproxy_logicproxy (juggle.Imodule.current_ch);
			if (_logicproxy != null)
			{
				string uuid = _clientmanager.get_client_uuid(
					_clientmanager.get_clientproxy(juggle.Imodule.current_ch));
				
				_logicproxy.client_call_logic (uuid, module, func, argv);
			}
		}

		public void heartbeats(long clockt)
		{
			_clientmanager.refresh_and_check_client(juggle.Imodule.current_ch, _timerservice.Tick, clockt);
		}

		private clientmanager _clientmanager;
		private logicmanager _logicmanager;
		private service.timerservice _timerservice;
	}
}

{'fraction_non_alphanumeric': 0.08798882681564246, 'fraction_numerical': 0.0, 'mean_word_length': 4.684126984126984, 'pattern_counts': {'":': 0, '<': 5, '<?xml version=': 0, '>': 5, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '6979019', 'n_tokens_mistral': 1359, 'n_tokens_neox': 1133, 'n_words': 199}