Skip to content

Commit d87f917

Browse files
committed
Renamed unpack_row() -> unpack_plain_row(), unpack_ce_row() -> unpack_col_encrypted_row()
Per review comments. Signed-off-by: Yaniv Kaul <yaniv.kaul@scylladb.com>
1 parent d67815c commit d87f917

5 files changed

Lines changed: 14 additions & 14 deletions

File tree

cassandra/numpy_parser.pyx

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,7 @@ cdef _parse_rows(BytesIOReader reader, ParseDesc desc,
9797
cdef Py_ssize_t i
9898

9999
for i in range(rowcount):
100-
unpack_row(reader, desc, arrs)
100+
unpack_plain_row(reader, desc, arrs)
101101

102102

103103
### Helper functions to create NumPy arrays and array descriptors
@@ -144,7 +144,7 @@ def make_array(coltype, array_size):
144144

145145
@cython.boundscheck(False)
146146
@cython.wraparound(False)
147-
cdef inline int unpack_row(
147+
cdef inline int unpack_plain_row(
148148
BytesIOReader reader, ParseDesc desc, ArrDesc *arrays) except -1:
149149
cdef Buffer buf
150150
cdef Py_ssize_t i, rowsize = desc.rowsize

cassandra/obj_parser.pyx

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -32,9 +32,9 @@ cdef class ListParser(ColumnParser):
3232
rowcount = read_int(reader)
3333
cdef RowParser rowparser = TupleRowParser()
3434
if desc.column_encryption_policy:
35-
return [rowparser.unpack_ce_row(reader, desc) for i in range(rowcount)]
35+
return [rowparser.unpack_col_encrypted_row(reader, desc) for i in range(rowcount)]
3636
else:
37-
return [rowparser.unpack_row(reader, desc) for i in range(rowcount)]
37+
return [rowparser.unpack_plain_row(reader, desc) for i in range(rowcount)]
3838

3939

4040
cdef class LazyParser(ColumnParser):
@@ -51,21 +51,21 @@ def parse_rows_lazy(BytesIOReader reader, ParseDesc desc):
5151
rowcount = read_int(reader)
5252
cdef RowParser rowparser = TupleRowParser()
5353
if desc.column_encryption_policy:
54-
return (rowparser.unpack_ce_row(reader, desc) for i in range(rowcount))
54+
return (rowparser.unpack_col_encrypted_row(reader, desc) for i in range(rowcount))
5555
else:
56-
return (rowparser.unpack_row(reader, desc) for i in range(rowcount))
56+
return (rowparser.unpack_plain_row(reader, desc) for i in range(rowcount))
5757

5858

5959
cdef class TupleRowParser(RowParser):
6060
"""
6161
Parse a single returned row into a tuple of objects:
6262
6363
(obj1, ..., objN)
64-
If CE (Column encryption) policy is enabled - use unpack_ce_row(),
65-
otherwsise use unpack_row()
64+
If CE (Column encryption) policy is enabled - use unpack_col_encrypted_row(),
65+
otherwsise use unpack_plain_row()
6666
"""
6767

68-
cpdef unpack_ce_row(self, BytesIOReader reader, ParseDesc desc):
68+
cpdef unpack_col_encrypted_row(self, BytesIOReader reader, ParseDesc desc):
6969
assert desc.rowsize >= 0
7070

7171
cdef Buffer buf
@@ -101,7 +101,7 @@ cdef class TupleRowParser(RowParser):
101101

102102
return res
103103

104-
cpdef unpack_row(self, BytesIOReader reader, ParseDesc desc):
104+
cpdef unpack_plain_row(self, BytesIOReader reader, ParseDesc desc):
105105
assert desc.rowsize >= 0
106106

107107
cdef Buffer buf

cassandra/parsing.pxd

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,5 +28,5 @@ cdef class ColumnParser:
2828
cpdef parse_rows(self, BytesIOReader reader, ParseDesc desc)
2929

3030
cdef class RowParser:
31-
cpdef unpack_row(self, BytesIOReader reader, ParseDesc desc)
31+
cpdef unpack_plain_row(self, BytesIOReader reader, ParseDesc desc)
3232

cassandra/parsing.pyx

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ cdef class ColumnParser:
3939
cdef class RowParser:
4040
"""Parser for a single row"""
4141

42-
cpdef unpack_row(self, BytesIOReader reader, ParseDesc desc):
42+
cpdef unpack_plain_row(self, BytesIOReader reader, ParseDesc desc):
4343
"""
4444
Unpack a single row of data in a ResultMessage.
4545
"""

cassandra/row_parser.pyx

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -46,9 +46,9 @@ def make_recv_results_rows(ColumnParser colparser):
4646
rowcount = read_int(reader)
4747
if desc.column_encryption_policy:
4848
for i in range(rowcount):
49-
rowparser.unpack_ce_row(reader, desc)
49+
rowparser.unpack_col_encrypted_row(reader, desc)
5050
else:
5151
for i in range(rowcount):
52-
rowparser.unpack_row(reader, desc)
52+
rowparser.unpack_plain_row(reader, desc)
5353

5454
return recv_results_rows

0 commit comments

Comments
 (0)