@@ -148,17 +148,20 @@ public int CheckAndProcessEvents()
148
148
149
149
if ( fileEvents . Length > 0 )
150
150
{
151
- Logger . Trace ( "Processing {0} Events" , fileEvents . Length ) ;
152
- ProcessEvents ( fileEvents ) ;
151
+ Logger . Trace ( "Handling {0} Events" , fileEvents . Length ) ;
152
+ var processedEventCount = ProcessEvents ( fileEvents ) ;
153
+ lastCountOfProcessedEvents = processedEventCount ;
154
+ Logger . Trace ( "Processed {0} Events" , processedEventCount ) ;
153
155
}
154
156
155
157
processingEvents = false ;
156
158
signalProcessingEventsDone . Set ( ) ;
157
159
return lastCountOfProcessedEvents ;
158
160
}
159
161
160
- private void ProcessEvents ( Event [ ] fileEvents )
162
+ private int ProcessEvents ( Event [ ] fileEvents )
161
163
{
164
+ var eventsProcessed = 0 ;
162
165
var configChanged = false ;
163
166
var headChanged = false ;
164
167
var repositoryChanged = false ;
@@ -195,9 +198,8 @@ private void ProcessEvents(Event[] fileEvents)
195
198
{
196
199
if ( fileA . Equals ( paths . DotGitConfig ) )
197
200
{
198
- Logger . Trace ( "ConfigChanged" ) ;
199
-
200
201
configChanged = true ;
202
+ eventsProcessed ++ ;
201
203
}
202
204
else if ( fileA . Equals ( paths . DotGitHead ) )
203
205
{
@@ -206,13 +208,13 @@ private void ProcessEvents(Event[] fileEvents)
206
208
headContent = paths . DotGitHead . ReadAllLines ( ) . FirstOrDefault ( ) ;
207
209
}
208
210
209
- Logger . Trace ( "HeadChanged: {0}" , headContent ?? "[null]" ) ;
210
211
headChanged = true ;
212
+ eventsProcessed ++ ;
211
213
}
212
214
else if ( fileA . Equals ( paths . DotGitIndex ) )
213
215
{
214
- Logger . Trace ( "IndexChanged" ) ;
215
216
indexChanged = true ;
217
+ eventsProcessed ++ ;
216
218
}
217
219
else if ( fileA . IsChildOf ( paths . RemotesPath ) )
218
220
{
@@ -237,6 +239,7 @@ private void ProcessEvents(Event[] fileEvents)
237
239
238
240
Logger . Trace ( "RemoteBranchDeleted: {0}/{1}" , origin , branch ) ;
239
241
RemoteBranchDeleted ? . Invoke ( origin , branch ) ;
242
+ eventsProcessed ++ ;
240
243
}
241
244
else if ( fileEvent . Type == EventType . RENAMED )
242
245
{
@@ -257,6 +260,7 @@ private void ProcessEvents(Event[] fileEvents)
257
260
258
261
Logger . Trace ( "RemoteBranchCreated: {0}/{1}" , origin , branch ) ;
259
262
RemoteBranchCreated ? . Invoke ( origin , branch ) ;
263
+ eventsProcessed ++ ;
260
264
}
261
265
}
262
266
}
@@ -287,6 +291,7 @@ private void ProcessEvents(Event[] fileEvents)
287
291
288
292
Logger . Trace ( "LocalBranchChanged: {0}" , branch ) ;
289
293
LocalBranchChanged ? . Invoke ( branch ) ;
294
+ eventsProcessed ++ ;
290
295
}
291
296
else if ( fileEvent . Type == EventType . DELETED )
292
297
{
@@ -307,6 +312,7 @@ private void ProcessEvents(Event[] fileEvents)
307
312
308
313
Logger . Trace ( "LocalBranchDeleted: {0}" , branch ) ;
309
314
LocalBranchDeleted ? . Invoke ( branch ) ;
315
+ eventsProcessed ++ ;
310
316
}
311
317
else if ( fileEvent . Type == EventType . RENAMED )
312
318
{
@@ -331,6 +337,7 @@ private void ProcessEvents(Event[] fileEvents)
331
337
332
338
Logger . Trace ( "LocalBranchCreated: {0}" , branch ) ;
333
339
LocalBranchCreated ? . Invoke ( branch ) ;
340
+ eventsProcessed ++ ;
334
341
}
335
342
}
336
343
}
@@ -344,9 +351,8 @@ private void ProcessEvents(Event[] fileEvents)
344
351
}
345
352
346
353
repositoryChanged = true ;
354
+ eventsProcessed ++ ;
347
355
}
348
-
349
- lastCountOfProcessedEvents ++ ;
350
356
}
351
357
352
358
if ( configChanged )
@@ -357,7 +363,7 @@ private void ProcessEvents(Event[] fileEvents)
357
363
358
364
if ( headChanged )
359
365
{
360
- Logger . Trace ( "ConfigChanged " ) ;
366
+ Logger . Trace ( "HeadChanged: {0}" , headContent ?? "[null] ") ;
361
367
HeadChanged ? . Invoke ( headContent ) ;
362
368
}
363
369
@@ -372,6 +378,8 @@ private void ProcessEvents(Event[] fileEvents)
372
378
Logger . Trace ( "RepositoryChanged" ) ;
373
379
RepositoryChanged ? . Invoke ( ) ;
374
380
}
381
+
382
+ return eventsProcessed ;
375
383
}
376
384
377
385
private bool disposed ;
0 commit comments