@@ -398,7 +398,7 @@ cdef class CoreProtocol:
398
398
if cbuf != NULL and cbuf_len > 0 :
399
399
msg = cpython.PyBytes_FromStringAndSize(cbuf, cbuf_len - 1 )
400
400
else :
401
- msg = self .buffer.read_cstr ()
401
+ msg = self .buffer.read_null_str ()
402
402
self .result_status_msg = msg
403
403
404
404
cdef _parse_copy_data_msgs(self ):
@@ -510,18 +510,18 @@ cdef class CoreProtocol:
510
510
self .backend_secret = self .buffer.read_int32()
511
511
512
512
cdef _parse_msg_parameter_status(self ):
513
- name = self .buffer.read_cstr ()
513
+ name = self .buffer.read_null_str ()
514
514
name = name.decode(self .encoding)
515
515
516
- val = self .buffer.read_cstr ()
516
+ val = self .buffer.read_null_str ()
517
517
val = val.decode(self .encoding)
518
518
519
519
self ._set_server_parameter(name, val)
520
520
521
521
cdef _parse_msg_notification(self ):
522
522
pid = self .buffer.read_int32()
523
- channel = self .buffer.read_cstr ().decode(self .encoding)
524
- payload = self .buffer.read_cstr ().decode(self .encoding)
523
+ channel = self .buffer.read_null_str ().decode(self .encoding)
524
+ payload = self .buffer.read_null_str ().decode(self .encoding)
525
525
self ._on_notification(pid, channel, payload)
526
526
527
527
cdef _parse_msg_authentication(self ):
@@ -611,7 +611,7 @@ cdef class CoreProtocol:
611
611
if code == 0 :
612
612
break
613
613
614
- message = self .buffer.read_cstr ()
614
+ message = self .buffer.read_null_str ()
615
615
616
616
parsed[chr (code)] = message.decode()
617
617
0 commit comments