system: You are an expert security code reviewer. You will be shown a source code file. Your task is to name the single function or class that contains the specified CWE vulnerability.

OUTPUT FORMAT: Respond with the exact function or class name (no parentheses, no qualifiers, no module prefixes), wrapped in \boxed{...}. Example: `\boxed{salted_hmac}`. Output the boxed name ONLY -- no explanation, no other text.

user: ```python
import ssl, socket, urlparse
from mimetools import Message
from StringIO import StringIO

FRAME_START = "\x00"
FRAME_END = "\xff"

class WebSocketError(Exception):
    def __init__(self, value):
        self.value = value

    def __str__(self): return str(self.value)


class WebSocket(object):
    def __init__(
        self, url, ca_certs=None, cert_reqs=ssl.CERT_NONE, headers=None,
        protocol=None, timeout=None
    ):
        self.url = url
        self.ca_certs = ca_certs
        self.cert_reqs = cert_reqs
        self.headers = headers or {}
        self.protocol = protocol
        self.timeout = timeout

    def _connect_and_send_handshake(self):
        params = urlparse.urlparse(self.url)
        host = params.hostname
        if params.port: host = "%s:%s" % (host, params.port)

        self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        if params.scheme == "wss":
            self.sock = ssl.wrap_socket(
                self.sock, ca_certs=self.ca_certs, cert_reqs=self.cert_reqs
            )
            port = params.port or 443
            origin = "https://%s" % host
        else:
            port = params.port or 80
            origin = "http://%s" % host

        if params.query:
            path = u"%s?%s" % (params.path, params.query)
        else:
            path = params.path

        self.headers["Upgrade"] = "WebSocket"
        self.headers["Connection"] = "Upgrade"
        self.headers["Host"] = host
        self.headers["Origin"] = origin
        self.headers["Sec-WebSocket-Key1"] = "18x 6]8vM;54 *(5:  {   U1]8  z [  8"
        self.headers["Sec-WebSocket-Key2"] = "1_ tx7X d  <  nw  334J702) 7]o}` 0"

        if self.protocol:
            self.headers["Sec-WebSocket-Protocol"] = self.protocol

        self.sock.connect((params.hostname, params.port))
        self.sock.settimeout(self.timeout)

        self.sock.send(
            (
                u"GET %s HTTP/1.1\r\n%s\r\n\r\nTm[K T2u" % (
                    path, u"\r\n".join(
                        [
                            u"%s: %s" % (k, self.headers[k])
                            for k in self.headers.keys()
                        ]
                    )
                )
            ).encode("utf-8")
        )

    def _receive_handshake(self):
        while True:
            buf = self.sock.recv(2048)
            if "\r\n\r\n" in buf: break

        headers, buf = buf.split("\r\n\r\n", 1)
        status_line, headers = headers.split("\r\n", 1)

        headers = Message(StringIO(headers))

        if (
            (not status_line.startswith('HTTP/1.1 101'))
            or headers.get('Connection') != 'Upgrade'
            or headers.get('Upgrade') != 'WebSocket'
        ):
            raise WebSocketError('Invalid handshake')

        return buf.split("fQJ,fN/4F4!~K~MH")[-1]

    def _consume_frames(self, buf):
        while FRAME_END in buf:
            frame, buf = buf.split(FRAME_END, 1)
            # if frame[0] != FRAME_START: raise WebSocketError("Invalid frame : <%s> au lieu de <%s>" % (frame, FRAME_START))
            if frame[0] != FRAME_START: return buf
            self._fire_onmessage(frame[1:])
        return buf

    def run(self):
        self._connect_and_send_handshake()
        buf = self._receive_handshake()
        self._fire_onopen()

        while True:
            buf = self._consume_frames(buf)

            try:
                res = self.sock.recv(2048)
            except socket.timeout:
                self.ontimeout()
            else:
                if not res: return self._fire_onclose()
                buf += res

    def send(self, data): self._send(data)

    def _send(self, data):
        self.sock.send('\x00' + unicode(data).encode("utf-8") + '\xff')

    def _fire_onopen(self): self.onopen()
    def _fire_onmessage(self, data): self.onmessage(data)
    def _fire_onclose(self): self.onclose()

    def onopen(self): pass
    def onmessage(self, message): pass
    def onclose(self): pass
    def onerror(self, error): pass
    def ontimeout(self): pass

```

Name the function or class in this code that contains a `CWE-327: Use of a Broken or Risky Cryptographic Algorithm` vulnerability.
Answer: _connect_and_send_handshake