@@ -107,23 +107,23 @@ def call(
107107 ) -> Results :
108108 """Synchronously call an RPC procedure and return the result"""
109109
110- callBody = sunrpc .CallBody (
110+ call_body = sunrpc .CallBody (
111111 proc_desc .program ,
112112 proc_desc .version ,
113113 proc_desc .procedure ,
114114 self ._auth .credentials ,
115115 self ._auth .verifier ,
116116 params ,
117117 )
118- message = sunrpc .Message (self ._xid , callBody )
119- messageSerializer = MessageSerializer (
118+ message = sunrpc .Message (self ._xid , call_body )
119+ message_serializer = MessageSerializer (
120120 params_serializer , result_deserializer , self ._auth .credentials_serializer , self ._auth .verifier_serializer
121121 )
122- requestPayload = messageSerializer .serialize (message )
123- self ._send (requestPayload )
122+ request_payload = message_serializer .serialize (message )
123+ self ._send (request_payload )
124124
125- responsePayload = self ._receive ()
126- response = messageSerializer .deserialize_from_bytes (responsePayload )
125+ response_payload = self ._receive ()
126+ response = message_serializer .deserialize_from_bytes (response_payload )
127127 if response .xid != self ._xid :
128128 raise MismatchXidError ("Invalid response xid" )
129129 if not isinstance (response .body , sunrpc .AcceptedReply ):
@@ -143,11 +143,11 @@ def _send(self, data: bytes) -> None:
143143 fragment = data [offset : offset + self ._fragment_size ]
144144 fragment_size = len (fragment )
145145
146- fragmentHeader = fragment_size
146+ fragment_header = fragment_size
147147 if offset + fragment_size == data_size :
148- fragmentHeader = fragmentHeader | 0x80000000 # MSB set to indicate last fragment
148+ fragment_header = fragment_header | 0x80000000 # MSB set to indicate last fragment
149149
150- chunk = fragmentHeader .to_bytes (4 , "big" ) + fragment
150+ chunk = fragment_header .to_bytes (4 , "big" ) + fragment
151151 self ._sock .sendall (chunk )
152152 offset += fragment_size
153153
0 commit comments