Databases
StackOverflow2013
Postsdbo
POC# - confused on lock
Body
 

Note that there are some explanatory texts on larger screens.

plurals
  1. POC# - confused on lock
    text
    copied!<p>For my network based project I need to lock some codes to prevent simultaneous access. This is my code </p> <pre><code>using System; using System.Collections.Generic; using System.Linq; using System.Text; using Utility; using DataBaseConnection; using System.Net.Sockets; using System.Data; using System.IO; namespace SunHavenClasses { public delegate void CtatReceiveDelegate(string message); public class ServerHandlerClass { public event CtatReceiveDelegate OnChatDataReceive; private Settings settings; private DBCon con; private Utility.Network.Server server; private Dictionary&lt;string, Socket&gt; UsersOnline; private Dictionary&lt;string, int&gt; unAuthenticatedIps; private string pass = "logisoftlogicielbarundipankar"; public ServerHandlerClass(Settings s) { settings = s; con = s.GetConnection(); server = new Utility.Network.Server(7777); server.ClientConnectEventArise += OnUserConnect;//.OnClientConnect(OnUserConnect); server.ClientDataReceiveEventArise += OnUsersDataReceive; server.ClientDataSendEventArise += OnDataSendToUser; server.ClientDisconnectEventArise += OnUserDisconnect; server.OnBlockUser += OnUserBlocked; UsersOnline = new Dictionary&lt;string, Socket&gt;(); unAuthenticatedIps = new Dictionary&lt;string, int&gt;(); } private void OnUserConnect(Utility.Network.ServerEventArguments e) { Stream data = Utility.Serializing.Serialize(settings); data = ZipNEncrypt.Zip(new string[] { "settings" }, new Stream[] { data }, pass); server.Send(data, e.ClientSocket); //MessageBox.Show(e.ClientSocket.RemoteEndPoint.ToString() + " is Connected!!"); } private void OnUsersDataReceive(Utility.Network.ServerEventArguments e) { Dictionary&lt;string, System.IO.Stream&gt; data = ZipNEncrypt.Unzip(e.Data, pass); User user; try { user = (User)Serializing.Deserialize(data["user"]); if (!UsersOnline.ContainsKey(user.GetUserId())) { server.BlockIp(e.ClientSocket); return; } data.Remove("user"); } catch (Exception) { bool passed = true; foreach (string key in data.Keys) { if (key.Equals("LoggedIn")) break; string[] str = key.Split('_'); if (str[0].Equals("GetData")) { string strr = (string)Serializing.Deserialize(data[key]); if (strr.Contains("Users")) { string ip = e.ClientSocket.RemoteEndPoint.ToString().Split(':')[0]; /*CHANGE 1.2.10 00:14*/ lock (unAuthenticatedIps) { if (!unAuthenticatedIps.ContainsKey(ip)) { unAuthenticatedIps.Add(ip, 1); } else unAuthenticatedIps[ip] += 1; if (unAuthenticatedIps[ip] &gt;= 11) passed = false; } /*CHANGE 1.2.10 00:14*/ break; } else passed = false;//server.AddBlockedIp(ip); } else passed = false; } if (!passed) { server.BlockIp(e.ClientSocket); } } foreach (string key in data.Keys) { if (key.Equals("LoggedIn")) { try { User u = (User)Serializing.Deserialize(data["LoggedIn"]); if (!UsersOnline.ContainsKey(u.GetUserId())) { if (User.ValidateUser(u.GetUserId(), u.GetPassword(), con)) { /*CHANGE 1.2.10 00:14*/ lock (UsersOnline) { UsersOnline.Add(u.GetUserId(), e.ClientSocket); string ip = e.ClientSocket.RemoteEndPoint.ToString().Split(':')[0]; Utility.Log.Write("UserLog.log", u.GetUserId() + " Logged In From Ip " + ip); } /*CHANGE 1.2.10 00:14*/ } else { server.BlockIp(e.ClientSocket); return; } } else { Stream tmpStream = Serializing.Serialize("Same User"); tmpStream = ZipNEncrypt.Zip(new string[] { key + "ERROR_SameUser" }, new Stream[] { tmpStream }, pass); server.Send(tmpStream, e.ClientSocket); return; } } catch (Exception) { } return; } else if (key.Equals("chat")) { string ip = e.ClientSocket.RemoteEndPoint.ToString().Split(':')[0]; string message = ip + " : "+ (string)Serializing.Deserialize(data[key]); OnChatDataReceive(message); return; } string[] str = key.Split('_'); Stream dataStream = null; object obj = null; try { if (str[0].StartsWith("Get")) { if (str[0].Equals("GetData")) { string query = (string)Serializing.Deserialize(data[key]); obj = con.GetData(query); } else if (str[0].Equals("GetColumn")) { string query = (string)Serializing.Deserialize(data[key]); string[] tmp = query.Split('%'); obj = con.GetColumn(tmp[0], tmp[1]); } else if (str[0].Equals("GetColumnDistrinctValue")) { string query = (string)Serializing.Deserialize(data[key]); string[] tmp = query.Split('%'); obj = con.GetColumnDistrinctValue(tmp[0], tmp[1]); } } else { lock (this) { if (str[0].Equals("ExecuteUpdate")) { if (str[1].Equals("Query")) { Query query = (Query)Serializing.Deserialize(data[key]); obj = con.ExecuteUpdate(query); } else if (str[1].Equals("String")) { string query = (string)Serializing.Deserialize(data[key]); obj = con.ExecuteUpdate(query); } } else if (str[0].Equals("ExecuteBatchUpdate")) { if (str[1].Equals("Query")) { Query[] query = (Query[])Serializing.Deserialize(data[key]); obj = con.ExecuteBatchUpdate(query); } else if (str[1].Equals("String")) { string[] query = (string[])Serializing.Deserialize(data[key]); obj = con.ExecuteBatchUpdate(query); } } else if (str[0].Equals("ExecutrInsert")) { Query query = (Query)Serializing.Deserialize(data[key]); obj = con.ExecutrInsert(query); } } } dataStream = Serializing.Serialize(obj); dataStream = ZipNEncrypt.Zip(new string[] { key }, new Stream[] { dataStream }, pass); } catch (Exception ex) { dataStream = Serializing.Serialize(ex.Message); dataStream = ZipNEncrypt.Zip(new string[] { key + "_ERROR" }, new Stream[] { dataStream }, pass); } server.Send(dataStream, e.ClientSocket); } } private void OnDataSendToUser(Utility.Network.ServerEventArguments e) { } private void OnUserDisconnect(Utility.Network.ServerEventArguments e) { //System.Windows.Forms.MessageBox.Show("Disconnected"); string ip = e.ClientSocket.RemoteEndPoint.ToString().Split(':')[0]; /*CHANGE 1.2.10 00:14*/ lock (unAuthenticatedIps) { if (unAuthenticatedIps.ContainsKey(ip)) unAuthenticatedIps.Remove(ip); } lock (UsersOnline) { foreach (string key in UsersOnline.Keys) if (UsersOnline[key].Equals(e.ClientSocket)) { Utility.Log.Write("UserLog.log", key + " Logged Out From Ip " + ip); UsersOnline.Remove(key); break; } } /*CHANGE 1.2.10 00:14*/ } private void OnUserBlocked(Utility.Network.ServerEventArguments e) { string ip = e.ClientSocket.RemoteEndPoint.ToString().Split(':')[0]; Utility.Log.Write("UserLog.log", "Blocked For Illegal Access From Ip " + ip); } public void Send(Stream dataStream) { foreach (string key in UsersOnline.Keys) { try { server.Send(dataStream, UsersOnline[key]); } catch (Exception) { } } } public void Send(Stream dataStream, Socket client) { try { server.Send(dataStream, client); } catch (Exception) { } } /*changed*/ public bool AddUser(string userId, Socket socket) { if (UsersOnline.ContainsKey(userId)) return false; UsersOnline.Add(userId, null); return true; } public void RemoveUser(string userId) { if (!UsersOnline.ContainsKey(userId) || UsersOnline[userId] != null) return; UsersOnline.Remove(userId); } } } </code></pre> <p>Now I am not sure that I am using lock correctly.Please Give me some advice. Thanks.</p>
 

Querying!

 
Guidance
An individual column

Larger individual text columns get their own page to allow for proper reading.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload