Socket.BeginConnect и чтение/запись данных - проверка кода

private void Connect()
        {
            String server = "192.168.10.100";
            Int32 port = 6000;
            _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            IPAddress ip = IPAddress.Parse(server);
            int iPortNo = System.Convert.ToInt16(port);
            IPEndPoint ipEnd = new IPEndPoint(ip, iPortNo);
            try
            {
                server = "192.168.10.100";
                port = 6000;
                _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                ip = IPAddress.Parse(server);
                iPortNo = System.Convert.ToInt16(port);
                ipEnd = new IPEndPoint(ip, iPortNo);
                //_socket.Blocking = false; ?????
                _socket.BeginConnect(ipEnd, new AsyncCallback(ConnectCallback), _socket);
            }
            catch (Exception e)
            {
                _socket.Dispose();
                MessageBox.Show(e.ToString() + " Connect()");
            }
        }
public void ConnectCallback(IAsyncResult ar)
        {
            while (flag)
                try
                {
                    FileBuffer = new byte[BYTEBUFFER];
                    int j = 0;
                    Socket client = (Socket)ar.AsyncState;
                    buf12 = new byte[BYTEBUFFER];
                    int read = client.Receive(buf12);
                    fs.Write(buf12,0,buf12.Length);
 
                   int readFile =  fs.Read(FileBuffer, 0, FileBuffer.Length);
                    for (int i = 16; i <= read; i = i + 16)
                    {
                        Convert = BitConverter.ToInt16(buf12, i - 12);
                        
                       /* ThreadPool.QueueUserWorkItem(delegate(object sender)
                        {
                            System.Windows.Forms.DataVisualization.Charting.Chart _chart = (System.Windows.Forms.DataVisualization.Charting.Chart)sender;
                            _chart.Invoke(actionChart, new object[] {_chart, BitConverter.ToInt16(buf12, i - 12)});
                        },chart1);*/
                        if (chart1.InvokeRequired == false)
                            MessageBox.Show("FATAL");
                           Invoke(new Action(() =>
                        {
                            if(readFile !=0)
                                textBoxThread.AppendText(String.Format("{0}:{1}:{2}:{3}", FileBuffer[i - 16].ToString(), FileBuffer[i - 15].ToString(), BitConverter.ToInt16(FileBuffer, i - 14).ToString(), BitConverter.ToInt16(FileBuffer, i - 12).ToString()) + Environment.NewLine);
                            textBox1.Text=String.Format("{0}:{1}:{2}:{3}", buf12[i - 16].ToString(), buf12[i - 15].ToString(), BitConverter.ToInt16(buf12, i - 14).ToString(), Convert.ToString()) + Environment.NewLine;
                          //  chart1.Series[0].Points.AddY(Double.Parse(BitConverter.ToInt16(buf12, i - 12).ToString()));
                          //  textBoxThread.AppendText((j == BitConverter.ToInt16(buf12, i - 12) || j == 1000) ? "" : j.ToString() + Environment.NewLine);
                        }));
                       /* if (i % 400 == 0 || i == 16)
                        {
                            chart1.BeginInvoke(new Action(() =>
                            {
                                chart1.Series[0].Points.AddY(Convert);
                            }));
                        }*/
                    }
                    //    client.BeginReceive(buf12, 0, buf12.Length, 0,
                    //           new AsyncCallback(ReceiveCallback), buf12);
                }
                catch (Exception e)
                {
                    fs.Close();
                    MessageBox.Show(e.ToString() + " ConnectCallback(IAsyncResult ar)"); return;
                }
            
        }

_socket.BeginConnect->ConnectCallback->Socket client = (Socket)ar.AsyncState;->client.BeginReceive(buf12, 0, buf12.Length, 0,
                               new AsyncCallback(ReceiveCallback), buf12);->textBox1.Invoke(new Action(() =>
                     {
                         textBox1.AppendText(String.Format("{0}:{1}:{2}:{3}", state[i - 16].ToString(), state[i - 15].ToString(), state[i - 14].ToString(), BitConverter.ToInt16(state, i - 12).ToString()) + Environment.NewLine);
                     }));

public class ClientSendMsgEventArgs : EventArgs
    {
        public string msg;
        public string IP;
        public string port;
        public ClientSendMsgEventArgs(string msg, string IP, string port)
        {
            this.IP = IP;
            this.port = port;
            this.msg = msg;
        }
    }
 
    public delegate void ClientSendMsgEventHandler(object sender, ClientSendMsgEventArgs e);

public event ClientSendMsgEventHandler ClientSendMsgEvent;
 protected virtual void OnClientSendMsg(ClientSendMsgEventArgs e)
        {
            if (ClientSendMsgEvent != null)
                ClientSendMsgEvent(this, e);
        }
....где то внутри метода отправки данных
OnClientSendMsg(new ClientReceiveMsgEventArgs(str, e.RemoteEndPoint.ToString(), msg));
...