@@ -279,15 +279,24 @@ func (d MonitoredDatastore) StopMessageProcessor() {
279279}
280280
281281func (d MonitoredDatastore ) StoreFile (ctx context.Context , service , name string , data io.Reader ) error {
282- return d .D .StoreFile (ctx , service , name , data )
282+ s := ftime .Now ()
283+ err := d .D .StoreFile (ctx , service , name , data )
284+ d .C .DatastoreOperation (s , ftime .Now (), "StoreFile" , err )
285+ return err
283286}
284287
285288func (d MonitoredDatastore ) StatFile (ctx context.Context , service , name string ) (time.Time , error ) {
286- return d .D .StatFile (ctx , service , name )
289+ s := ftime .Now ()
290+ res , err := d .D .StatFile (ctx , service , name )
291+ d .C .DatastoreOperation (s , ftime .Now (), "StatFile" , err )
292+ return res , err
287293}
288294
289295func (d MonitoredDatastore ) ReadFile (ctx context.Context , service , name string ) (db.ReadSeekerCloser , time.Time , error ) {
290- return d .D .ReadFile (ctx , service , name )
296+ s := ftime .Now ()
297+ res , t , err := d .D .ReadFile (ctx , service , name )
298+ d .C .DatastoreOperation (s , ftime .Now (), "ReadFile" , err )
299+ return res , t , err
291300}
292301
293302func (d MonitoredDatastore ) IsNotFound (err error ) bool {
0 commit comments