MQTT Outgoing 머시기 에러코드 수정
This commit is contained in:
@@ -238,7 +238,10 @@ namespace Best.HTTP.Shared.Databases
|
|||||||
}
|
}
|
||||||
finally
|
finally
|
||||||
{
|
{
|
||||||
this.rwlock.ExitWriteLock();
|
if (this.rwlock != null)
|
||||||
|
{
|
||||||
|
this.rwlock.ExitWriteLock();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -98,17 +98,17 @@ namespace Best.HTTP.Shared.Databases
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
for (int i = 0; i < this.Metadatas.Count; ++i)
|
for (int i = 0; i < this.Metadatas.Count; ++i)
|
||||||
{
|
{
|
||||||
var metadata = this.Metadatas[i];
|
var metadata = this.Metadatas[i];
|
||||||
|
|
||||||
if (metadata.IsDeleted)
|
if (metadata.IsDeleted)
|
||||||
continue;
|
continue;
|
||||||
|
|
||||||
metadata.SaveTo(stream);
|
metadata.SaveTo(stream);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
public void LoadFrom(Stream stream)
|
public void LoadFrom(Stream stream)
|
||||||
{
|
{
|
||||||
|
|||||||
Reference in New Issue
Block a user