The Inbox: Network-ul.153.mcz

A new version of Network was added to project The Inbox:
http://source.squeak.org/inbox/Network-ul.153.mcz

==================== Summary ====================

Name: Network-ul.153
Author: ul
Time: 24 October 2014, 3:38:28.874 am
UUID: 3e87044d-a929-4570-bba7-77fdb7d2bd41
Ancestors: Network-ul.152

- use the new ExternalSemaphoreTable API
- unifed socket initialization
- unregister ResolverSemaphore when the network initialization fails

=============== Diff against Network-ul.152 ===============

Item was changed:
  ----- Method: NetNameResolver class>>initializeNetwork (in category 'network initialization') -----
  initializeNetwork
  "Initialize the network drivers and record the semaphore to be used by the resolver. Do nothing if the network is already initialized. Evaluate the given block if network initialization fails."
  "NetNameResolver initializeNetwork"
 
- | semaIndex |
  self resolverStatus = ResolverUninitialized
  ifFalse: [^HaveNetwork := true].  "network is already initialized"
 
  HaveNetwork := false. "in case abort"
+ ResolverSemaphore := ExternalSemaphoreTable newExternalSemaphore.
- ResolverSemaphore := Semaphore new.
- semaIndex := Smalltalk registerExternalObject: ResolverSemaphore.
 
  "result is nil if network initialization failed, self if it succeeds"
+ (self primInitializeNetwork: ResolverSemaphore indexInExternalObjectsArray)
+ ifNil: [
+ ExternalSemaphoreTable unregisterExternalObject: ResolverSemaphore.
+ ResolverSemaphore := nil.
+ NoNetworkError signal: 'failed network initialization']
- (self primInitializeNetwork: semaIndex)
- ifNil: [NoNetworkError signal: 'failed network initialization']
  ifNotNil: [HaveNetwork := true].
 
+ self initializeOldNetworkFlag!
- self initializeOldNetworkFlag
- !

Item was changed:
  ----- Method: Socket>>acceptFrom: (in category 'initialize-destroy') -----
  acceptFrom: aSocket
  "Initialize a new socket handle from an accept call"
- | semaIndex readSemaIndex writeSemaIndex |
 
+ self initializeSocketHandleUsing: [
+ self
+ primAcceptFrom: aSocket socketHandle
+ receiveBufferSize: 8000
+ sendBufSize: 8000
+ semaIndex: semaphore indexInExternalObjectsArray
+ readSemaIndex: readSemaphore indexInExternalObjectsArray
+ writeSemaIndex: writeSemaphore indexInExternalObjectsArray ]!
- semaphore := Semaphore new.
- readSemaphore := Semaphore new.
- writeSemaphore := Semaphore new.
- semaIndex := Smalltalk registerExternalObject: semaphore.
- readSemaIndex := Smalltalk registerExternalObject: readSemaphore.
- writeSemaIndex := Smalltalk registerExternalObject: writeSemaphore.
- socketHandle := self primAcceptFrom: aSocket socketHandle
- receiveBufferSize: 8000
- sendBufSize: 8000
- semaIndex: semaIndex
- readSemaIndex: readSemaIndex
- writeSemaIndex: writeSemaIndex.
- socketHandle
- ifNotNil: [ self register ]
- ifNil: [  "socket creation failed"
- Smalltalk unregisterExternalObject: semaphore.
- Smalltalk unregisterExternalObject: readSemaphore.
- Smalltalk unregisterExternalObject: writeSemaphore.
- readSemaphore := writeSemaphore := semaphore := nil ]
- !

Item was changed:
  ----- Method: Socket>>destroy (in category 'initialize-destroy') -----
  destroy
  "Destroy this socket. Its connection, if any, is aborted and its resources are freed. Do nothing if the socket has already been destroyed (i.e., if its socketHandle is nil)."
 
  socketHandle ifNotNil: [
  self isValid ifTrue: [ self primSocketDestroy: socketHandle ].
+ ExternalSemaphoreTable unregisterExternalObjects: {
+ semaphore.
+ readSemaphore.
+ writeSemaphore }.
- Smalltalk unregisterExternalObject: semaphore.
- Smalltalk unregisterExternalObject: readSemaphore.
- Smalltalk unregisterExternalObject: writeSemaphore.
  socketHandle := nil.
  readSemaphore := writeSemaphore := semaphore := nil.
  self unregister ]!

Item was changed:
  ----- Method: Socket>>finalize (in category 'finalization') -----
  finalize
