summaryrefslogtreecommitdiffstats
path: root/networking-odl/networking_odl/db/db.py
diff options
context:
space:
mode:
Diffstat (limited to 'networking-odl/networking_odl/db/db.py')
-rw-r--r--networking-odl/networking_odl/db/db.py71
1 files changed, 0 insertions, 71 deletions
diff --git a/networking-odl/networking_odl/db/db.py b/networking-odl/networking_odl/db/db.py
index 31f4ce2..a8e7ade 100644
--- a/networking-odl/networking_odl/db/db.py
+++ b/networking-odl/networking_odl/db/db.py
@@ -12,8 +12,6 @@
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
# License for the specific language governing permissions and limitations
# under the License.
-import datetime
-
from sqlalchemy import asc
from sqlalchemy import func
from sqlalchemy import or_
@@ -163,72 +161,3 @@ def create_pending_row(session, object_type, object_uuid,
# Keep session flush for unit tests. NOOP for L2/L3 events since calls are
# made inside database session transaction with subtransactions=True.
session.flush()
-
-
-@db_api.retry_db_errors
-def delete_pending_rows(session, operations_to_delete):
- with session.begin():
- session.query(models.OpendaylightJournal).filter(
- models.OpendaylightJournal.operation.in_(operations_to_delete),
- models.OpendaylightJournal.state == odl_const.PENDING).delete(
- synchronize_session=False)
- session.expire_all()
-
-
-@db_api.retry_db_errors
-def _update_maintenance_state(session, expected_state, state):
- with session.begin():
- row = session.query(models.OpendaylightMaintenance).filter_by(
- state=expected_state).with_for_update().one_or_none()
- if row is None:
- return False
-
- row.state = state
- return True
-
-
-def lock_maintenance(session):
- return _update_maintenance_state(session, odl_const.PENDING,
- odl_const.PROCESSING)
-
-
-def unlock_maintenance(session):
- return _update_maintenance_state(session, odl_const.PROCESSING,
- odl_const.PENDING)
-
-
-def update_maintenance_operation(session, operation=None):
- """Update the current maintenance operation details.
-
- The function assumes the lock is held, so it mustn't be run outside of a
- locked context.
- """
- op_text = None
- if operation:
- op_text = operation.__name__
-
- with session.begin():
- row = session.query(models.OpendaylightMaintenance).one_or_none()
- row.processing_operation = op_text
-
-
-def delete_rows_by_state_and_time(session, state, time_delta):
- with session.begin():
- now = session.execute(func.now()).scalar()
- session.query(models.OpendaylightJournal).filter(
- models.OpendaylightJournal.state == state,
- models.OpendaylightJournal.last_retried < now - time_delta).delete(
- synchronize_session=False)
- session.expire_all()
-
-
-def reset_processing_rows(session, max_timedelta):
- with session.begin():
- now = session.execute(func.now()).scalar()
- max_timedelta = datetime.timedelta(seconds=max_timedelta)
- rows = session.query(models.OpendaylightJournal).filter(
- models.OpendaylightJournal.last_retried < now - max_timedelta,
- models.OpendaylightJournal.state == odl_const.PROCESSING,
- ).update({'state': odl_const.PENDING})
-
- return rows