callagent: Remove the semapahore from the transport
This commit is contained in:
parent
7d0a7945c7
commit
65c0f05dfa
|
@ -19,7 +19,7 @@
|
|||
PackageLoader fileInPackage: 'Sockets'.
|
||||
|
||||
Object subclass: SIPTransport [
|
||||
| queue sem handler |
|
||||
| queue handler |
|
||||
<category: 'SIP-Callagent'>
|
||||
<comment: 'I am the baseclass for a transport'>
|
||||
|
||||
|
@ -37,7 +37,6 @@ Object subclass: SIPTransport [
|
|||
|
||||
initialize [
|
||||
queue := SharedQueue new.
|
||||
sem := Semaphore forMutualExclusion.
|
||||
]
|
||||
|
||||
queueData: aDatagram [
|
||||
|
@ -95,7 +94,6 @@ SIPTransport subclass: SIPUdpTransport [
|
|||
]
|
||||
|
||||
initialize: anAddress [
|
||||
sem := Semaphore forMutualExclusion.
|
||||
socket := Sockets.DatagramSocket local: anAddress port: 5060.
|
||||
socket
|
||||
bufferSize: 2048;
|
||||
|
@ -108,7 +106,7 @@ SIPTransport subclass: SIPUdpTransport [
|
|||
[ | data |
|
||||
data := socket next.
|
||||
data ifNotNil: [
|
||||
sem critical: [self handleData: data].
|
||||
self handleData: data.
|
||||
].
|
||||
] repeat.
|
||||
] fork.
|
||||
|
|
Reference in New Issue