projects
/
openvswitch
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
don't use select.POLL* constants
[openvswitch]
/
python
/
ovs
/
stream.py
diff --git
a/python/ovs/stream.py
b/python/ovs/stream.py
index dad68483e7a8ea72735397a470be85e972f22a6b..c4d243d0d61f2598bb2145a39a57c8423274ef34 100644
(file)
--- a/
python/ovs/stream.py
+++ b/
python/ovs/stream.py
@@
-14,7
+14,6
@@
import errno
import os
import errno
import os
-import select
import socket
import ovs.poller
import socket
import ovs.poller
@@
-236,9
+235,9
@@
class Stream(object):
if self.state == Stream.__S_CONNECTING:
wait = Stream.W_CONNECT
if wait == Stream.W_RECV:
if self.state == Stream.__S_CONNECTING:
wait = Stream.W_CONNECT
if wait == Stream.W_RECV:
- poller.fd_wait(self.socket,
select
.POLLIN)
+ poller.fd_wait(self.socket,
ovs.poller
.POLLIN)
else:
else:
- poller.fd_wait(self.socket,
select
.POLLOUT)
+ poller.fd_wait(self.socket,
ovs.poller
.POLLOUT)
def connect_wait(self, poller):
self.wait(poller, Stream.W_CONNECT)
def connect_wait(self, poller):
self.wait(poller, Stream.W_CONNECT)
@@
-324,7
+323,7
@@
class PassiveStream(object):
return error, None
def wait(self, poller):
return error, None
def wait(self, poller):
- poller.fd_wait(self.socket,
select
.POLLIN)
+ poller.fd_wait(self.socket,
ovs.poller
.POLLIN)
def __del__(self):
# Don't delete the file: we might have forked.
def __del__(self):
# Don't delete the file: we might have forked.