Line data    Source code

       1              : // Copyright 2012 The LevelDB-Go and Pebble Authors. All rights reserved. Use
       2              : // of this source code is governed by a BSD-style license that can be found in
       3              : // the LICENSE file.
       4              : 
       5              : package pebble
       6              : 
       7              : // JobID identifies a job (like a compaction). Job IDs are passed to event
       8              : // listener notifications and act as a mechanism for tying together the events
       9              : // and log messages for a single job such as a flush, compaction, or file
      10              : // ingestion. Job IDs are not serialized to disk or used for correctness.
      11              : type JobID int
      12              : 
      13              : // newJobIDLocked returns a new JobID; DB.mu must be held.
      14            1 : func (d *DB) newJobIDLocked() JobID {
      15            1 :         res := d.mu.nextJobID
      16            1 :         d.mu.nextJobID++
      17            1 :         return res
      18            1 : }
      19              : 
      20            1 : func (d *DB) newJobID() JobID {
      21            1 :         d.mu.Lock()
      22            1 :         defer d.mu.Unlock()
      23            1 :         return d.newJobIDLocked()
      24            1 : }