Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion runtime/src/main/java/dev/ionfusion/fusion/Binding.java
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ boolean isFree(BaseSymbol name)

/**
* Gets the original binding to which this binding refers.
* Returns itself, if and only if this binding is original.
* Returns itself if and only if this binding is original.
*
* @return not null.
*/
Expand Down
49 changes: 38 additions & 11 deletions runtime/src/main/java/dev/ionfusion/fusion/Namespace.java
Original file line number Diff line number Diff line change
Expand Up @@ -284,8 +284,12 @@ public String toString()

private final SyntaxWraps myWraps;
private final BoundIdMap<NsBinding> myBindings = new BoundIdMap<>();
private int myDefinitionCount;
private final ArrayList<Object> myValues = new ArrayList<>();

/**
* Storage for the values of namespace-level definitions.
*/
private final ArrayList<Object> myDefinedValues = new ArrayList<>();

private ArrayList<BindingDoc> myBindingDocs;


Expand Down Expand Up @@ -369,7 +373,10 @@ ModuleIdentity getResolutionBase()
*/
final int definitionCount()
{
return myDefinitionCount;
synchronized (myDefinedValues)
{
return myDefinedValues.size();
}
}

/**
Expand Down Expand Up @@ -516,8 +523,15 @@ SyntaxSymbol predefine(SyntaxSymbol identifier, SyntaxValue formForErrors)
}
if (newDefinition == null)
{
newDefinition = newDefinedBinding(identifier, myDefinitionCount);
myDefinitionCount++;
// Allocate a new address for this definition.
int address;
synchronized (myDefinedValues)
{
address = myDefinedValues.size();
myDefinedValues.add(null);
}

newDefinition = newDefinedBinding(identifier, address);
}

installBinding(identifier, newDefinition);
Expand Down Expand Up @@ -548,7 +562,7 @@ private <T> void set(ArrayList<T> list, int address, T value)
}
else // We need to grow the list. Annoying lack of API to do this.
{
list.ensureCapacity(myDefinitionCount); // Grow all at once
list.ensureCapacity(definitionCount()); // Grow all at once
for (int i = size; i < address; i++)
{
list.add(null);
Expand All @@ -567,7 +581,10 @@ private <T> void set(ArrayList<T> list, int address, T value)
@Override
public final void set(int address, Object value)
{
set(myValues, address, value);
synchronized (myDefinedValues)
{
myDefinedValues.set(address, value);
}
}


Expand Down Expand Up @@ -811,9 +828,13 @@ final Object lookupDefinition(NsDefinedBinding binding)
if (binding.isOwnedBy(this))
{
int address = binding.myAddress;
if (address < myValues.size()) // for prepare-time lookup

synchronized (myDefinedValues)
{
return myValues.get(address);
if (address < myDefinedValues.size()) // for prepare-time lookup
{
return myDefinedValues.get(address);
}
}
}
return null;
Expand Down Expand Up @@ -855,7 +876,10 @@ final Object lookup(String name)
@Override
public final Object lookup(int address)
{
return myValues.get(address);
synchronized (myDefinedValues)
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Do these reads need to be synchronized? Are there cases where lookups will be happening in contention with their address being set? At least to my intuition, the writes would need to be synchronized to ensure addresses are allocated correctly, but once we reach this code path it means an address has been allocated and thus should be safe to read without contention.

{
return myDefinedValues.get(address);
}
}

@Override
Expand All @@ -867,7 +891,10 @@ public final Object lookupImport(int moduleAddress, int bindingAddress)

final Object[] extractValues()
{
return myValues.toArray();
synchronized (myDefinedValues)
{
return myDefinedValues.toArray();
}
}


Expand Down
Loading