@@ -108,9 +108,11 @@ public int getSize() {
108
108
*/
109
109
void enqueue (ServerRequest request ) {
110
110
synchronized (reqQueueLockObject ) {
111
+ BranchLogger .v ("Queue operation enqueue. Request: " + request );
111
112
if (request != null ) {
112
113
queue .add (request );
113
114
if (getSize () >= MAX_ITEMS ) {
115
+ BranchLogger .v ("Queue maxed out. Removing index 1." );
114
116
queue .remove (1 );
115
117
}
116
118
}
@@ -163,6 +165,7 @@ ServerRequest peekAt(int index) {
163
165
synchronized (reqQueueLockObject ) {
164
166
try {
165
167
req = queue .get (index );
168
+ BranchLogger .v ("Queue operation peekAt " + req );
166
169
} catch (IndexOutOfBoundsException | NoSuchElementException e ) {
167
170
BranchLogger .e ("Caught Exception ServerRequestQueue peekAt " + index + ": " + e .getMessage ());
168
171
}
@@ -182,6 +185,7 @@ ServerRequest peekAt(int index) {
182
185
void insert (ServerRequest request , int index ) {
183
186
synchronized (reqQueueLockObject ) {
184
187
try {
188
+ BranchLogger .v ("Queue operation insert. Request: " + request + " Size: " + queue .size () + " Index: " + index );
185
189
if (queue .size () < index ) {
186
190
index = queue .size ();
187
191
}
@@ -213,7 +217,7 @@ public ServerRequest removeAt(int index) {
213
217
}
214
218
return req ;
215
219
}
216
-
220
+
217
221
/**
218
222
* <p>As the method name implies, removes {@link ServerRequest} supplied in the parameter if it
219
223
* is present in the queue.</p>
@@ -225,7 +229,9 @@ public boolean remove(ServerRequest request) {
225
229
boolean isRemoved = false ;
226
230
synchronized (reqQueueLockObject ) {
227
231
try {
232
+ BranchLogger .v ("Queue operation remove. Request: " + request );
228
233
isRemoved = queue .remove (request );
234
+ BranchLogger .v ("Queue operation remove. Removed: " + isRemoved );
229
235
} catch (UnsupportedOperationException e ) {
230
236
BranchLogger .e ("Caught UnsupportedOperationException " + e .getMessage ());
231
237
}
@@ -239,7 +245,9 @@ public boolean remove(ServerRequest request) {
239
245
void clear () {
240
246
synchronized (reqQueueLockObject ) {
241
247
try {
248
+ BranchLogger .v ("Queue operation clear" );
242
249
queue .clear ();
250
+ BranchLogger .v ("Queue cleared." );
243
251
} catch (UnsupportedOperationException e ) {
244
252
BranchLogger .e ("Caught UnsupportedOperationException " + e .getMessage ());
245
253
}
@@ -259,6 +267,7 @@ ServerRequestInitSession getSelfInitRequest() {
259
267
BranchLogger .v ("Checking if " + req + " is instanceof ServerRequestInitSession" );
260
268
if (req instanceof ServerRequestInitSession ) {
261
269
ServerRequestInitSession r = (ServerRequestInitSession ) req ;
270
+ BranchLogger .v (r + " is initiated by client: " + r .initiatedByClient );
262
271
if (r .initiatedByClient ) {
263
272
return r ;
264
273
}
@@ -324,11 +333,13 @@ void processNextQueueItem(String callingMethodName) {
324
333
if (!(req instanceof ServerRequestRegisterInstall ) && !hasUser ()) {
325
334
BranchLogger .d ("Branch Error: User session has not been initialized!" );
326
335
networkCount_ = 0 ;
336
+ BranchLogger .v ("Invoking " + req + " handleFailure. Has no session. hasUser: " + hasUser ());
327
337
req .handleFailure (BranchError .ERR_NO_SESSION , "Request " + req + " has no session." );
328
338
}
329
339
// Determine if a session is needed to execute (SDK-271)
330
340
else if (requestNeedsSession (req ) && !isSessionAvailableForRequest ()) {
331
341
networkCount_ = 0 ;
342
+ BranchLogger .v ("Invoking " + req + " handleFailure. Has no session." );
332
343
req .handleFailure (BranchError .ERR_NO_SESSION , "Request " + req + " has no session." );
333
344
} else {
334
345
executeTimedBranchPostTask (req , Branch .getInstance ().prefHelper_ .getTaskTimeout ());
@@ -351,7 +362,7 @@ else if (requestNeedsSession(req) && !isSessionAvailableForRequest()) {
351
362
}
352
363
353
364
void insertRequestAtFront (ServerRequest req ) {
354
- BranchLogger .v ("insertRequestAtFront " + req + " networkCount_: " + networkCount_ );
365
+ BranchLogger .v ("Queue operation insertRequestAtFront " + req + " networkCount_: " + networkCount_ );
355
366
if (networkCount_ == 0 ) {
356
367
this .insert (req , 0 );
357
368
} else {
@@ -393,6 +404,7 @@ void updateAllRequestsInQueue() {
393
404
try {
394
405
for (int i = 0 ; i < this .getSize (); i ++) {
395
406
ServerRequest req = this .peekAt (i );
407
+ BranchLogger .v ("Queue operation updateAllRequestsInQueue updating: " + req );
396
408
if (req != null ) {
397
409
JSONObject reqJson = req .getPost ();
398
410
if (reqJson != null ) {
0 commit comments