+
  self primSocketDestroyGently: socketHandle.
+ ExternalSemaphoreTable unregisterExternalObjects: {
+ semaphore.
+ readSemaphore.
+ writeSemaphore }
- Smalltalk unregisterExternalObject: semaphore.
- Smalltalk unregisterExternalObject: readSemaphore.
- Smalltalk unregisterExternalObject: writeSemaphore.
  !

Item was changed:
  ----- Method: Socket>>initialize: (in category 'initialize-destroy') -----
  initialize: socketType
  "Initialize a new socket handle. If socket creation fails, socketHandle will be set to nil."
- | semaIndex readSemaIndex writeSemaIndex |
 
+ self initializeSocketHandleUsing: [
- semaphore := Semaphore new.
- readSemaphore := Semaphore new.
- writeSemaphore := Semaphore new.
- semaIndex := Smalltalk registerExternalObject: semaphore.
- readSemaIndex := Smalltalk registerExternalObject: readSemaphore.
- writeSemaIndex := Smalltalk registerExternalObject: writeSemaphore.
- socketHandle :=
  self primSocketCreateNetwork: 0
  type: socketType
  receiveBufferSize: 8000
  sendBufSize: 8000
+ semaIndex: semaphore indexInExternalObjectsArray
+ readSemaIndex: readSemaphore indexInExternalObjectsArray
+ writeSemaIndex: writeSemaphore indexInExternalObjectsArray ]!
- semaIndex: semaIndex
- readSemaIndex: readSemaIndex
- writeSemaIndex: writeSemaIndex.
-
- socketHandle
- ifNotNil: [ self register ]
- ifNil: [  "socket creation failed"
- Smalltalk unregisterExternalObject: semaphore.
- Smalltalk unregisterExternalObject: readSemaphore.
- Smalltalk unregisterExternalObject: writeSemaphore.
- readSemaphore := writeSemaphore := semaphore := nil ]
- !

Item was changed:
  ----- Method: Socket>>initialize:family: (in category 'initialize-destroy') -----
  initialize: socketType family: family
  "Initialize a new socket handle. If socket creation fails, socketHandle will be set to nil."
- | semaIndex readSemaIndex writeSemaIndex |
 
+ NetNameResolver useOldNetwork ifTrue: [ ^self initialize: socketType ].
+ self initializeSocketHandleUsing: [
- NetNameResolver useOldNetwork ifTrue: [^self initialize: socketType].
- semaphore := Semaphore new.
- readSemaphore := Semaphore new.
- writeSemaphore := Semaphore new.
- semaIndex := Smalltalk registerExternalObject: semaphore.
- readSemaIndex := Smalltalk registerExternalObject: readSemaphore.
- writeSemaIndex := Smalltalk registerExternalObject: writeSemaphore.
- socketHandle :=
  self primSocketCreateNetwork: family
  type: socketType
  receiveBufferSize: 8000
  sendBufSize: 8000
+ semaIndex: semaphore indexInExternalObjectsArray
+ readSemaIndex: readSemaphore indexInExternalObjectsArray
+ writeSemaIndex: writeSemaphore indexInExternalObjectsArray ]!
- semaIndex: semaIndex
- readSemaIndex: readSemaIndex
- writeSemaIndex: writeSemaIndex.
-
- socketHandle
- ifNotNil: [ self register ]
- ifNil: [  "socket creation failed"
- Smalltalk unregisterExternalObject: semaphore.
- Smalltalk unregisterExternalObject: readSemaphore.
- Smalltalk unregisterExternalObject: writeSemaphore.
- readSemaphore := writeSemaphore := semaphore := nil ]
- !

Item was added:
+ ----- Method: Socket>>initializeSocketHandleUsing: (in category 'initialize-destroy') -----
+ initializeSocketHandleUsing: aBlock
+ "Initialize a new socket handle. If socket creation fails, socketHandle will be set to nil."
+
+ | semaphores |
+ semaphores := ExternalSemaphoreTable newExternalSemaphores: 3.
+ semaphore := semaphores at: 1.
+ readSemaphore := semaphores at: 2.
+ writeSemaphore := semaphores at: 3.
+ (socketHandle := aBlock value)
+ ifNotNil: [ self register ]
+ ifNil: [
+ "socket creation failed"
+ semaphore := readSemaphore := writeSemaphore := nil.
+ ExternalSemaphoreTable unregisterExternalObjects: semaphores ]!