@@ -72,7 +72,9 @@ impl<'config> WatchmanFileSource<'config> {
7272CompilerState :: deserialize_from_file ( saved_state_path)
7373} ) ?;
7474let query_timer = perf_logger_event. start ( "watchman_query_time" ) ;
75- let file_source_result =self . query_file_result ( compiler_state. clock . clone ( ) ) . await ?;
75+ let file_source_result =self
76+ . query_file_result ( compiler_state. clock . clone ( ) , false )
77+ . await ?;
7678 perf_logger_event. stop ( query_timer) ;
7779 compiler_state
7880. pending_file_source_changes
@@ -133,7 +135,7 @@ impl<'config> WatchmanFileSource<'config> {
133135perf_logger_event : & impl PerfLogEvent ,
134136perf_logger : & impl PerfLogger ,
135137) ->Result < CompilerState > {
136- let file_source_result =self . query_file_result ( None ) . await ?;
138+ let file_source_result =self . query_file_result ( None , false ) . await ?;
137139let compiler_state = perf_logger_event. time ( "from_file_source_changes" , ||{
138140CompilerState :: from_file_source_changes (
139141self . config ,
@@ -157,7 +159,9 @@ impl<'config> WatchmanFileSource<'config> {
157159let expression =get_watchman_expr ( self . config ) ;
158160
159161let query_timer = perf_logger_event. start ( "watchman_query_time_before_subscribe" ) ;
160- let file_source_result =self . query_file_result ( compiler_state. clock . clone ( ) ) . await ?;
162+ let file_source_result =self
163+ . query_file_result ( compiler_state. clock . clone ( ) , true )
164+ . await ?;
161165 perf_logger_event. stop ( query_timer) ;
162166
163167let query_timer = perf_logger_event. start ( "watchman_query_time_subscribe" ) ;
@@ -185,7 +189,11 @@ impl<'config> WatchmanFileSource<'config> {
185189
186190/// Internal method to issue a watchman query, returning a raw
187191/// WatchmanFileSourceResult.
188- async fn query_file_result ( & self , since_clock : Option < Clock > ) ->Result < FileSourceResult > {
192+ async fn query_file_result (
193+ & self ,
194+ since_clock : Option < Clock > ,
195+ omit_changed_files : bool ,
196+ ) ->Result < FileSourceResult > {
189197let expression =get_watchman_expr ( self . config ) ;
190198debug ! (
191199"WatchmanFileSource::query_file_result(...) get_watchman_expr = {:?}" ,
@@ -197,6 +205,8 @@ impl<'config> WatchmanFileSource<'config> {
197205// passed as the request params
198206let request =if since_clock. is_some ( ) {
199207QueryRequestCommon {
208+ omit_changed_files,
209+ empty_on_fresh_instance : omit_changed_files,
200210expression : Some ( expression) ,
201211since : since_clock,
202212 ..Default :: default ( )
@@ -207,6 +217,8 @@ impl<'config> WatchmanFileSource<'config> {
207217. map ( PathGeneratorElement :: RecursivePath )
208218. collect ( ) ;
209219QueryRequestCommon {
220+ omit_changed_files,
221+ empty_on_fresh_instance : omit_changed_files,
210222expression : Some ( expression) ,
211223path : Some ( query_roots) ,
212224 ..Default :: default ( )
@@ -257,7 +269,7 @@ impl<'config> WatchmanFileSource<'config> {
257269) ;
258270let query_timer = perf_logger_event. start ( "watchman_query_time_try_saved_state" ) ;
259271let file_source_result =self
260- . query_file_result ( Some ( scm_since) )
272+ . query_file_result ( Some ( scm_since) , false )
261273. await
262274. map_err ( |_|"query failed" ) ?;
263275 perf_logger_event. stop ( query_timer) ;