code: def get_message(self, dummy0, sock_info, use_cmd=False):
          
  
          ns = self.namespace()
          ctx = sock_info.compression_context
  
          if use_cmd:
              spec = self.as_command(sock_info)[0]
              if sock_info.op_msg_enabled:
                  request_id, msg, size, _ = _op_msg(
                      0, spec, self.db, ReadPreference.PRIMARY,
                      False, False, self.codec_options,
                      ctx=sock_info.compression_context)
                  return request_id, msg, size
              ns = _UJOIN % (self.db, "$cmd")
              return query(0, ns, 0, -1, spec, None, self.codec_options, ctx=ctx)
  
          return get_more(ns, self.ntoreturn, self.cursor_id, ctx)
docs: Get a getmore message.