Project Name File Name Usage Source Code Link
Hermod TCPServer.cs #endregion #region Store the new connection _SocketConnections.AddOrUpdate(_TCPConnection.Value.RemoteSocket, _TCPConnection.Value, (RemoteEndPoint, TCPConnection) => TCPConnection) Link To Source File
hyperstack SocketApplicationProxy.cs Clients.AddOrUpdate( id, x => new SocketClient() { Id = id, Next = ParseRequest, Socket = socket }, ( x, y ) => new SocketClient() { Id = id, Next = ParseRequest, Socket = socket } ) Link To Source File
Symbiote SimpleDependencyRegistry.cs Definitions .AddOrUpdate( key, x => new List() { dependency }, ( x, y ) => { if( IsDuplicate( dependency ) ) { EliminateDuplicateDependencies( dependency, y, key ); } y.Add( dependency ); return y; } ) Link To Source File
Symbiote DispatchManager.cs Dispatchers.AddOrUpdate( envelope.MessageType, x => dispatcher, ( x, y ) => dispatcher ) Link To Source File
Symbiote DispatchManager.cs Dispatchers.AddOrUpdate( y, x, ( t, m ) => x ) Link To Source File
typefoundry SimpleDependencyRegistry.cs Definitions .AddOrUpdate( key, x => new List() { dependency }, ( x, y ) => { if( IsDuplicate( dependency ) ) { EliminateDuplicateDependencies( dependency, y, key ); } y.Add( dependency ); return y; } ) Link To Source File
ProjectEuler DictionaryExtensions.cs concurrentDict.AddOrUpdate(key, addValueFactory, updateValueFactory) Link To Source File
InVision GameComponentCollection.cs _componentsRegister.AddOrUpdate(key, addValueFactory, updateValueFactory) Link To Source File
Monator CachedDomainStatistics.cs _activeRequests.AddOrUpdate(selector.Id, time, ( guid, date) => time ) Link To Source File
ILSpy AstMethodBodyBuilder.cs #if DEBUG unhandledOpcodes.AddOrUpdate(byteCode.Code, c => 1, (c, n) => n+1) Link To Source File
SharpDevelop AstMethodBodyBuilder.cs #if DEBUG unhandledOpcodes.AddOrUpdate(byteCode.Code, c => 1, (c, n) => n+1) Link To Source File
Mystique PostOffice.cs underControls.AddOrUpdate(info, release) Link To Source File
OrchardApp Cache.cs _entries.AddOrUpdate(key, // "Add" lambda k => AddEntry(k, acquire), // "Update" lamdba (k, currentEntry) => UpdateEntry(currentEntry, k, acquire)) Link To Source File
lokad-cqrs MemoryTapeStream.cs _storage.AddOrUpdate(_name, s => { condition.Enforce(0); return new List { buffer }; }, (s, list) => { condition.Enforce(list.Count); list.Add(buffer); return list; }) Link To Source File
lokad-cqrs MemoryAtomicReaderWriter.cs _store.AddOrUpdate(GetName(key), s => { result = addFactory(); using (var memory = new MemoryStream()) { _strategy.Serialize(result, memory); return memory.ToArray(); } }, (s2, bytes) => { TEntity entity; using (var memory = new MemoryStream(bytes)) { entity = _strategy.Deserialize(memory); } result = update(entity); using (var memory = new MemoryStream()) { _strategy.Serialize(result, memory); return memory.ToArray(); } }) Link To Source File
lokad-cqrs MemoryQuarantine.cs _failures.AddOrUpdate(envelope.EnvelopeId, s => 1, (s1, i) => i + 1) Link To Source File
lokad-cqrs Program.cs _states.AddOrUpdate(path, key => { changed = true; return value; }, (s, s1) => { changed = s1 != value; return value; }) Link To Source File
FistCore.Lib MembasePool.cs this._client.AddOrUpdate(vBucket, new CouchbaseClient(this._bucketProps[vBucket].BucketName, this._bucketProps[vBucket].BucketPassword), (key, value) => { return new CouchbaseClient(this._bucketProps[vBucket].BucketName, this._bucketProps[vBucket].BucketPassword); }) Link To Source File
orchard Cache.cs _entries.AddOrUpdate(key, // "Add" lambda k => AddEntry(k, acquire), // "Update" lamdba (k, currentEntry) => UpdateEntry(currentEntry, k, acquire)) Link To Source File
monodevelop AstMethodBodyBuilder.cs localVariables.AddOrUpdate(token, allVariables, (key, oldValue) => allVariables) Link To Source File
monodevelop AstMethodBodyBuilder.cs #if DEBUG unhandledOpcodes.AddOrUpdate(byteCode.Code, c => 1, (c, n) => n+1) Link To Source File
ravendb HttpServer.cs databaseLastRecentlyUsed.AddOrUpdate(tenantId, SystemTime.Now, (s, time) => SystemTime.Now) Link To Source File
ravendb IndexDefinitionStorage.cs indexDefinitions.AddOrUpdate(name, indexDefinition, (s1, definition) => indexDefinition) Link To Source File
ravendb IndexStorage.cs indexes.AddOrUpdate(indexDefinition.Name, n => { var directory = OpenOrCreateLuceneDirectory(indexDefinition, encodedName); return CreateIndexImplementation(encodedName, indexDefinition, directory); }, (s, index) => index) Link To Source File
ravenmq HttpServer.cs databaseLastRecentlyUsed.AddOrUpdate(match.Groups[1].Value, DateTime.Now, (s, time) => DateTime.Now) Link To Source File
ravenmq RavenMQConnection.cs lastEtagPerQeueue.AddOrUpdate( readResults.Queue, lastMsg.Id, (s, guid) => Max(lastMsg.Id, guid)) Link To Source File
MOUSE Node.cs _pendingConnections.AddOrUpdate(endPoint, (key) => { var val = new PendingConnection(key); Log.Info("Connecting to " + endPoint); Net.Connect(endPoint); var expiration = TaskEx.Delay(TimeSpan.FromSeconds(ExpirationTimeout), val.Expiration.Token); expiration.ContinueWith((_) => { PendingConnection cont; if (_pendingConnections.TryRemove(key, out cont)) cont.TCS.SetException(new Exception("Cant connect to -" + key)); }); return val; }, (key, val) => val ) Link To Source File
Roger ByMessageHirarchyRootSequenceGenerator.cs sequences.AddOrUpdate(messageType.HierarchyRoot(), type => 1u, (type, s) => s+1) Link To Source File
sones InMemoryNonRevisionedFS.cs outValue.AddOrUpdate(myToBeUpdatedVertexID, updatedVertex, (key, oldValue) => { lock (oldValue) { oldValue = updatedVertex; return oldValue; } }) Link To Source File
twdc DerivedTypeModelBinderCache.cs _hashToTypeDictionary.AddOrUpdate(encryptedName, name => currentItem, (name, itemValue) => currentItem) Link To Source File
twdc DerivedTypeModelBinderCache.cs _typeToHashDictionary.AddOrUpdate(currentItem, type => encryptedName, (type, name) => encryptedName) Link To Source File
WowPacketParser CharacterHandler.cs packet.SniffFileInfo.Storage.Objects.AddOrUpdate(guid, playerInfo) Link To Source File
WowPacketParser CharacterHandler.cs packet.SniffFileInfo.Storage.Objects.AddOrUpdate(playerGuid, playerInfo) Link To Source File
WowPacketParser CharacterHandler.cs packet.SniffFileInfo.Storage.Objects.AddOrUpdate(playerGuid, playerInfo) Link To Source File