You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sf...@apache.org on 2015/03/09 16:14:34 UTC
[17/30] incubator-usergrid git commit: changing buffer impl to queue
changing buffer impl to queue
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/6066b6e9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/6066b6e9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/6066b6e9
Branch: refs/heads/two-dot-o
Commit: 6066b6e98e3f3324858d8812fb607bf77b37f9a8
Parents: 5ad1a8c
Author: Shawn Feldman <sf...@apache.org>
Authored: Fri Mar 6 15:50:48 2015 -0700
Committer: Shawn Feldman <sf...@apache.org>
Committed: Fri Mar 6 15:50:48 2015 -0700
----------------------------------------------------------------------
.../notifications/Usergrid.Notifications/MainPage.xaml.cs | 8 ++++----
.../persistence/index/impl/EsIndexBufferConsumerImpl.java | 2 --
2 files changed, 4 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/6066b6e9/sdks/dotnet/samples/notifications/Usergrid.Notifications/MainPage.xaml.cs
----------------------------------------------------------------------
diff --git a/sdks/dotnet/samples/notifications/Usergrid.Notifications/MainPage.xaml.cs b/sdks/dotnet/samples/notifications/Usergrid.Notifications/MainPage.xaml.cs
index ccef239..2120eeb 100644
--- a/sdks/dotnet/samples/notifications/Usergrid.Notifications/MainPage.xaml.cs
+++ b/sdks/dotnet/samples/notifications/Usergrid.Notifications/MainPage.xaml.cs
@@ -44,7 +44,7 @@ namespace Usergrid.Notifications
{
this.InitializeComponent();
//TODO: change me to your server
- serverUrl = "http://10.0.1.20:8080/";
+ serverUrl = "http://server/";
//TODO: change me to your org
org = "test-organization";
//TODO: change me to your app
@@ -52,9 +52,9 @@ namespace Usergrid.Notifications
//TODO: change me to your notifier name
notifier = "windows";
//TODO: change me to your user
- user = "mobileuser";
+ user = "test";
//TODO: change me to your password
- password = "P@ssw0rd1";
+ password = "test";
this.NavigationCacheMode = NavigationCacheMode.Required;
usergrid = new Client.Usergrid(serverUrl, org, app, user, password, notifier);
@@ -79,7 +79,7 @@ namespace Usergrid.Notifications
// If you are using the NavigationHelper provided by some templates,
// this event is handled for you.
}
-
+
private void pushText_TextChanged(object sender, TextChangedEventArgs e)
{
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/6066b6e9/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java
index 625f4e7..d952d78 100644
--- a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java
+++ b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java
@@ -93,7 +93,6 @@ public class EsIndexBufferConsumerImpl implements IndexBufferConsumer {
if(polled!=null) {
drainList.add(polled);
producerQueue.drainTo(drainList, config.getIndexBufferSize());
- System.out.println("Consumer Thread" + Thread.currentThread().getName());
for(IndexOperationMessage drained : drainList){
subscriber.onNext(drained);
}
@@ -116,7 +115,6 @@ public class EsIndexBufferConsumerImpl implements IndexBufferConsumer {
.doOnNext(new Action1<List<IndexOperationMessage>>() {
@Override
public void call(List<IndexOperationMessage> containerList) {
- System.out.println("Buffered Consumer Thread" + Thread.currentThread().getName());
if (containerList.size() > 0) {
flushMeter.mark(containerList.size());
Timer.Context time = flushTimer.time();