Skip to content

Commit

Permalink
Analizators/s1854
Browse files Browse the repository at this point in the history
  • Loading branch information
SuhorukovAnton committed Jan 21, 2022
1 parent c05d9fe commit 143f0a5
Show file tree
Hide file tree
Showing 7 changed files with 7 additions and 14 deletions.
2 changes: 1 addition & 1 deletion common/ASC.Core.Common/Data/DbSubscriptionService.cs
Original file line number Diff line number Diff line change
Expand Up @@ -136,7 +136,7 @@ public bool IsUnsubscribe(int tenant, string sourceId, string actionId, string r
}
else
{
q = q = q.Where(r => r.Object == string.Empty);
q = q.Where(r => r.Object == string.Empty);
}

return q.Any();
Expand Down
2 changes: 1 addition & 1 deletion common/ASC.Core.Common/EF/Context/BaseDbContext.cs
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
{
if (!string.IsNullOrEmpty(MigrateAssembly))
{
r = r.MigrationsAssembly(MigrateAssembly);
r.MigrationsAssembly(MigrateAssembly);
}
});
break;
Expand Down
2 changes: 1 addition & 1 deletion common/ASC.Core.Common/Notify/Engine/NotifyEngine.cs
Original file line number Diff line number Diff line change
Expand Up @@ -261,7 +261,7 @@ private NotifyResult SendNotify(NotifyRequest request, IServiceScope serviceScop
}
else
{
result = new NotifyResult(sendResponces.Aggregate((SendResult)0, (s, r) => s |= r.Result), sendResponces);
result = new NotifyResult(sendResponces.Aggregate((SendResult)0, (s, r) => r.Result), sendResponces);
}
log.Debug(result);
return result;
Expand Down
1 change: 0 additions & 1 deletion common/ASC.Data.Storage/CrossModuleTransferUtility.cs
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,6 @@ public void CopyFile(string srcDomain, string srcPath, string destDomain, string
memstream.Seek(0, SeekOrigin.Begin);
holder.UploadChunk(session, memstream, chunksize);
memstream.Dispose();
memstream = null;
}
}
finally
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -288,10 +288,6 @@ public override Uri Save(string domain, string path, Stream stream, string conte
? MimeMapping.GetMimeMapping(Path.GetFileName(path))
: contentType;

if (mime == "application/octet-stream")
{
contentDisposition = "attachment";
}

var customHeaders = new Dictionary<string, string>();

Expand Down
2 changes: 0 additions & 2 deletions common/services/ASC.ElasticSearch/Engine/BaseIndexer.cs
Original file line number Diff line number Diff line change
Expand Up @@ -526,7 +526,6 @@ private IBulkIndexOperation<T> GetMeta(BulkIndexDescriptor<T> desc, T data)
while (!string.IsNullOrEmpty(name))
{
sourceExprText = "." + name + sourceExprText;
expression = member.Expression;
}

if (isList)
Expand Down Expand Up @@ -581,7 +580,6 @@ private IBulkIndexOperation<T> GetMeta(BulkIndexDescriptor<T> desc, T data)
while (!string.IsNullOrEmpty(name))
{
sourceExprText = "." + name + sourceExprText;
expression = member.Expression;
}

var parameters = new Dictionary<string, object>();
Expand Down
8 changes: 4 additions & 4 deletions common/services/ASC.ElasticSearch/Engine/FactoryIndexer.cs
Original file line number Diff line number Diff line change
Expand Up @@ -230,7 +230,7 @@ public void Index(List<T> data, bool immediately = true, int retry = 0)
Thread.Sleep(60000);
if (retry < 5)
{
Index(data, immediately, retry++);
Index(data, immediately, retry + 1);
return;
}

Expand Down Expand Up @@ -259,7 +259,7 @@ public void Index(List<T> data, bool immediately = true, int retry = 0)
Thread.Sleep(60000);
if (retry < 5)
{
Index(data, immediately, retry++);
Index(data, immediately, retry + 1);
return;
}

Expand Down Expand Up @@ -304,7 +304,7 @@ private async Task InternalIndexAsync(List<T> data, bool immediately, int retry)
await Task.Delay(60000);
if (retry < 5)
{
await IndexAsync(data, immediately, retry++);
await IndexAsync(data, immediately, retry + 1);
return;
}

Expand Down Expand Up @@ -333,7 +333,7 @@ private async Task InternalIndexAsync(List<T> data, bool immediately, int retry)
await Task.Delay(60000);
if (retry < 5)
{
await IndexAsync(data, immediately, retry++);
await IndexAsync(data, immediately, retry + 1);
return;
}

Expand Down

0 comments on commit 143f0a5

Please sign in to comment.