60 lines
1.4 KiB
Smalltalk
60 lines
1.4 KiB
Smalltalk
"""
|
|
The following changes need to be kept for pharo.
|
|
"""
|
|
OsmoUDPSocketTest extend [
|
|
createSocket [
|
|
^ Socket newUDP
|
|
]
|
|
]
|
|
|
|
OsmoUDPSocket extend [
|
|
startRXProcess [
|
|
^ [[[
|
|
Processor activeProcess name: name, ' RX'.
|
|
self runRXProcess
|
|
] on: ConnectionClosed do: []
|
|
] ensure: [net_exit signal]] fork.
|
|
]
|
|
]
|
|
|
|
OsmoAppConnection extend [
|
|
createConnection: aHostname port: aPort [
|
|
<category: 'pharo-porting'>
|
|
^(SocketStream openConnectionToHostNamed: aHostname port: aPort)
|
|
binary;
|
|
noTimeout;
|
|
yourself
|
|
]
|
|
]
|
|
|
|
OsmoStreamSocketBase extend [
|
|
driveDispatch [
|
|
<category: 'private'>
|
|
[
|
|
[self dispatchOne] on: ConnectionClosed do: [:e |
|
|
self logError: 'OsmoApplication dispatch failed.' area: #osmo.
|
|
self scheduleReconnect]
|
|
] on: Error do: [:e |
|
|
e logException: 'OsmoApplication error' area: #osmo.
|
|
self scheduleReconnect]
|
|
]
|
|
|
|
driveSend [
|
|
<category: 'private'>
|
|
|
|
[
|
|
self sendOne.
|
|
] on: ConnectionClosed do: [:e |
|
|
e logException: 'OsmoAppConnection send failed' area: #osmo.
|
|
self scheduleReconnect.
|
|
]
|
|
]
|
|
]
|
|
|
|
OsmoStreamSocketBase class extend [
|
|
connectionException [
|
|
<category: 'pharo-porting'>
|
|
^ConnectionTimedOut
|
|
]
|
|
]
|