errors: remove TooManyOrphanedStreamIds variant from [Query/NewSessio…

…n]Error This is now included in `BrokenConnectionErrorKind`. Corresponding variant in [Query/NewSession]Error is never constructed.
scylladb · Sep 18, 2024 · acc5461 · acc5461
1 parent 09735bc
commit acc5461
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 10 deletions.
diff --git a/scylla/src/errors.rs b/scylla/src/errors.rs
@@ -71,9 +71,6 @@ pub enum QueryError {
     #[error("Timeout Error")]
     TimeoutError,
 
-    #[error("Too many orphaned stream ids: {0}")]
-    TooManyOrphanedStreamIds(u16),
-
     #[error(transparent)]
     BrokenConnection(#[from] BrokenConnectionError),
 
@@ -159,9 +156,6 @@ impl From<QueryError> for NewSessionError {
             QueryError::ProtocolError(m) => NewSessionError::ProtocolError(m),
             QueryError::InvalidMessage(m) => NewSessionError::InvalidMessage(m),
             QueryError::TimeoutError => NewSessionError::TimeoutError,
-            QueryError::TooManyOrphanedStreamIds(ids) => {
-                NewSessionError::TooManyOrphanedStreamIds(ids)
-            }
             QueryError::BrokenConnection(e) => NewSessionError::BrokenConnection(e),
             QueryError::UnableToAllocStreamId => NewSessionError::UnableToAllocStreamId,
             QueryError::RequestTimeout(msg) => NewSessionError::RequestTimeout(msg),
@@ -229,9 +223,6 @@ pub enum NewSessionError {
     #[error("Timeout Error")]
     TimeoutError,
 
-    #[error("Too many orphaned stream ids: {0}")]
-    TooManyOrphanedStreamIds(u16),
-
     #[error(transparent)]
     BrokenConnection(#[from] BrokenConnectionError),
 

diff --git a/scylla/src/transport/load_balancing/default.rs b/scylla/src/transport/load_balancing/default.rs
@@ -2843,7 +2843,6 @@ mod latency_awareness {
                 QueryError::BadQuery(_)
                 | QueryError::BrokenConnection(_)
                 | QueryError::ConnectionPoolError(_)
-                | QueryError::TooManyOrphanedStreamIds(_)
                 | QueryError::UnableToAllocStreamId
                 | QueryError::DbError(DbError::IsBootstrapping, _)
                 | QueryError::DbError(DbError::Unavailable { .. }, _)