org.abora.gold.rcmain
Class IPRendezvousListener

java.lang.Object
  |
  +--org.abora.gold.java.AboraHeaper
        |
        +--org.abora.gold.xpp.basic.Heaper
              |
              +--org.abora.gold.rcmain.ServerChunk
                    |
                    +--org.abora.gold.rcmain.FDListener
                          |
                          +--org.abora.gold.rcmain.IPRendezvousListener

public class IPRendezvousListener

extends FDListener

An IPRendezvousListener binds to a known rendezvous socket address.
Its handleInput method accepts connection on this socket and sets up a FEBE connection
on the spawned socket, including a IPConnectionListener.

Field Summary

protected int

myAddress

Fields inherited from class org.abora.gold.rcmain.FDListener

myFD

Fields inherited from class org.abora.gold.rcmain.ServerChunk

myEndingState, myFluidSpace, SecretEmulsion

Fields inherited from class org.abora.gold.xpp.basic.Heaper

AllBlasts, BecomeMap, GarbageCount, InGC, InitializedClasses, InitializingClasses, LastMemory, NextClientRequestNumber, NotOneElementSignal, PackageTable, PromiseNameTable, StringHashSBoxes

Fields inherited from class org.abora.gold.java.AboraHeaper

ActiveClubs, CurrentAuthor, CurrentBertCanopyCache, CurrentBertCrum, CurrentChunk, CurrentGrandMap, CurrentKeyMaster, CurrentPacker, CurrentSensorCanopyCache, CurrentServer, CurrentSession, CurrentSessions, CurrentTrace, InitialEditClub, InitialOwner, InitialReadClub, InitialSponsor, InsideTransactionFlag

Constructor Summary

IPRendezvousListener(int anAddress)

IPRendezvousListener(Rcvr receiver)

Method Summary

boolean	execute() A client is trying to connect to the rendezvous socket. Accept the connection and spawn an IPconnectionListener for them. NOTE: in smalltalk (only) it is not guarnteed that there is anyone there. so we do a non blocking operation and return quietly if there isn't
static Heaper	make(int anAddress)
void	restartIPRendezvous(Rcvr rcvr)
void	sendSelfTo(Xmtr xmtr) do nothing
boolean	shouldBeReady() There should be data waiting on this FD.

Methods inherited from class org.abora.gold.rcmain.FDListener

actualHashForEqual, descriptor, destruct, initTimeNonInherited, isEqual, problems, registerFor

Methods inherited from class org.abora.gold.rcmain.ServerChunk

aliveFlag, cleanupGarbage, destroy, destroyOKIfRequested, destroyPending, destroyReadyFlag, destroyRequestedFlag, emulsion, fluidSpace, fluidSpace, inRequest, inRequestFlag, linkTimeNonInherited, notInRequest, shouldDestroy

Methods inherited from class org.abora.gold.xpp.basic.Heaper

