ArraySync.cs File Reference

Classes
class	pluginbase.Objects.Syncable.Watchers.ArraySync< T >
	Syncable class that can synchronize other syncables that it can contain More...

Namespaces
namespace	pluginbase.Objects.Syncable.Watchers

Functions
int	pluginbase.Objects.Syncable.Watchers.Find (Func< T, bool > predicate)
	Find the index of an element in the array given the predicate otherwise returns -1 More...
int	pluginbase.Objects.Syncable.Watchers.FindNull ()
	Find the index of the first available null spot Returns -1 if none exists More...
bool	pluginbase.Objects.Syncable.Watchers.AddToNullSlot (T item)
	Add an element to first available null slot. Returns true on success. More...
bool	pluginbase.Objects.Syncable.Watchers.Remove (T item)
	Remove the first occurance of an element in the array. Returns true on success. More...
void	pluginbase.Objects.Syncable.Watchers.Sort< TKey > (Func< T, TKey > expression)
	Sorts the array with a given expression More...
override void	TouchRecurse ()
override void	ResetWatch ()
sealed override void	EncodeTo (System.IO.BinaryWriter writer, EncodeContext context)
sealed override void	DecodeFrom (System.IO.BinaryReader reader, DecodeContext context)
sealed override void	Persist (pluginbase.Objects.Libs.Persist.IPersistObject obj)
sealed override void	Load (pluginbase.Objects.Libs.Persist.IReadPersistObject obj)
IEnumerator< T >	GetEnumerator ()
	Gets the enumerator. More...

Function Documentation

DecodeFrom()

sealed override void DecodeFrom ( System.IO.BinaryReader  reader, DecodeContext  context  )

protected

        {
            int arrLen = reader.ReadInt32();
            if (_items == null || _items.Length != arrLen)
                this.Resize(arrLen);

            while(true)
            {
                int idx = reader.ReadInt32();
                if (idx < 0)
                    break;
                ReadItem(reader, idx, context);
                OnItemChange(idx);
            }
        }

EncodeTo()

sealed override void EncodeTo ( System.IO.BinaryWriter  writer, EncodeContext  context  )

protected

Attribute: i

.ArrModified

Attribute: i].Value != null && _items[i

.Value.Modified))

        {
            if (_items == null)
            {
                writer.Write(0);
            }
            else
            {
                writer.Write(_items.Length);

                for (int i=0; i<_items.Length; ++i)
                {
                    if (context.Mode == WatchableEncodeMode.Full
                        || _items[i].ArrModified
                        || (_items[i].Value != null && _items[i].Value.Modified))
                    {
                        EncodeItem(writer, i, context);
                    }
                }

                writer.Write(-1); //Terminator
            }
        }

GetEnumerator()

IEnumerator IEnumerable GetEnumerator

(

)

Gets the enumerator.

Returns

The enumerator.

        {
            return _items.Select(x => x.Value).Where(x => x != null).GetEnumerator();
        }

Load()

sealed override void Load ( pluginbase.Objects.Libs.Persist.IReadPersistObject  obj )

protected

Attribute: idx

.TypeString = typeString;

Attribute: idx

.Value = null;

Attribute: idx

.TypeString = null;

Attribute: idx

.TypeString = typeString;

Attribute: idx

.Value = inst;

Attribute: idx

.Value.Load(item.GetObject("_"));

        {
            int len = obj.Get<int>("length");
            this.Resize(len);

            foreach(var item in obj.EnumerateList("items"))
            {
                try
                {
                    int idx = item.Get<int>("idx");
                    string typeString = item.Get<string>("__type");
                    _items[idx].TypeString = typeString;

                    Type type = TypeSerializer.Deserialize(typeString);
                    if (type == null)
                    {
                        _items [idx].Value = null;
                        _items [idx].TypeString = null;
                    }
                    else
                    {
                        var inst = (T)Activator.CreateInstance(type);
                        inst.Watcher = this;

                        _items [idx].TypeString = typeString;
                        _items [idx].Value = inst;
                        _items [idx].Value.Load(item.GetObject("_"));
                    }
                }
                catch
                {
#if DEBUG
                    throw;
#endif
                }
            }
        }

Persist()

sealed override void Persist ( pluginbase.Objects.Libs.Persist.IPersistObject  obj )

protected

Attribute: i

.TypeString ?? string.Empty);

Attribute: i

.Value != null)

Attribute: i

.Value.Persist(item.GetOrCreateObject("_"));

        {
            obj.Set("length", _items.Length);
            for(int i=0; i<_items.Length; ++i)
            {
                var item = obj.CreateListItem("items");
                item.Set("idx", i);
                item.Set("__type", _items[i].TypeString ?? string.Empty);
                if (_items[i].Value != null)
                {
                    _items [i].Value.Persist(item.GetOrCreateObject("_"));
                }
            }
        }

ResetWatch()

override void ResetWatch ( )

protected

Attribute: i

.ArrModified = false;

Attribute: i

.Value != null)

Attribute: i

.Value.ResetWatch();

        {
            base.ResetWatch();
            for (int i=0; i<_items.Length; ++i)
            {
                _items[i].ArrModified = false;
                if (_items[i].Value != null)
                    _items[i].Value.ResetWatch();
            }
        }

TouchRecurse()

override void TouchRecurse ( )

protected

Attribute: i

.Value != null)

Attribute: i

.Value.TouchRecurse();

        {
            base.TouchRecurse();
            for (int i=0; i<_items.Length; ++i)
            {
                if (_items[i].Value != null)
                    _items[i].Value.TouchRecurse();
            }
        }