System.Data.SQLite
Check-in [812f16fdb8]
Not logged in

Many hyperlinks are disabled.
Use anonymous login to enable hyperlinks.

Overview
Comment:More spacing cleanup.
Downloads: Tarball | ZIP archive | SQL archive
Timelines: family | ancestors | descendants | both | sessions
Files: files | file ages | folders
SHA1: 812f16fdb88a4495fdda71a4b15c5a50b3930315
User & Date: mistachkin 2017-10-06 20:07:47
Context
2017-10-06
20:53
Further refinements to IDisposable handling. check-in: cc900bbb35 user: mistachkin tags: sessions
20:07
More spacing cleanup. check-in: 812f16fdb8 user: mistachkin tags: sessions
20:03
Cleanup regions. check-in: 31aaba7c78 user: mistachkin tags: sessions
Changes
Hide Diffs Unified Diffs Ignore Whitespace Patch

Changes to System.Data.SQLite/SQLiteSession.cs.

1499
1500
1501
1502
1503
1504
1505



1506
1507
1508
1509
1510
1511
1512
....
1536
1537
1538
1539
1540
1541
1542


1543
1544
1545
1546
1547
1548
1549
....
1570
1571
1572
1573
1574
1575
1576



1577
1578
1579
1580
1581
1582
1583
....
1813
1814
1815
1816
1817
1818
1819



1820
1821
1822
1823
1824
1825
1826
....
1846
1847
1848
1849
1850
1851
1852


1853
1854
1855
1856
1857
1858
1859
....
1881
1882
1883
1884
1885
1886
1887



1888
1889
1890
1891
1892
1893
1894
        {
            CheckDisposed();
            CheckRawData();

            if (conflictCallback == null)
                throw new ArgumentNullException("conflictCallback");




            UnsafeNativeMethods.xSessionFilter xFilter = null;

            if (tableFilterCallback != null)
            {
                xFilter = new UnsafeNativeMethods.xSessionFilter(
                    delegate(IntPtr context, byte[] tblName)
                {
................................................................................
                        }
                    }

                    return 0;
                });
            }



            UnsafeNativeMethods.xSessionConflict xConflict;

            xConflict = new UnsafeNativeMethods.xSessionConflict(
                delegate(IntPtr context,
                         SQLiteChangeSetConflictType type,
                         IntPtr iterator)
            {
................................................................................
                    {
                        // do nothing.
                    }
                }

                return SQLiteChangeSetConflictResult.Abort;
            });




            IntPtr pData = IntPtr.Zero;

            try
            {
                int nData = 0;

................................................................................
            SessionTableFilterCallback tableFilterCallback,
            object clientData
            )
        {
            CheckDisposed();
            CheckInputStream();




            UnsafeNativeMethods.xSessionFilter xFilter;

            xFilter = new UnsafeNativeMethods.xSessionFilter(
                delegate(IntPtr context, byte[] tblName)
            {
                try
                {
................................................................................
                    {
                        // do nothing.
                    }
                }

                return 0;
            });



            UnsafeNativeMethods.xSessionConflict xConflict;

            xConflict = new UnsafeNativeMethods.xSessionConflict(
                delegate(IntPtr context,
                         SQLiteChangeSetConflictType type,
                         IntPtr iterator)
................................................................................
                    {
                        // do nothing.
                    }
                }

                return SQLiteChangeSetConflictResult.Abort;
            });




            SQLiteErrorCode rc = UnsafeNativeMethods.sqlite3changeset_apply_strm(
                handle, new SQLiteStreamAdapter(inputStream, flags).xInput,
                IntPtr.Zero, xFilter, xConflict, IntPtr.Zero);

            if (rc != SQLiteErrorCode.Ok)
                throw new SQLiteException(rc, "sqlite3changeset_apply_strm");







>
>
>







 







>
>







 







>
>
>







 







>
>
>







 







>
>







 







>
>
>







1499
1500
1501
1502
1503
1504
1505
1506
1507
1508
1509
1510
1511
1512
1513
1514
1515
....
1539
1540
1541
1542
1543
1544
1545
1546
1547
1548
1549
1550
1551
1552
1553
1554
....
1575
1576
1577
1578
1579
1580
1581
1582
1583
1584
1585
1586
1587
1588
1589
1590
1591
....
1821
1822
1823
1824
1825
1826
1827
1828
1829
1830
1831
1832
1833
1834
1835
1836
1837
....
1857
1858
1859
1860
1861
1862
1863
1864
1865
1866
1867
1868
1869
1870
1871
1872
....
1894
1895
1896
1897
1898
1899
1900
1901
1902
1903
1904
1905
1906
1907
1908
1909
1910
        {
            CheckDisposed();
            CheckRawData();

            if (conflictCallback == null)
                throw new ArgumentNullException("conflictCallback");

            ///////////////////////////////////////////////////////////////////

            #region Native Callback Methods
            UnsafeNativeMethods.xSessionFilter xFilter = null;

            if (tableFilterCallback != null)
            {
                xFilter = new UnsafeNativeMethods.xSessionFilter(
                    delegate(IntPtr context, byte[] tblName)
                {
................................................................................
                        }
                    }

                    return 0;
                });
            }

            ///////////////////////////////////////////////////////////////////

            UnsafeNativeMethods.xSessionConflict xConflict;

            xConflict = new UnsafeNativeMethods.xSessionConflict(
                delegate(IntPtr context,
                         SQLiteChangeSetConflictType type,
                         IntPtr iterator)
            {
................................................................................
                    {
                        // do nothing.
                    }
                }

                return SQLiteChangeSetConflictResult.Abort;
            });
            #endregion

            ///////////////////////////////////////////////////////////////////

            IntPtr pData = IntPtr.Zero;

            try
            {
                int nData = 0;

................................................................................
            SessionTableFilterCallback tableFilterCallback,
            object clientData
            )
        {
            CheckDisposed();
            CheckInputStream();

            ///////////////////////////////////////////////////////////////////

            #region Native Callback Methods
            UnsafeNativeMethods.xSessionFilter xFilter;

            xFilter = new UnsafeNativeMethods.xSessionFilter(
                delegate(IntPtr context, byte[] tblName)
            {
                try
                {
................................................................................
                    {
                        // do nothing.
                    }
                }

                return 0;
            });

            ///////////////////////////////////////////////////////////////////

            UnsafeNativeMethods.xSessionConflict xConflict;

            xConflict = new UnsafeNativeMethods.xSessionConflict(
                delegate(IntPtr context,
                         SQLiteChangeSetConflictType type,
                         IntPtr iterator)
................................................................................
                    {
                        // do nothing.
                    }
                }

                return SQLiteChangeSetConflictResult.Abort;
            });
            #endregion

            ///////////////////////////////////////////////////////////////////

            SQLiteErrorCode rc = UnsafeNativeMethods.sqlite3changeset_apply_strm(
                handle, new SQLiteStreamAdapter(inputStream, flags).xInput,
                IntPtr.Zero, xFilter, xConflict, IntPtr.Zero);

            if (rc != SQLiteErrorCode.Ok)
                throw new SQLiteException(rc, "sqlite3changeset_apply_strm");