Skip to content
Merged
Changes from 1 commit
Commits
Show all changes
37 commits
Select commit Hold shift + click to select a range
2cdf16b
Code changes to support binary encoding for point operations.
kundadebdatta Aug 23, 2024
387005b
Merge branch 'master' into users/dkunda/4644_binary_encoding_for_poin…
kundadebdatta Sep 18, 2024
c0e5952
Code changes to introduce cosmos buffered stream wrapper.
kundadebdatta Sep 25, 2024
07eff74
Code changes to remove unnecessary using statement.
kundadebdatta Sep 25, 2024
265a7d3
Code changes to remove the pooling logic.
kundadebdatta Sep 25, 2024
bcdc75e
Code changes to port fixes into newtonsoft reader and writer to addre…
kundadebdatta Sep 25, 2024
4e35d0f
Code changes to set inner stream on disposal of buffered stream.
kundadebdatta Sep 26, 2024
4ac933f
Minor cosmetic code changes.
kundadebdatta Sep 26, 2024
8033075
Code changes to use clonable stream instead of buffered stream.
kundadebdatta Sep 27, 2024
4359dc8
Revert "Code changes to use clonable stream instead of buffered stream."
kundadebdatta Oct 1, 2024
88d5431
Code changes to use clonable stream from request handler when the out…
kundadebdatta Oct 2, 2024
abbcb11
Merge branch 'master' into users/dkunda/4644_binary_encoding_for_poin…
kundadebdatta Oct 2, 2024
16583c3
Code changes to address review comments.
kundadebdatta Oct 2, 2024
b3da27d
Merge branch 'master' into users/dkunda/4644_binary_encoding_for_poin…
kundadebdatta Oct 2, 2024
7fc7407
Merge branch 'master' into users/dkunda/4644_binary_encoding_for_poin…
kundadebdatta Oct 3, 2024
c275cf1
Code changes to fix test failures.
kundadebdatta Oct 3, 2024
da1f135
Merge branch 'master' into users/dkunda/4644_binary_encoding_for_poin…
kundadebdatta Oct 7, 2024
fbf9ffc
Code changes to address review comments.
kundadebdatta Oct 7, 2024
96c8581
Adding more stream tests.
kundadebdatta Oct 7, 2024
2baa15c
Code changes to fix batch item emulator tests.
kundadebdatta Oct 7, 2024
a97101a
Code changes to use cloneable stream in buffered stream.
kundadebdatta Oct 9, 2024
6981e01
Merge branch 'master' into users/dkunda/4644_binary_encoding_for_poin…
kundadebdatta Oct 9, 2024
9ed19b6
Code changes to fix build failures.
kundadebdatta Oct 9, 2024
dbc9596
Code changes to match ContainerCore.Items to master
kundadebdatta Oct 9, 2024
3929404
Code changes to fix build failures.
kundadebdatta Oct 9, 2024
b8151e0
Merge branch 'master' into users/dkunda/4644_binary_encoding_for_poin…
kundadebdatta Oct 9, 2024
cc67f67
Code changes to address review comments.
kundadebdatta Oct 10, 2024
de8aab6
Merge branch 'master' into users/dkunda/4644_binary_encoding_for_poin…
kundadebdatta Oct 10, 2024
d72dbe7
Merge branch 'master' into users/dkunda/4644_binary_encoding_for_poin…
kundadebdatta Oct 10, 2024
c932a1f
Merge branch 'master' into users/dkunda/4644_binary_encoding_for_poin…
kundadebdatta Oct 10, 2024
8855ebd
Code changes to fix container creation using binary encoding.
kundadebdatta Oct 16, 2024
7009570
Merge branch 'master' into users/dkunda/4644_binary_encoding_for_poin…
kundadebdatta Oct 18, 2024
f67ae93
Code changes to add internal types in a common place.
kundadebdatta Oct 18, 2024
b2b6af7
Merge branch 'master' into users/dkunda/4644_binary_encoding_for_poin…
kundadebdatta Oct 22, 2024
aea8a3a
Merge branch 'master' into users/dkunda/4644_binary_encoding_for_poin…
kundadebdatta Oct 23, 2024
3245664
Code changes to remove ContentSerializationFormat. Addressing minor r…
kundadebdatta Oct 23, 2024
cce11dd
Merge branch 'master' into users/dkunda/4644_binary_encoding_for_poin…
kundadebdatta Oct 23, 2024
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Code changes to remove the pooling logic.
  • Loading branch information
kundadebdatta committed Sep 25, 2024
commit 265a7d3bf5dc2df1ca1b4ea3aee9917c7b0ad617
Original file line number Diff line number Diff line change
Expand Up @@ -231,27 +231,5 @@ private void ReadFirstByte()
this.hasReadFirstByte = true;
}
}

internal class ObjectPool<T>
{
private readonly ConcurrentBag<T> Objects;
private readonly Func<T> ObjectGenerator;

public ObjectPool(Func<T> objectGenerator)
{
this.ObjectGenerator = objectGenerator ?? throw new ArgumentNullException(nameof(objectGenerator));
this.Objects = new ConcurrentBag<T>();
}

public T Get()
{
return this.Objects.TryTake(out T item) ? item : this.ObjectGenerator();
}

public void Return(T item)
{
this.Objects.Add(item);
}
}
}
}