Lines Matching full:self
76 def __init__(self, raw_socket):
77 self._ssl = socket.ssl(raw_socket)
79 def send(self, bytes):
80 return self._ssl.write(bytes)
82 def recv(self, size=-1):
83 return self._ssl.read(size)
85 def close(self):
93 def __init__(self, options):
94 self._options = options
95 self._socket = None
97 def run(self):
102 self._socket = socket.socket()
103 self._socket.settimeout(self._options.socket_timeout)
105 self._socket.connect((self._options.server_host,
106 self._options.server_port))
107 if self._options.use_tls:
108 self._socket = _TLSSocket(self._socket)
109 self._handshake()
110 for line in self._options.message.split(',') + [_GOODBYE_MESSAGE]:
112 self._socket.send(frame)
113 if self._options.verbose:
115 received = self._socket.recv(len(frame))
118 if self._options.verbose:
122 self._socket.close()
124 def _handshake(self):
125 self._socket.send(_method_line(self._options.resource))
126 self._socket.send(_UPGRADE_HEADER)
127 self._socket.send(_CONNECTION_HEADER)
128 self._socket.send(self._format_host_header())
129 self._socket.send(_origin_header(self._options.origin))
130 self._socket.send('\r\n')
133 received = self._socket.recv(1)[0]
137 self._skip_headers()
139 def _skip_headers(self):
143 received = self._socket.recv(1)[0]
151 def _format_host_header(self):
152 host = 'Host: ' + self._options.server_host
153 if ((not self._options.use_tls and
154 self._options.server_port != _DEFAULT_PORT) or
155 (self._options.use_tls and
156 self._options.server_port != _DEFAULT_SECURE_PORT)):
157 host += ':' + str(self._options.server_port)
