@@ -39,6 +39,7 @@ pub(crate) use crate::unix::RawOp;
39
39
pub enum OpEntry {
40
40
/// This operation creates an io-uring submission entry.
41
41
Submission ( io_uring:: squeue:: Entry ) ,
42
+ #[ cfg( feature = "io-uring-sqe128" ) ]
42
43
/// This operation creates an 128-bit io-uring submission entry.
43
44
Submission128 ( io_uring:: squeue:: Entry128 ) ,
44
45
/// This operation is a blocking one.
@@ -51,6 +52,7 @@ impl From<io_uring::squeue::Entry> for OpEntry {
51
52
}
52
53
}
53
54
55
+ #[ cfg( feature = "io-uring-sqe128" ) ]
54
56
impl From < io_uring:: squeue:: Entry128 > for OpEntry {
55
57
fn from ( value : io_uring:: squeue:: Entry128 ) -> Self {
56
58
Self :: Submission128 ( value)
@@ -210,19 +212,10 @@ impl Driver {
210
212
. push_back ( entry. user_data ( user_data as _ ) . into ( ) ) ;
211
213
Poll :: Pending
212
214
}
215
+ #[ cfg( feature = "io-uring-sqe128" ) ]
213
216
OpEntry :: Submission128 ( _entry) => {
214
- #[ cfg( feature = "io-uring-sqe128" ) ]
215
- {
216
- self . squeue . push_back ( _entry. user_data ( user_data as _ ) ) ;
217
- Poll :: Pending
218
- }
219
- #[ cfg( not( feature = "io-uring-sqe128" ) ) ]
220
- {
221
- Poll :: Ready ( Err ( io:: Error :: new (
222
- io:: ErrorKind :: Unsupported ,
223
- "submission entry 128 is not enabled" ,
224
- ) ) )
225
- }
217
+ self . squeue . push_back ( _entry. user_data ( user_data as _ ) ) ;
218
+ Poll :: Pending
226
219
}
227
220
OpEntry :: Blocking => {
228
221
if self . push_blocking ( user_data, op) ? {
0 commit comments