abstractDeclarationFor, abstractTypeFor, addMethodAttributeToInOf, addPackage, addPackageCategory, allClientProtocolOn, argumentTypesFor, arrow, blast, blast, BLAST, cachePromiseNameTable, cachePromiseNameTableIn, canYouBecome, cast, cleanPromiseClasses, clientClassesDo, clientFunctionsOn, clientMethodsOn, clientProtocol, clientProtocolDo, clientProtocolOn, clientProtocolOn, collectibleClasses, compare, compileClientSubclasses, compileConstantPromiseMethods, compileCreateFromRcvr, compileEQ, compileGeneratedClassMethod, compileGeneratedMethod, compileHook, compilePromise, compilePromiseDefaultMethods, compilePromiseFluidDeclarations, compilePromiseHandlers, compilePromiseMethods, compileRequestCreateMsgInArguments, compileRequestEvaluateMsgInReturningArguments, compileRPCSpecialistEvaluateMsgForReturningArguments, compileSendSelfTo, compileSendSelfToSendHook, compileStubbleMethods, compileSubclassStubbleMethods, computeMangle, computePreorder, constantTypeValue, convert, convertCopyDeclarations, convertDeferredDeclarations, convertProxyDeclarations, convertSubclassCopyDeclarations, convertSubclassDeferredDeclarations, convertSubclassProxyDeclarations, copyReferencesToType, create, create, create, create, create, create, create, create, create, create, createRequestClassArguments, definesProxyMethods, delete, deref, destructor, enum, enumFlags, equals, exportName, fetchAttribute, fetchPackage, fetchSuperCategory, fileOutClientProtocol, findCategory, findSenderAndReceiverMethods, findTailInto, flushPromiseNameTable, foo, freezeClientClasses, freezeClientProtocol, freezeStProtocol, frozenClasses, garbageCollect, garbageCollectFrom, gcOpportunity, gcOpportunity, generatedCategory, generatePromiseNames, getCategory, getOrMakePackage, getSuperCategory, handlerSignaturesFrom, hash, hashForEqual, hasProxyMethods, info_clientClasses, info_clientSideClasses, info_promiseClasses, info_stProtocol, inGC, initializedClasses, initializingClasses, initPackages, initStringHashSBoxes, inspectPieces, instanceSize, IntegerVar, isByProxy, isConstructed, isDestructed, isEqual, isEqualOrSubclassOf, isGenerated, isIntType, isKindOf, isRawType, isUnlocked, make, makeClassTable, makeFillTable, makeRequestTable, mangle, markChildren, markCount, markInstances, mayBecome, mayBecomeAnySubclassOf, new1, newX, nonCopyVariables, notWorking, pack, packageClasses, packagingCategory, parseExportName, passe, pointerToStaticMember, pointerToStaticMember, pointerToVirtualMember, preorderMax, preorderNumber, printOn, PROBLEM, promiseClass, promiseDefaultValue, promiseName, promiseNameTable, promiseToAbstract, registerPackageCategory, removeGeneratedCode, removeStubbleMethods, removeSubclassGeneratedCode, removeSubclassStubbleMethods, requestProcedure, requestProceduresFrom, returnTypeFor, rootName, scheduleTermination, sendProxyTo, serverNameFor, setGC, signal, signals, smalltalkSelector, stClientProtocol, stubbleSelectorTokenReturnsArguments, subclassNonCopyVariables, takeOop, togglePromiseName, togglePromiseOfParse, unimplemented, unmangle, verifyFreeze, wipeStubble

Methods inherited from class org.abora.gold.java.AboraHeaper

asOop, basicInspect, displayString, error, hack, halt, inspect, knownBug, mightNotImplement, REQUIRES, shouldImplement, shouldNotImplement, stubbleForSubclassResponsibility, thingToDo, willNotImplement

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

myAddress

protected int myAddress

Constructor Detail

IPRendezvousListener

public IPRendezvousListener(int anAddress)

IPRendezvousListener

public IPRendezvousListener(Rcvr receiver)

Method Detail

restartIPRendezvous

public void restartIPRendezvous(Rcvr rcvr)

execute

public boolean execute()

A client is trying to connect to the rendezvous socket.
Accept the connection and spawn an IPconnectionListener for them.
NOTE: in smalltalk (only) it is not guarnteed that there is anyone there.
so we do a non blocking operation and return quietly if there isn't

Overrides:

execute in class FDListener

shouldBeReady

public boolean shouldBeReady()

Description copied from class: FDListener

There should be data waiting on this FD. Return TRUE if I am still in a reasonable state
to continue, FALSE if not (in which case the Listener will be destroyed by the caller)

Overrides:

shouldBeReady in class FDListener

sendSelfTo

public void sendSelfTo(Xmtr xmtr)

Description copied from class: Heaper

do nothing

Overrides:

sendSelfTo in class Heaper

make

public static Heaper make(int anAddress)