Skip to content

Commit

Permalink
keep track of stream_ and ping_id, cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
colinmarc committed Mar 22, 2012
1 parent e035027 commit 95336df
Show file tree
Hide file tree
Showing 2 changed files with 19 additions and 8 deletions.
19 changes: 19 additions & 0 deletions python-spdy/connection.py
Expand Up @@ -29,6 +29,25 @@ def __init__(self, side, version=2):
self.frame_queue = []
self.input_buffer = b''

if side == SERVER:
self._stream_id = 2
self._ping_id = 2
else:
self._stream_id = 1
self._ping_id = 1

@property
def next_stream_id(self):
sid = self._stream_id
self._stream_id += 2
return sid

@property
def next_ping_id(self):
pid = self._ping_id
self._ping_id += 2
return pid

def incoming(self, chunk):
self.input_buffer += chunk

Expand Down
8 changes: 0 additions & 8 deletions python-spdy/frames.py
Expand Up @@ -41,14 +41,6 @@ def __init__(self, version, frame_type):
def __repr__(self):
return self.frame_type

#abstract
def _parse(self):
raise NotImplementedError()

#abstract
def _encode(self):
raise NotImplementedError()

class SynStream(ControlFrame):
def __init__(self, version, stream_id, headers):
super(SynStream, self).__init__(version, SYN_STREAM)
Expand Down

0 comments on commit 95336df

Please sign in to comment.