I hereby claim:
- I am bm4cs on github.
- I am bm4cs (https://keybase.io/bm4cs) on keybase.
- I have a public key whose fingerprint is C8E1 7FE7 C3B4 96C8 B6E1 A47E B89B 4DED 12CA C26E
To claim this, I am signing this object:
I hereby claim:
To claim this, I am signing this object:
amdgpu/polaris10_{ce,ce_2,k_smc,k2_smc,k_mc,mc,me,me_2,mec2,mec2_2,mec,mec_2,pfp,pfp_2,rlc,sdma1,sdma,smc,smc_sk,uvd,vce}.bin |
function insert(item, user, request) { | |
request.execute({ | |
success: function () { | |
request.respond(); | |
sendNotifications(); | |
} | |
}); | |
function sendNotifications() { | |
var channelTable = tables.getTable('Channel'); |
maximumLatencyQuery.Bind(sqlSinkForMaximumMessageLatency(targetSqlConnectionString, false)).Run(); | |
maximumLatencyQuery.Bind(mobileServicesSinkForMaximumMessageLatency(mobileServicesEndpointURL, mobileServicesApplicationKey, false)).Run(); |
// Convert points to signals | |
var fooEdgeEvents = | |
from e in fooPointEvents | |
.AlterEventDuration(e => TimeSpan.MaxValue) | |
.ClipEventDuration(fooMessagesObservable, (e1, e2) => (e1.MessageId == e2.MessageId)) | |
select e; | |
var latencyQuery = | |
from e1 in fooEdgeEvents | |
join e2 in barPointEvents |
public void OnNext(PointEvent<TEvent> e) | |
{ | |
if (e.EventKind == EventKind.Cti) | |
{ | |
return; | |
} | |
var entity = e.Payload; | |
try |
public static IObserver<PointEvent<TEvent>> CreateObserver(string connectionString, bool storeCtis) | |
{ | |
var res = new SqlAzureSink<TEvent>(connectionString, storeCtis); | |
return Observer.Create<PointEvent<TEvent>>(e => res.OnNext(e)); | |
} |