Skip to content

Instantly share code, notes, and snippets.

View jurrchen's full-sized avatar

Jieren Chen jurrchen

20 followers · 10 following
View GitHub Profile
@jurrchen
jurrchen / criu.log
Created January 18, 2019 08:34
3.11 error
(00.000003) Version: 3.11 (gitid 0)
(00.000038) Running on prepl2 Linux 4.14.65+ #1 SMP Thu Oct 25 10:42:50 PDT 2018 x86_64
(00.000047) File /run/criu.kdat does not exist
(00.000071) sockets: Probing sock diag modules
(00.000220) sockets: Done probing
(00.004050) Pagemap is fully functional
(00.004118) Found anon-shmem device at 5
(00.004137) Reset 266's dirty tracking
(00.004189) ... done
(00.004236) Dirty track supported on kernel
@jurrchen
jurrchen / criu.log
Created January 18, 2019 03:58
dump issues log
(00.000005) Version: 2.8 (gitid 0)
(00.000070) Probing sock diag modules
(00.000120) Done probing
(00.055897) ========================================
(00.055938) Dumping processes (pid: 32)
(00.055940) ========================================
(00.055975) Running pre-dump scripts
(00.056054) Pagemap is fully functional
(00.056109) Found anon-shmem device at 5
(00.056209) Reset 93's dirty tracking
@jurrchen
jurrchen / Dockerfile
Created January 18, 2019 03:45
dump issues
FROM python:3.7
RUN apt-get update && apt-get install -y curl lsb-release
RUN CLOUD_SDK_REPO="cloud-sdk-$(lsb_release -c -s)" && echo "deb http://packages.cloud.google.com/apt $CLOUD_SDK_REPO main" | tee -a /etc/apt/sources.list.d/google-cloud-sdk.list
RUN curl https://packages.cloud.google.com/apt/doc/apt-key.gpg | apt-key add -
RUN apt-get update && apt-get install -y --no-install-recommends \
google-cloud-sdk && \
rm -rf /var/lib/apt/lists/*
@jurrchen
jurrchen / gist:648ce78dad2af853c1d1
Created September 8, 2014 14:38
8/29 Prod Logs
This file has been truncated, but you can view the full file.
441799872883220497 2014-08-29T00:01:59 2014-08-29T00:02:00Z 25780853 ip-172-31-47-64 54.191.149.185 Local5 Debug DEBUG [service=expert host=ip-172-31-47-64] application [securesocial] calling deleteExpiredTokens()
441800595717050404 2014-08-29T00:04:52 2014-08-29T00:04:52Z 38420403 ip-172-31-10-254-1 54.187.111.151 Daemon Info dhclient bound to 172.31.10.254 -- renewal in 1445 seconds.
441801039830867969 2014-08-29T00:06:37 2014-08-29T00:06:38Z 25780853 ip-172-31-47-64 54.191.149.185 Local5 Debug DEBUG [service=expert host=ip-172-31-47-64] application Room.websocket().async() - Connected Web Socket For [8] (User) From [172.56.4.181] - ID Cookie [53f11e0ece1c1aff4eef431440ad83a18fc355264dd520389c41f6cd80556b11fac03db052569eabae67509b9880db71f8bd5f5607ada0a018a15a89d692521c77004e8a96311b1422642c0dc63e67a832ed2c4a6664e4e96fc8796e84ed9dc620202cd3d0b2417b1568217c2f78c1886aef5e616a717256adad1dc0be574983].
441801039944114184 2014-08-29T00:06:37 2014-08-29T00:06:38Z 25780853 ip-172-31-47-64 54.191.149.185 Local5 De
@jurrchen
jurrchen / gist:49c0faa7bb7b9e08b578
Last active August 29, 2015 14:02
class CompositionActor(originalSender: Actor) extends FSM {
startWith((List.empty[CreditData], List.empty[ScoreData]), Intializing)
when(Initializing) {
case Event(Request(userA, userB), state) => {
mysqlActor ! LookupRequest(userA)
mysqlActor ! LookupRequest(userB)
goto(LookingUpCreditData) using state
}
@jurrchen
jurrchen / gist:7671236
Last active December 29, 2015 12:29
def getMostRecentPostsLegacy(kloutId: String)(implicit eventStream: EventStream, principal: Principal): Future[List[HydratedPost]] = {
eventStream info "Nas is like"
eventStream warn "half man"
try {
throw new Exception("half amazin'")
} catch {
case t: Throwable => eventStream error t
}
}
@jurrchen
jurrchen / gist:7671216
Created November 27, 2013 05:48
def getMostRecentPostsLegacy(kloutId: String) = {
superUser { implicit principal =>
streamApi { implicit eventStream =>
queryService getMostRecentPostsLegacy kloutId
}
}
}
@jurrchen
jurrchen / gist:7670900
Last active December 29, 2015 12:29
def streamApi[T](businessLogic: EventStream => T)(implicit principal: Principal, resulter: Resulter[T]): Action[AnyContent] = {
streamApiWithBody(parse.anyContent)(baseWrapper[T] compose businessLogic)
}
def streamApiWithBody[T, A](bodyParser: BodyParser[A])(businessLogic: EventStream => RequestWrapper[T, A])(implicit principal: Principal, resulter: Resulter[T]): Action[A] = {
Action(bodyParser) { implicit request =>
request.headers.get(StreamHeader) flatMap (EventLevel maybeWithName _.toLowerCase) match {
case Some(lvl) if principal.willPerform(ViewStream) => {
Ok.stream {
Concurrent.unicast[Either[EventFinal, Event]] { channel =>
@jurrchen
jurrchen / gist:5736041
Created June 8, 2013 17:52
trait TopicsFeature extends AkkaAgentTopicStateServiceComponent
with RealTopicOntologyServiceComponent
with RealTopicServiceComponent
with RealTopicImportServiceComponent
with RealUserTopicServiceComponent
with RealPlusKServiceComponent
with RealPotentialTopicsServiceComponent
with RealTopicsDataServiceComponent
with RealUserScienceTopicsServiceComponent {
self: UserWalletServiceComponent with OnlineHBaseClientComponent with UserServiceComponent with StreamServiceComponent with QuestEventBusComponent with NotifServiceComponent with MaxwellHBaseClientComponent with MongoClientComponent with RetriableQuery with SearchServiceComponent with BrandServiceComponent with IdentityServiceComponent with CemeteryServiceComponent with MySQLStateServiceComponent with NotifServiceComponent with RegistrationServiceComponent with KafkaProducerComponent =>
@jurrchen
jurrchen / gist:5736008
Created June 8, 2013 17:45
trait real extends RetriableQuery
with RealMixpanelClientComponent
with RealUserServiceComponent
with RealQuestJobsRunner
with RealIdentityServiceComponent
with RealNotifServiceComponent
with ZkOnlineHBaseComponent
with RealMaxwellHBaseClientComponent
with RealMoveableMaxwellHBaseClientComponent
with RealSoiHBaseWrapperComponent