From 02ae085aed4ba5a1d18a065a0f0e887353e8d42d Mon Sep 17 00:00:00 2001
From: User Infidel <infidel@bsd-server.local>
Date: Sun, 2 Oct 2022 22:26:07 +0700
Subject: [PATCH] Separate modes of tcp handlers

---
 README.md                                     |  25 +++-
 bin/tcp_sock                                  | Bin 0 -> 16288 bytes
 bin/wtf                                       | Bin 0 -> 15680 bytes
 .../kqueue_file_watch.cpp                     |   0
 kqueue_socket.c => src/kqueue_ktimer.c        |   0
 src/ktcp_socket_01.c                          | 106 +++++++++++++++
 src/ktcp_socket_02.c                          | 116 ++++++++++++++++
 src/wtf.c                                     | 125 ++++++++++++++++++
 8 files changed, 366 insertions(+), 6 deletions(-)
 create mode 100755 bin/tcp_sock
 create mode 100755 bin/wtf
 rename kqueue_file_watch.cpp => src/kqueue_file_watch.cpp (100%)
 rename kqueue_socket.c => src/kqueue_ktimer.c (100%)
 create mode 100644 src/ktcp_socket_01.c
 create mode 100644 src/ktcp_socket_02.c
 create mode 100644 src/wtf.c

diff --git a/README.md b/README.md
index 2404d7b..b63a16a 100644
--- a/README.md
+++ b/README.md
@@ -1,9 +1,15 @@
-# KQUEUE Utilization
+# Kernel Queue (kqueue) Utilization
 
 This is your lame attempt to understand how those Network Virtual Functions sofware works as well to sharpen your understanding on C++ and C programming language. 
 
+## Why not [epoll]() or [select]()
+
+Using epoll or select would make your system spend most of its time looking at and fiddling sith the data structures and has very little time for anything else.
+
+
+## Notes
+
 
-## Hints
 
 - Compile using `g++`  for the file watcher
 
@@ -13,8 +19,8 @@ The `kqueue_socket.c` is my attempt on create a socket watcher timer program usi
 
 - [KQUEUE NETBSD GUIDE](https://wiki.netbsd.org/tutorials/kqueue_tutorial/)
 
-```
-
+```C
+    // --------------------------------------------
     struct kevent my_event;
     struct kevent my_change;
 
@@ -23,13 +29,20 @@ The `kqueue_socket.c` is my attempt on create a socket watcher timer program usi
     for(;;){
 
         ...;
-
     }
 
-    
 ```
 
+### TCP 01
+
+- Pointer of kevent
+
+### TCP 02
+
+- Array of kevent
+
 ## Goal 
+
 - Understand the difference between c++ and C
 - Understand how strcuct works and the difference between it on c++ and C
 - Understand 
diff --git a/bin/tcp_sock b/bin/tcp_sock
new file mode 100755
index 0000000000000000000000000000000000000000..cd692d80b6f783158628ea8a5aac70a204d3487d
GIT binary patch
literal 16288
zcmd5@33OZ4nZ8d?o0nL2>?C#;qHH8-6WPv27DFV*3eO<{lf;m)$+G-xi^!6zCEFC7
z#5IHJx+D!03he-yIh0c7oU}8P6k6gm5Qnz3DfFb7t~t!m+6`?@%i@+yJ>P%dy^<_j
zw46@o%=OW||Nj4XefQq?+~wW8(WEGOOe7P#hADuL+ufXE<cvA5;;5jlW_IRgbJ-kb
z1;vb?n{%i%AX)a4F(g^q4V0-UNspNX!Q?goQBE;1CQD(4$7T^cqi_q%C<jXnRF;UG
z6G)$8mGr@qCQg@Sm54)=@d!OaNzXo+i=%AffGnFtV6v3;qq@<rT-Yl&xq%Vxrh;ia
zPnWzcKx=p--a>Fl)FV{l=903U$uY)cDfMoI9>w|BreYyj845P*d-XtNsAZ`hYIVgT
zu4-aYJ;*jyZ(~%~Yq!<0FP|?>(TOMN08@0TZYG_oQHCG+BiMl-^}P*0N(J~)(~>{Z
zEyS-BzkK{A;a7y8XktLQ6O9Sk79>Rj`opvb>13wWKtz{klG%(L^pEABQ{5-BvoHre
zl!LxL2YpWt`rI7!tvTq_#wD0-<z-EPjQ*hVI{YSze{BwWTMqip9Q3*zbn3qnj2wGb
zJWV;|T{-AX5AO~}BVp$Abw(p?VSk6t{DFYp8E2h(G#ZJrs2<qOV)1B5hfpvajQirD
z81u*Vy+Oz%;xV>M->ruMM}y&bD~Sd=_pw+cuuG4#P%svUVskLu!eTnIKqwN^*{+Wz
z^n?y>bAYDQRcs?BkgwXcQUX<o*EGSOlA@^?_atE?g6{?>=j}6#_G1dE>|Q}T&T$hv
zBIFO0HgSmNS?2t?H-j#1li=YDI?Yd+9?GC+&acNZ=$Y&BlNt2P`FA{nPBF=JB7;tA
zfK2@v^wh%%%(EGES|emSmqDjBM5YTFbXrejx|l(yHAbev3_7h<G7V?YizN}|NCth(
zJQ3rT>PqXGOj`Gw_Q7Y-l7r2tuGamc{j_B9a&+a73!H3p!B3GpX1f6q-cG!si=#*j
zUL~Bmbm$z%zfCxG<xoGzzePB8;m~o8KSwxq-Oytk|0?0sWkZKK{uJTVRYM0jevEJm
zd#ID+4--yZGt|WK&k#;sGStBFPZFL_xSQjL2&ZLzsEXtJ38yX@a&kOMICaHPF~{#D
zoVs9$alDyuYWkt!KZCH~7Q(5?hb{td)RJ#_ZuZ>dY4mL0)=;1P^XA_5^?`xSee(zE
zyI(BUy07*?o+WIXlM7Y@s_#By_x6n5ZLjaOYCZjl*(d194JclzCEpwT0!$8l3dS9?
zKY<)QlC->)??lJ+D~_*eqn~&={=EZ#tc(v{`ppZSHaGKplk)mC@5CBUP#-vsC4b~e
zo~`b89DAPBzfM{Ah%K5|{qhNFM8`2t_g(e{iCOi%UKsbDt4p3q{@63xSj_Edy<5&{
zNu|E~rE(aJetEDERjx~pZce_tIr;kF6|j)TdeF<sfx*uq=2jW+nD)TnD%X;YXSHPF
zoUEs#=M5O~Brl)5nD1tTPyhGm=n2~NJWrXn`1Iz!T{f-fCtC7Cy+eCRJ2j%luk}{H
z>p4l)yEGf^r;KH5-6Kl9W8=W)HN){)n|jUfa6{cArs!*R$zN%`iE~<S<Jr-3mtGun
zNN1iGNT`1CnJs-`+m;^GZ8+tvzWOJ^*<8nLH2i60tbp{Vt+^1NrS+PBmeU_*Q~9l)
z+dQ{>?(q0-Kkb-Z#~8KGwuY~h4zISh_^j5q12yi~lBYC>_8sliAJs$wO~hMoADWDL
zK`cl81?|-P>Lu%8)II(>dA&%@)qQ#t;h3UBsNNgjrTKY+9+=wIl*da?pvm~y$~#Gf
z(TlBzPq((ZWM7f|3tax-Z+Vd%)=vF)J+--}oY8*p=XgoVf=yV+)<1A{(C)<eZfn$f
zEo}g4K5X}VV+7%Cd!EtQK6r@`ieKx#q@dYi3(_&rz{VI~3Qf;w*^4kTmyE2r5Pf5i
z<}2FojKvC)LJjC<+5U&tL5LbvJNV`~%*p}p$h<tpo}-$-KttvvEk%P<E{~2Ty>EBl
z^)}mAcG6vpkyrcv=qMjlgBJj4eLe2?Pz;bF(+1qM!mu+v9uQ3fJ#{FE(CZy>Jlo%T
zs^8w4?5QP%zCP0H^}hWatqEH4dzcXq!eCE79NkQg{^L*5Q3P~IzCf!X#2y1W;H9Y9
zU>V?~cNkplA#K2W7&JuTeMpp#iSkKN9v7w2KLg%=fuH4N(tEfSx|o&&-iIwr>q{K&
z^$vUZV&LH_9DI)22XWZpyL)6bQFgL};$57I_aq>#?|}wh!IVB}X~`cLO-%k^;w4BX
zy>E8k^(L7)L}p(9qpbE`FbBMsNp$E}(C+oVnLKmy5eV^E1~u?|y_Zq(Qx~n8GN>&*
zj@H+DS<*W=mi`3jj%Qgb8n@!)*T~Cv;icC*h!73|8u|n`Ke*2Owxj1I_&fOu34IYP
zt*`MMI;)D;Wzgs+ALvQ%54-RB;b<cN<S>aY;r4#`zugJSU+jc#IPU3pB)>&b7vq#Q
z`1lAa^lw1Nw!xF44bWqbp8LVp`ktx!9d8ArSLxh=_IMTQSl};ez4)QMSHh;z-WQ0|
z*F#Fg&{B+(#2D~ixCIm}nioju4<vM6gTW(0jZ+2&mvQ^wBJZG}54d;8Ee508ds#s@
zuk&7Z+&77yY0qHkrTL2qu9%!yxkg6g%lTqxEd1Dp@bz&NtM!HvEEIMUNepYfw~xGh
zI=x<C5r8uGEZrEi<F_kpqdyqZTbzNY?vDq<ZBDT*7G&BMkEe2B-6^)!nHF?sSl=TV
zo{mT&9Ct=qIg#(dW6rhC1ugk(Lnw$Hxw9o03q-<UJrLJhTrL;89?F6cjD!Jpkn>=e
zcp?dJ@rctn1!Tx`sq45OXRA>yh;{g}>&GuckZsldyjlzPC!Edu;(9Ef)rW<*j#wK7
z8Dp9r3Pqf)(MX4L*Y*t!`PhfgP}h|s4q74SzdJg*0_Dq?i?^Yqb0Q^W|5m2#Emmd}
z+U$ohx#ojLXZ^u<Mn|2r5)>70EGpmRDA;2^z}8P+_mSoE=Yq<}E*^JGhrKV-dgm!B
zzQ?p-lH7x1)#eEtp0aT=O^MDJl;j?owmX#M-g!PIEhUV3o|;T<UgE*Y(?zqJm(nj&
z4II_y>0wdQ29XlQO-bJK7?^QKKyZ6$6DLudQF=%OD%*?pSd^w21-oEza|m-FLco&(
zM}0Xi>p3j&{esVx{*IZvFUofDglONdiSmpn&x`VxqI_4BR=b;<m@3LEMY&3p8%24O
zC|gCjTa@>R^0T6RLX@jTzsmT;9gZ^)@?#3^)}t|+QPtJ1Dp$30QCl$X#;-lm?82~L
z8w&02sHAKu&e(TiI=aAg5+M?8TWTmRty<c)VtH%pRV!PU1(vt!i`jhPV?Mif!-loa
zMbc$MBpQ!7H$*}qSc2EZ&gv@Ha#t0rL2xEkilK!i8A*;!ITo|WCKt-c41E)ZjG=$G
zXj6-jSt{B<;u)$ObilLW%dSiXrI3AI45yhGp7O@D7qID7u<6Q1*_NluD-4z9r@0=P
zWf}CWipdI5ouszrsk9-aq~1vxNvUyUmUkg)v0K%HKx}kUxrzuiwg&-zAE0@W?HIr_
z0M%=4{|fL$fTs19hXC5_Dm^9a2a)ByHa=svpM$uVbZc!x02h*OjpYjfZD!m1C~hTY
z1NX6$nBn|=pekKT!L^89=~@S3!2wR9suUChSGou+Y$Jh#)C|n>1ZC#@okUu#6s{zx
zwKpMWDtRzBA+zm5wiiFkM%!)_KLgkN$fR=fgGD+}s=WCjR`e9gM}eC^XD<rE-ctlW
zT+DcroFSn~+cTgYB>ECtKZ;KL)a5p6&@e#LHTiB7wun;j4PO2lc|i%dw#YjG8E=bv
zKzXZF;^qGsnSG8@KylmWP~3$iZlB+Z01BhX><g%U3pc01GLpTLQ!kUO0UjahypNOY
zRFXBo2RQX0sLVkQi^-&!l?;-iE&nShY<onsdw8^;hLp_!dEk3^;FIMjw1KVMG>Y81
ztdz{suGhMZ`lWOgvLe{GF1ruIxr_$N0sO2hiCaeJSn68q3hLUj1IVaPt*eMT#R`y;
zb)9J{Rj>%ZsWgZx2-t*dK7P|Gk+Jex<R8g%12o3D)vZ?iGiW3><xj|nrChB}rO|7G
z&x#=clL%OkjPA}Wnvu;T;7iC{1bi3S8vLf!5%xP|HxRG}PrX|Jlz#^{)(Wrm7_%=j
zO;=t6amLS)8T^fcPt)1{QPWg9T4#vt1G-a);B>?6OV#PNgCI_4pF%$4L1aiX?}olA
z<Yp<i?-$?|%8jNN*bjhxzo5<jJdk4<0v~5rDBDeUBX2ZyF*du^f;A*JpE>V_)BM}0
zQ}U?an0i0*Idg9Sp<r}gzfhe4RJo}Kd_^z44Q;}wsZMI8p8<M+bEq#%Uk1vjt4?Sc
zt!?yJRoZ`vPzo=RAr6+^0S*l!rR_2}yw-0Ece9j+Tk_rDF;wJ6^AYWSJE~<q(m-XS
z3FCa`LFo8}48*_v!Q#wGheTx_uP4taxID_(+|M9WmdvA@3`)1+r`&{98F?AC1`mH{
zI(!b64a@L%P`l0l1>%`p;D#1s3zUX60>tYqB;}*Fx4=IMFn<MK^}Y$vbf>Do&6Rms
z0kKP9n%OIe*shphyc2k3A{MQTMe#}{*jyQiB`W<LEvr^k2BPtxYn#E1G~bz$;#`*@
zGe$$cNBMg`gOvj&y7FeI0AC^GBh}OjGN;nUN<LV5vzXbNyt-dTb^AZCy5awa)n!VF
zvY@Ecq81fTn^9DvOh&hwRxq`wzI1)X+JbcjChSO62dl?;H($vM%Y3k}DJUqwsz>*d
zwy7YiMI?-FpQ6;4F08-^wQ%8lmtwFMRye^fut1k2$zCD(k;tS{rJ%sDQ8bDBCuB8r
z912XLJLbUPRlrNge?h@D04KW;{$#7W{K47^>1I8gms*%<TH1EmiZSSvSxR+j<Fp+G
zI}2`xk*OqH4G+^+Fe=K4O=hJ)1*sEfx`oYj5HQ2SC1)lNDF8~)|FZxpM{COozT%T0
zo63*WqUmN6-4Jo6o1(t7rh?*}GlfxG&2@=}SXg1u=S@&A3_HW!1GN?8WdUKr<CRks
zvO}F&Jgsq>YM)_WU`Hb`Q$ADeYpv_7r16*7S7QA$v&SK+D9Zcj1r%Hj1e%^7I9D0V
zoZ{F8cSORK!M1QDs`Ix<t^iG+ct<Cn=)rIxlxWc__pV-5>5K2{)MKu8ItOO+WBX#2
zzE~Wm%Xn@9yr*5Y;se>fHa)CIg8@S*GtkspRP75)9Abw*&>jrym4VJgYa*P}L{tw&
za#)~Bd{7<ZEm-HqhDI;SDrF-Pg12?S-FOKHG3pYtmF1b_-bP)fSn~4i(=3i_%!;K*
zeVILNv04vV3api8tA$zB%Xi1YD6pzM$|j4$T4R~)vP`eBSZmByt9qi#Wl<lss<nq8
zQ*KrNQL)D@s&$jaWL2N(dYbg>p0=3Oni{jss;+cdpEKJri|^~&L>8C)6I_8q(yuU=
z*{*)0>#$||9;>QtvJ_g?HJf17bQCsrKrLUbA-tvr2I}B}j9TGrIl#Of7Tb?t<~#)8
zbH?v2)_nUtR`s)8=gIhQSk2>B^>CN{_m<h}Fltx~efuFC1u8AmyDjE6tJ>FfmL%U{
zu3M~Xvdc7Af#`ee>;$6sKvY4)Fc%`Z)m~#U<?ph;XH_3Xg)6M;PZ{~F;l^j7C8t}j
z;~pOGa$#GhC~oQkM(=zlo+)D<cg9>`3=h2Ks6X6-rvP<f9k+4KhqKX&Yo!EcR5*g6
zVA#>Po!Sp)Cu3q}+VXQ-EB`uMeCqIO(Q}-tgfS@}nCcvQ{$u&bGs&l=y2v28A^5j8
zUVz*9(1FquSOh8$yXq|EI+J2VDi6E}UeNdsitdKYI3wd8O58#*wgdrCl5>#G7nI~R
z)243Qr>uRJPn++<qKdSF=hz|Sxj8f=OMXjQUd>bBM#xJ)nOi(!Nk6sSY8#}zg;qMy
zFy`YM6=eQUaK9d9{!Z2!{=e8cwPR$5be})kwwnn!7RMcEfUo{66v4GgA{@iO(_3%_
z8D~*2S|be0YOuu@psP)MlMqADzBu#JitgL7ClYPR{7}IlZ`DJ7P(53>dUpD@)!*Xv
zZQt48_4&vYJuCFRai5qc%jk253FuHyAcp13;49GXkCH>5r==yzS|UCk5lbLEM3njf
z!qDi9N1+n+MOs^9_}aloLWq<{?BjtMF>c$-V-M_Q&|q=23Zzq8+%el)+6WsDAOBuP
zx2qyJX%;1qjEjku#lyzW{L!d?A8#?Eb$PsK^JqNvkw+k;`@@M&wx?Z>>L2*{9=kb*
z?Y01Kw^T#oCM%%FV!j}M(8bUO{+1U0fd^V$NXf56_(()X2XRUYYm}gz2MW8x;Em6>
z36jFLOK^uEnb{wd?T<<fr$nA0C_y<54MD+A71Ftsnji=|F;Pm3_zXfimsUK21S>M4
z{b^EK-hgHcLR!l=UTd7M@mjZy*Sam2uXH8GiS!7aUx-p+w`W`Vq#&HnEpk+_J}XKK
zJ6hOy)GSeXxou}h?K_T|!I6~XLP2E>M{#Z%o21om3o?e!SOLbQhqQ=nmXxFv`I4ZR
zSk<E`rU1Sw%JZUBm>h8_Nhy-{v^B*O0G)^_oiYjx_XY{RCP*f>yFtQfXX7k=Ux=qg
z8U!U(&;<phwW37hNRVz_DJg7RcS|k0+B8JAOYoyYi$XM*>3qD}jT5NR4rENK6J9z+
zNlh=|r&AH!@f897EJIAf>AH;Tkq3qNQz=UgHc^M^sTLSll}5q3IVG}{uF@z)(j*Bc
zQlxEn36QS4C`~X%BrBN`8RuS3<SN5RYCqr+xE#K61rg*_At$38hS`HDB`5&-K1=S$
zBwtQ8$(Nh6Y`(;0Ddpw1Nz!q~<Vo`77Al)B@xN43pPJcQquFx#AeiuVZ1z5g)@!0?
z@2eK(u(J$w1y?)t0Ze9c15xn6qEAIK)Ac~ezFXdk2_|(g(L1x~v@s?6@htj2&=tJZ
zbBfm*V(c<nhl##O(B;1Gu&`5A=mwNdx$5<Kh)}(Tv*M@KPr+Bl|5f5n8v*nzeiY|L
z$5{F+pik8PAWulAt8Tg~%Wlu#<)B-5#mCFjb@@bgKEmnt)VnQi7FkUWdAj{o@P%&n
z`^6nO?C>uKCy4(axO@@5J9kT$yrkC*3NC-;dsxZ*7tkk5B%}QI9CUgqHIY1Bx=%#^
zPtc2T8j-KXq>EqYkf*l^6WOt2iJELGOkZINL-hV*B6(VeC!#OOL0_ALz6tb+zNg+w
zbQ5-mlbd9fc<JNxGFB|+g=B_u*bngbnZl~F<Y{T1O!Lw1<|gEp=!qQd^Kr-*XMFc9
z{oX6=tQ7N+e^UTvUygVl0lmaDzQ4YhL;l$u^Z~MiewQyz<@zuOz9*aV#?6aYbJ%%3
z2c2#ujMGQ@%s9dE4N|dq0^jZha5~wr{f4c+&Gp;1<ILsr)n#BUIA*lb7vMN0b@=e<
zcUX@>1c$1&P^8%(^0mYx(U{Ml*voJ$(izg}LzQYqR9~=VFWzalM)5_uuO-pZu}^yP
zUSG!@ZQSbF;`K=^Z8MOvxho#%^ci2=_^OuiSm`*7Ln)n<=&(Xxz3co;Cr(fNxRgyb
zBs0Ve0-d^i!Ol<|r%XC!`S@X5SQn(ao!5J|)NcSUEj`YhRKNE6MxR&n85Ps&wld$f
zn{TM~Z1&x-apN}ccHeeS?Pjk}oT}X7lldy~p?(_YpV+5S<3pY_?$cZRaliPaKTW2u
z^V67dZ$O{-r)kDV`)Qp1Ga!u_-~FfY^gkBx5s~VrSj1-xDDe*iX$_yR83#(EG5Eok
zK99;|Z{M;(^taKeX`b<|l*Cu^eii@CVEhMyWL2e)@M#ir#rAc?{mm%jQKM{^5Khs0
zw3E5`4O`sb#$4_GSUYpI><dH5C~>5BwS^Nd@fpY%#0MUAy$j=nxo8YA7yfqwIlq~4
zMI*d7Tzb3D80+o0bx2{%#YZ#T(4gkt{2jpnJVfG#MME162T@$I(?4RkTJ+{b8^$3%
zO~HH<D8F5itmfvZzFTraxXzX^k3k}60}0|XTY|!@TnYcSat73~^kVNJlF4lVf{^{)
z6Uk<#c|h>NN=m=n<OXKE8>ce+EF$;2#G|wnKiacO|4k-0Fvgk$f%Z|9q@G-FCB7Uy
zyfaGaGt~_Y$++fY7e&D2gFvZYPBKXA@FP*_Uw$8UQ8<tXWRj(nUH=WBVXrOEDNKH^
zwO?$+7jdn0{L+ssY2QlUf=OI{5B8+cm*<o0_=Q>K13;nH3WEH;?1Ipj-=mRCDSp}Y
z4}wN@qL<W^<oTqNIu(g@GLvj~NoxU+sejn!=B&d)-<j25#X?b*kt}_=FQ6}eDaC~y
z1Eamb*pvX8>0h3o<_p21vEr$5B+36E^kw_Y@61*U{pDHl%l4D{-C6o_e=7e!a;6j%
zWp?`=$<n`9>~HTC7j#Wo`q};;5&B}dr}q7WLO;8`vh|N;>C5xh$X}^X=NTG1(!bp2
z+r=ieNwl9Bj;Zk{<N9irf4Pru7X$Ax@H3N)UzX2<NiI_U<+)8<97;dZhSZbzDF8&1
z`f@*CF7)L(A?366&wxSxtE7M^rT+a{bkQ7KhgfvOBx#wVPYeGCGKmw&(s^$p{Uu`I
zekp7IWXt|KhyGh);1<Y<A>zo^AIYJA`3ggU{$nLGW$T+k$fl8e@q9z;c&0Mo?DnVk
z=%k<B{{2FqKAg%-(w8h}3jItOg1rk33ca+?Oj1wM7Ut03Azl>88#^hVtxtGXh+MRt
z9*ju$3ja>P)TFZha$M$tCdV$oR2p7pfbV1(&-PE#d?NifRvP;BL1AXfLfQWS!<N~|

literal 0
HcmV?d00001

diff --git a/bin/wtf b/bin/wtf
new file mode 100755
index 0000000000000000000000000000000000000000..718c59865554e09a270496e7f8442c58ee094665
GIT binary patch
literal 15680
zcmd5@3vgS-x!$9rmmjh0*h%a>i1H4F$aY@jVG=2^!g1;l*Rj(C2(m04J0iB^>X8Sx
zU<YHUY677t1q$~PXs36e+!@*#+7u{p8k&T*v}w6RGnBR&F7(<B?M+jlF637C`}gch
zvTRX0op$bewEMsJ-+v!x_ndXFw{eq6Q3{wyCbo_#fDhZ;oMPmR4K3%Wpsiwd=4Nx*
z9A*W@jGvoxs5Bs14v{e=S=tShsVGU0nFPV)HULphF)$`eVTSu=5j>-C3(P2;r3NZX
z#+;l$`sAymJ4@R*U6z%?j~eNZ&?A)e+`_I~=*hB8I3`QkK585Nq}@uB8yMkkDwxLe
zOvz&bTGQL{Ai-aC7y@5)xH%xpnFg83QtEvQdgSNFO`<uhx+~PK@7Dv>UBM-KSBEPW
zan+IyY6sb-=531V`i5=w?CY<Ur|HC#bbx6(#Veam{al8h4L_>01i$P=@+2d|$m^tb
zQ2o@;G%ySCE5dIQe#Q8S&;S~r$oa|R$!ta*`ptRh6?y2Z^3a2M=yUVXsl8<w-K!?I
z0W#W4Wj%fq`M)d=eP<r}C-cy+%|oX+m$3@AILDvnJo1b3(3u|I8;VB4%;)QgMmod(
zZk_o90lg>Adh}>C5@k_6u$TEl;ZWQc?}{;hT;Cr8GZBxmJ^Eff3^*DJ$2(Xo64;~1
zSyw0)*Tbwm6b`aLS0tvhJ)cSF2_1~~0FBpc*d~llU#)9}1Zv<M7MAQkC5@>VYs4`U
z!FvG8`S9%GTQO8smJqaOIBsIM3;APZZ5*QUEXOPnhO+3=Hqp;y(P^B^bT*4lb4jLi
zS@i66?tB(Kd!7$x(a9&7E@siwi#wR3S#+9L=_LA{Y|vbj$(}{0xhGR;7M<p$OqE&m
z?0M?UqRUv5j@JK<efVxfV0bd7yw?Ac{iHO-%hU=}k&~qsn2|eXy8#itn|LGVQ%DOw
zC<IPjF>;pUmk6gW7#ZUDZwaT+k37TiHwmYZj~wOr>x5INM-FrRXM|ITNBTJa1HvgR
zBRw4d9^te+jkIz6Il?K#BTXFtCgBv?5jV%5BD{$38je3fIE8Y=$?-1}P9YpA1>UM9
z-}Zdkv)$9`Y1!7)ko-&I;QEHZ>Bd9zPdD_xRI2q~dl2$0VQWk-*bk_o|CHT3kh<O8
zFlf~Vh7z-n(US>Kyjn~CY50}Dq*5dIz_?@foyZa4q@@;WTK|yZ_?DKs^X2%D`~F-V
zAHMLr7yGPk=J_t=4XfXawH~9GI-W@W+><<0JLGucc~bulW&NYJXhH4E$0#U{Cp`VP
z*%u^cH4J)T+<Ue@c`Et3C)HZY?P-Hs&T2`eq5u1pFdF^(a536gpG-9--)~I5IeY~y
zWUvABTJrSp!|=I7`a32b7%Y`qvh|FXOq`YNbPT)=Bc9~t<3j~*HvGo_rc%e~q5eE&
z+Lb385ACsO1HaIc=NcT^_q7wFYWzBH?fahN)VvF`5kF-tTk9WH8XTKWH?F=IpS5|=
z{2n*dKWd7;TA%!HZ7^|G8*Dw3I(y-z;q|gI&x<6~aOJ5jhr+fk18CdDbZrf_zYvwp
zb<9TKPby;tWPRG|bMaZ)p!t`1>%;7*ywP)$XP4(@k8jsW$LxB>C_dYozC${^+1iz7
zv_m`4;vp@0LUU+8)K2_aO%&0@x^dUYB{N0<SdNBs+KCU<3)aJEd;CqRwUWZse=-Gk
zOwkcE@9iJad^<)DDD7Ix<K@Q?GCsBnjuRnuzT@!8jt-aXE0TYa%OCtbFOnCv6Te?i
zG1rt++E4!yFH2jn2@ARUeb+u|b7FjVwrYcxe+NkOp~dq;4cy!I{3>$t-~~d+f35$5
zg0RIFWPG53jWOO0O;4)gB^YTZBdgCv-yWv<hxnbcYywH40J>Rj{Ud9|B-9SR(`04r
zw0CqG#`$y9@)v2y9H*sac*^BeD(QW<|F(D8fr{gQEWyZ&ewa$}K{b31kalQb2%|$g
zO^QrA?WPrjof<d+qUrR&ODKpi=pA)@d#K~Yki8>0@I6vEbcpl@z3)Cp%cPe4F=oVr
zFgP%TitN}84i}^=iU5M-i?q5y>?qLF-gBfkJRfk<dl6jiA?@_QS<ESr;mE+b40t{R
z4rjoN8E`ZMGQ>q#uuCw>?RFS8F=<Z^ybc8m(+)jL6%KkYdia9j;oZ)`=O~8o^{o$5
zss7PaqT={0YSRj!M(`d1q#b(TEDu6jpR}~(PmOLMH(=s%NG84S^xyVQ+RX3&EX}ll
zdD?rKL`RN7d(it%^3?J9sEhkDJRkf)?_~t%#CfZx3~Nhh=dTU2q<45MeIe+MZ?g_`
zK-KYe<m@rjGUy$K3-<yVxt5zBUh93=G4LkpJHDNSj)0{dYCVSzeTKJX*yzhWpeMa=
z^xyVIDp7bmN}{W{y*K{p9i@Dnj#>-n(DWOR-$kw-8cn4xY#ke*#pwXWSD@#g;jI}q
zdYkt1h||}ghKIv>Z4f{7!x7jr`r%P<`n{JG^v_!FWygIj7&jxA5irN>KI%M7-~);i
zE7NEyzKkz+#=?$m17H7ASdBN1Vj-}TNaCV4xNG#~lbQ7ZlN`#}V|)b@!q{GTo13>b
zJ0m@MI27)5ie09c_NGqSWM&b?e$?L`NrdChNQX15?{o4!YHW>jL9mc*><VGS>fG&*
zIfJ2CAQBGifw&%I*F#QVp-32DH(3pZT`m{%@ZGSe*J<pDjfw;k)%`)|f?E^L_5*P}
zhMj~mLtR^mSRl^q^82Y29mPL`=G=sm&MB0XTbr4(zf_q~Y_lK6fSeB+oe_s1e~|=A
zN;j2MZgv#yv-h#})7O4t+5EXgCcAiyut~6YC#@r%lG3|O8z*7u;|WupCxOx`Fb1cI
zNokK!@bejgw2h!NiRX;Hg(Z>_#sg1nCO0qT9=FMC;IiIhf=?SMN_QJYdT&a8Q<Coo
z49qx75`0wbb17z&nuMb=UbJ_iG|ebjjm6C&48I5m1dhgXT(<L~z|RSPh5A3NaN|)o
zQTmpM?<rBfCd%K4@_kWSZEmhURg?=wxl)vyM7dp*9irST%DY5)N%WueMV#@Sfi6Er
z_Fg?2qk&#q>#A|pIv00_;%@wQC)!;Y`)j(o_I6iOwghLwTQEgjU^<BqiFPhAl$O*i
z>0G|7qvM(t9ZLhtI`k{qd{M`IcHPE}Yn+Q^l}(XoJm%aO>FR<d)Ow|}w#K#0Rm1Aw
zoQaiV2=Rw)dJLL{)45|%wndhPz6nFa(7#v2&>{qWCt@IRsV7SZYBuV!D^o!%W{-+t
zGZVv5zEK+lZ2B44>+w^z6{zyat=5BJZa`*P3O%c0vO-iRspbNeHdK_<TPPzbHIB^k
zK13~ct9lTK?H**;5TVZYAi$phG%vP20q_(+^*Y;s0DK9cX}#qkfHu2I>$LqKvVvE~
zXUz615U(WN4Ym=0i%7T5@~;4GX4{7-ZX{+CuVW`M!-WSxReF`8>)^f8yB5TvK2D;h
z6qN#3dI>D<B!Pnz24?vhW#+=2L|Ua3uOO*4+mSPsYB0AUv+Y5)A3tp1_M-SDxaLPD
zRhl0x(ScIq%@47Xr%*ly-2AY;Bm{d;5&Y#+#zS(7gsN@Nf_9MTSKEeA^x&s1vr$09
z08Q%(-6(7krRW7-{uX&r8MwB{djJ`aMFXIMl`8QHUq@!2qZE<f_BrHtF^Svfcff(-
zC^Gv3if?ga2CN|2g`9esWDW3sqR#s)$xbC%1AKr}4}!`ZRADKZG_$f{QnVF*1BGp$
z@OB^f_FhQY43Im%k2^kDjzSyQ%Jvj;>(X*EOS?wvQtFrTmB>n9-@5cZ4Ce|OD1G=@
zR}i;?&Vkgm*5%Z-6@AF4PpvD7JH-l+l69?VDmAbKzo|5cstDMOY(9R|s*$nE4af`a
zZh*!(x4PA;uYg8kQ$9dOEah5tDve$f>Z}?8Fo}Tm$mrc_RXehI1U!k%MZk}ct;TO!
zJz@WYY%2k)@pQWZK;;i%W4frd7!}wTo2DzTf;i(>$PE5M!KdkLzsfX~j;2{62Y{{?
zB6Re(FHxu44uUwH-Gh9_gUFC(-VXi$vbi}jOWAdUP`N_+lqm-G17ODmZT6!;?#L4O
zEW1K!G2M>5)zr(_><$aoko<h+yd9Mm-b9^JK>fzlFCw2acPj`*sd-0*>I|UD_5tt}
zz5FJ`gilkQ)XKjAw2yPBFUwyB%BQPNXa%ip^!QYE{|2rUUm!yqthgB*8bnIxWpH?_
z|5H>qOKDnzb2%ln+I+wEMLU{hzQ2jeRujhg%!APJ2pNb!_0i(YN#_J*9&abl$hiW_
z*xWB5Q?8yzZvrUYh@Y|@t1|KmiUxOoXU2UFR$P?s@1VHN|26!%BrGgYnyL!jFn~0d
zGUY1UAHY8juy8qF^}Y+xbc?E>nuP^94zUYhn%OJx*shphya#x7A{MQVMe)i#)LtEk
zC93`1!IjIa1JQWMwaws0+HXlqajwgd8KWWJv;QNX!AhTr-qbQQfUgjJRyQCtxC3NP
zr45vPu=22&**m<sUq^F?z)Uw}jPumo@c+Z+GNnveP*QGDOG>BBC@E7WqgzeOnOf3N
zzP@Tr(b^&tcAlz(HDJ7(7xKa~AMABSMMYTk=#{5!D#&UH38UMmC=KO{sxU$=T)5Ds
z7_3EAPOytC&?QN-S4{OtWKy|ORAksFnZ)ZSWEFHA3QVFq=D^@Jz{{xqqM~&GC%fSO
zWUIUK!3|Zin)Rr>+`>%LGPWz0k3px*QfkXvr|l@(S@dZbnM%U7sA1Z2MnxsD$*dHp
zB6Z?Sx3HNG0%lma<jmw93V<^7|15yYkqwmuU-5a6O_ld=K<H)@-4JnRLeWrOS4Do#
znZhVmb6p}3i>eIzyb0QcnQBz`z=kTSWdUKL#)VT9vO}F&I<0k@YM)_WU`G&`sgSAm
zHP*FO()erag;@X0>~Tmcit-_P0R>kBfkyR5&Q->;r#N=O-H~v0s52ai>ipw}D?rmH
z-rd9JM<^WVN(A-l{i{}1`{D<B^q6Zmo%eG2u>-McUo4J8YCOLHzT>T2{*i27ryka$
zp@1Qj?Pz)}s`UjXcCp(Z*c}S%)q$QwM<SfpL{#sJ<gq}F_^39<gIFrYx&}g^S_X*_
zd|e9d#kV7fQJ0vltiUAqHtJHvQc!50W^t@DE0z-VW%jhiYQ4i!WUV$^EzGK3zC8{`
zkyRZ~Hd`FlI?H62WqO^(T4%Oe)nmObi~5*V-EaqFDy{0>ial;ot(z?-tNLv3)1+Vj
zw8f;>)tPNpb%o3NoY{_9d|&TovUv5sp(=1l`W5Cf+tn9(4_l`1v#Q!=OR-g5y%|<b
zM_^+I)C$!)!t3f_pdK}lQ7bB22C!g<#rAWUc?|-nbH*i$wa|W-RsB-$Yh?U)tnP8E
zdbrnq$ue8Lh!&PY-+l*<0@ar3{T6elRXx;uh9uu(t{bdsvez_Mf#{#unF&Pif~bPP
zFc&<z(OzdU74EVB$*Mkv23J|tHyG7f$BoZIB&S<H$!mDL*M)7FqPVFG*czHr6V8+|
zk2_;7Foq{Ud(<Be;weB~SkG;&``c`E=>B*DGb$XxP%!Lh+|Gu-%}&<D%(ms{wpM&R
zTYT#9X3=w;nuIYaADHSKdj4biC@{&VrMlQ4xgq%X1~0&E{LPNi6IeJZ54-9t<&!4G
z@Khdn;k=;n9TdF)GUJSl_f6t$6JuAy0ZMWX()ogte4Vtp-*%7nkmX+UeOOeHmh&9%
zX|lGZM3VAbGV*GHf@*}ktS5Vmm#w#<U+sjnx7bPt8peElqk_!e6}nZAGJg;22>&y7
zPP;L(yL6vF+PRkrI2QNELjk_}v#tnUn<T<93_LxEH-m8&1*0Rvu&joHz5u;(#5eR9
zoc6_;msWJ&j(w46F#E&0L2lN&{GfW8n>{;y+Zt~0`dW52d3`=IMb8R-f7~bL$x`|}
zKLH);3HY#VDe4OB_D88gpC=fMvS7r=Jz@#C2anR<?G25dcoZs8U!<cWhHv#g5`w4P
zV;^_S@NwII?t5TAg9eKuDv-{<Gc+DP{{5`mAEK)S<eW5%l6!{bqt+)Pi-(P$`J++)
z0Uj|Uy4+vHJQ`15N(gl6{&1p)?c1$K^^bgfkKLTZc4vUcEgeX_$qMMPm@mX1bTP!h
z9}MbrM*&e6Qu1;GABo85AWlhPtrC>;Kw&o<yz%)qK~h+Y1a}CMnf*~|c}!wBCGrG8
z3Cd|`2nv3>kd;fR37nu46QzuZ&md%SX~iQ*up&LWHABkC8_;Y)$Y}Y-YmKXGyw*+Q
zwQkB+SEdo;L<WS;uSKb_UAb01F9@&Y7dawWUlOH-9Vu=-VwUKa1=-Gy*moQ;gCi-=
z2#(5{j^NxhHc6{L5M&IWu>y?A8Zsg>ENMw8@}!`cSj}T;rU1Sv%GX4xFgfDVl2Rm7
zQ*)Xp06Gy<I$;zT?oASWRgg?<Z<B;Gm5sCX6Cs`vX%dulK`$sMtq~=HBSCuWN=aek
zx?5_|t4%|sMS@oeEppLdX7cfBpPE38b|7O?y{M%}loWaiKb`jA=5Gk_msw&G&a`D*
zk31;EpGsS5vWYfKPe))}Q(6V<(`k`rdX+{gk|9YjktS`sO@Q>ei_!#RM6!};k#W__
ziCkkCN$&?d0++*At{{S(F63mC!!UO+r3D4RKUyJ^`!UIvlTGsF<}8;laal@vxowhk
zoH2Qle7S|n<xBjpmDHzZ_J>riTp<W1d=1Op2hn;>^xS>bqC9q%g0A4zj<d84P$szn
zDtKVgRg3I&JrJ_*lyAiZlRB8_O*wShm=gVP4*dY=3clXCC$|A2*hsVv6I~N@yPzLN
zNp?z$+=5~h`P%g;*wn7YIsVh?r{D(Z%u=^uK;+*>N%oJHjHSN<`b6<3wTbA)I2<3(
zw@6`vIDe3bPVdbplAq1#_Vl+cu8yoWk320s3T~9TbK<ZikDXn4>=?^c3GOAkWtF__
z=l09f-&-Z~VbCW_B&&Qf5B)oN=x6fK&w*Zw(}?^mCad^0$(xEZuOtQI?L2n=n1`-n
z>6*y@GSDZww_8PYQyHThO4*5SkCd4zSdAFZlD906{T;krQ&>}uyvF4*k8EykLT+Uq
z$>aY<$d_i_FP8Pvr;y1Q=TpQy;@|wiY{}yfJrl_P+&G8x$kRuNiQ;xI*+GBFkDYQ}
z&q3XjO$Fn|^TT=U&{v*`?9<x><J6Ej>rHU%f>bP?z@4=KP8Azlwl@138@9FJtmO06
zXJJ7c4?5}IF-|w#KHNGE>oJJnFx1%<Y4>;eg7HW+=JO}^GrY~{>C$oO1NY{M>I((;
z<6Cq`6gQuJ!9;iW0a=sx`g&f`re@C;uTNqbn}M{=eR0D<I=kWoNyi#GS<sbgogcu&
zQHP&xa;b)7mY6}HBa$!F(-p^&kd8z?elix;1*v}L^`0#a8^Oy+k25FLue-k0=hb{h
zYqa`i=DV(O>jqDwZ|kN_+q^Bl7SD!8uTLC-+~SIMjkpD#!TFW$3~JmJ&)_~i=#S%g
z%a8GNNj$?cu7PK8x>%mUGWXDV$EL#_i-<#`xMrTw@cG(to->-q&z*D|D4X4~Wuxde
z<I+%uXWZYB_zK=r;_|z3eO<C@GAHN^iMe72y5s(Kl<}xh?v@Y^v3j(Jx%dmNxWALR
zaM@@#a|I8Cp=6XeQM)?B375EqF$VF0N1f?H&odW|3g*I%d*nQ#u4shE*QM|F8AEnA
z4*hA2x%i+&H8eJPZT{|105wG7hDAdgfrBXCantpES5R+HbYf)TW(cN@K>5oJ$!c$p
z>U$-p3vZJp%zcmuVjw}hOO~K8D;KoCvz!5aETMSzi)3;efFR`FFCy9OG!F<ajHLA|
zO>SVuw`nRh%CeH&Z%Wb<0JLY6^|zVaz!+;21i25EdUD;A_%g`in@w8(n8^){v13C2
zA>lC9L7>#HBq5}=_|Y3VS--r8)g&son}o7bZu>WahrO;mCop+0>YUJ@D|Ds5vL0E|
zzLD-+Nt{{Sh6Xu|B+m!A{u^Ap-vdClHwc2f$5kWrn}ow8Q;uJ5`$M3S2z?}`)Ms^z
zk{4XZfQ($WL(+l(vh|M&{iDL*MJXuC(wvemmu2hA=lfwAR7fqNG%$Lmk4*`n+4}PQ
z@|O5VtK9#$%Ju(WguaZwyytaED1KvXb-b=@Qh$!V+#kySUz?dN3^=#``*ZY%#Qt)K
zzN8|x@jR2s{*#nP08smB3{#Tl7^etSZoG2!pMXxbzC7>Ld`x{hPf%CO`sF^`E%e*S
zIFcBS>G3E1`X+eU^&c&3BXR7fdBHws6zN?0FU#k_$<~+qtHolIB<qm|q@Ki203e$5
zU+(i(34OUvNcmj-Q(#d2HBvy7QvZuNbdsecOM1g2Va^cQk3{`_*+js(vUIg5mqsd$
zG})29pEG}QWq%8qTpH<>&7d4>tDG1HI!<;J^ojIm&N37x%Z|^ZZ-(+j`ZaS6g=d7G
zEOO&d-?2$QH~!~^K3!bOPO>gp&J_CDG6d@j3<`ZT&rVWL(iY{>-~S0iqBKV#2j#x!
zxX2Yhca@><7WF%UUV)!%zZ{nZpvkcdFrChbfV_}nJhy(DW)tb(Ne@;ey3m)Ma!~ev
DOU{OG

literal 0
HcmV?d00001

diff --git a/kqueue_file_watch.cpp b/src/kqueue_file_watch.cpp
similarity index 100%
rename from kqueue_file_watch.cpp
rename to src/kqueue_file_watch.cpp
diff --git a/kqueue_socket.c b/src/kqueue_ktimer.c
similarity index 100%
rename from kqueue_socket.c
rename to src/kqueue_ktimer.c
diff --git a/src/ktcp_socket_01.c b/src/ktcp_socket_01.c
new file mode 100644
index 0000000..2405080
--- /dev/null
+++ b/src/ktcp_socket_01.c
@@ -0,0 +1,106 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <netinet/in.h>
+#include <sys/socket.h>
+#include <sys/event.h>
+#include <string.h>
+#include <unistd.h>
+
+int main() {
+    int socket_listen_fd,
+        port_num = 1339,
+        client_len,
+        socket_connection_fd,
+        kq,
+        new_events;
+
+    struct kevent change_event[4], event[4];
+    struct kevent evList[32];
+
+    struct sockaddr_in serv_addr, client_addr;
+
+    if (((socket_listen_fd = socket(AF_INET, SOCK_STREAM, 0)) < 0))
+    {
+        perror("Failed creating socket");
+        exit(1);
+    }
+    
+    bzero((char *)&serv_addr, sizeof(serv_addr));
+    serv_addr.sin_family = AF_INET;
+    serv_addr.sin_addr.s_addr = INADDR_ANY;
+    serv_addr.sin_port = htons(port_num);
+    
+    if (bind(socket_listen_fd, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0) 
+    {
+        perror("Failed binding socket");
+        exit(1);
+    }
+
+    listen(socket_listen_fd, 3);
+    client_len = sizeof(client_addr);
+
+    // kqueue SETUP
+    
+    kq = kqueue();
+
+    EV_SET(change_event, socket_listen_fd, EVFILT_READ, EV_ADD | EV_ENABLE, 0, 0, 0);
+    if (kevent(kq, change_event, 1, NULL, 0, NULL) == -1)
+    {
+        perror("Failed create kevent");
+        exit(1);
+    }
+
+    for (;;)
+    {
+
+        new_events = kevent(kq, NULL, 0, event, 1, NULL);
+
+        // printf("New events ->  %d\n", new_events);
+
+        if (new_events == -1)
+        {
+            perror("Failed create new kevent");
+            exit(1);
+        }
+
+        for (int i = 0; new_events > i; i++)
+        {
+            printf("Amount of new events : %d\n", new_events);
+            int event_fd = event[i].ident;
+
+            if (event[i].flags & EV_EOF)
+            {
+                printf("Client disconnected...\n");
+                close(event_fd);
+            }
+
+            else if (event_fd == socket_listen_fd)
+            {
+                printf("New connection coming in...\n");
+
+                socket_connection_fd = accept(event_fd, (struct sockaddr *)&client_addr, (socklen_t *)&client_len);
+                if (socket_connection_fd == -1)
+                {
+                    perror("Failed to accept connection...");
+                }
+
+                EV_SET(change_event, socket_connection_fd, EVFILT_READ, EV_ADD, 0, 0, NULL);
+                if (kevent(kq, change_event, 1, NULL, 0, NULL) < 0)
+                {
+                    perror("Kevent failed to maintain connection");
+                }
+
+            }
+
+            else if (event[i].filter == EVFILT_READ)
+            {
+                char buf[1024];
+                size_t bytes_read = recv(event_fd, buf, sizeof(buf), 0);
+                printf("Reading %zu bytes\n", bytes_read);
+            }
+        }
+    }
+    
+    return 0;
+
+}
diff --git a/src/ktcp_socket_02.c b/src/ktcp_socket_02.c
new file mode 100644
index 0000000..cd36ef0
--- /dev/null
+++ b/src/ktcp_socket_02.c
@@ -0,0 +1,116 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <netinet/in.h>
+#include <sys/socket.h>
+#include <sys/event.h>
+#include <string.h>
+#include <unistd.h>
+
+int main() {
+    int socket_listen_fd,
+        port_num = 2339,
+        client_len,
+        socket_connection_fd,
+        kq,
+        new_events;
+
+struct kevent change_event, event;
+    struct kevent evList[32];
+
+    struct sockaddr_in serv_addr, client_addr;
+
+    if (((socket_listen_fd = socket(AF_INET, SOCK_STREAM, 0)) < 0))
+    {
+        perror("Failed creating socket");
+        exit(1);
+    }
+    
+    bzero((char *)&serv_addr, sizeof(serv_addr));
+    serv_addr.sin_family = AF_INET;
+    serv_addr.sin_addr.s_addr = INADDR_ANY;
+    serv_addr.sin_port = htons(port_num);
+    
+    if (bind(socket_listen_fd, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0) 
+    { perror("Failed binding socket"); exit(1);
+    }
+
+    listen(socket_listen_fd, 3);
+    client_len = sizeof(client_addr);
+
+    // kqueue SETUP
+    
+    kq = kqueue();
+
+    EV_SET(&change_event, socket_listen_fd, EVFILT_READ, EV_ADD | EV_ENABLE, 0, 0, 0);
+    if (kevent(kq, &change_event, 1, NULL, 0, NULL) == -1)
+    {
+        perror("Failed create kevent");
+        exit(1);
+    }
+
+    for (;;)
+    {
+
+        new_events = kevent(kq, NULL, 0, evList, 1, NULL);
+
+        // printf("New events ->  %d\n", new_events);
+
+        if (new_events == -1)
+        {
+            perror("Failed create new kevent");
+            exit(1);
+        }
+
+        for (int i = 0; new_events > i; i++)
+        {
+            printf("Amount of new events : %d\n", new_events);
+            int event_fd = evList[i].ident;
+
+            if (evList[i].flags & EV_EOF)
+            {
+                printf("Client disconnected...\n");
+                close(event_fd);
+            }
+
+            else if (event_fd == socket_listen_fd)
+            {
+                printf("New connection coming in...\n");
+
+                socket_connection_fd = accept(event_fd, (struct sockaddr *)&client_addr, (socklen_t *)&client_len);
+                if (socket_connection_fd == -1)
+                {
+                    perror("Failed to accept connection...");
+                }
+
+                EV_SET(&change_event, socket_connection_fd, EVFILT_READ, EV_ADD, 0, 0, NULL);
+                if (kevent(kq, &change_event, 1, NULL, 0, NULL) < 0)
+                {
+                    perror("Kevent failed to maintain connection");
+                }
+
+            }
+
+            else if (evList[i].filter == EVFILT_READ)
+            {
+                char buf[1024];
+                size_t bytes_read = recv(event_fd, buf, sizeof(buf), 0);
+                printf("--------------------------------------------------\n");
+                printf("Reading %zu bytes\n", bytes_read);
+                printf("Incoming msg : %s", buf);
+                printf("--------------------------------------------------\n");
+
+                char s_buf[1024];
+                int len;
+                char *message = "[+] Hello from kTCP\n";
+
+                strcpy(s_buf, message);
+
+                send(event_fd, s_buf, strlen(s_buf), 0);
+
+            }
+        }
+    }
+    
+    return 0;
+
+}
diff --git a/src/wtf.c b/src/wtf.c
new file mode 100644
index 0000000..9a6fff8
--- /dev/null
+++ b/src/wtf.c
@@ -0,0 +1,125 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <netinet/in.h>
+#include <sys/socket.h>
+#include <sys/event.h>
+#include <string.h>
+#include <unistd.h>
+
+int main()
+{
+    // All needed variables.
+    int socket_listen_fd,
+        portno = 1815,
+        client_len,
+        socket_connection_fd,
+        kq,
+        new_events;
+    struct kevent change_event[4],
+        event[4];
+    struct sockaddr_in serv_addr,
+        client_addr;
+
+    // Create socket.
+    if (((socket_listen_fd = socket(AF_INET, SOCK_STREAM, 0)) < 0))
+    {
+        perror("ERROR opening socket");
+        exit(1);
+    }
+
+    // Create socket structure and bind to ip address.
+    bzero((char *)&serv_addr, sizeof(serv_addr));
+    serv_addr.sin_family = AF_INET;
+    serv_addr.sin_addr.s_addr = INADDR_ANY;
+    serv_addr.sin_port = htons(portno);
+
+    if (bind(socket_listen_fd, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0)
+    {
+        perror("Error binding socket");
+        exit(1);
+    }
+
+    // Start listening.
+    listen(socket_listen_fd, 3);
+    client_len = sizeof(client_addr);
+
+    // Prepare the kqueue.
+    kq = kqueue();
+
+    // Create event 'filter', these are the events we want to monitor.
+    // Here we want to monitor: socket_listen_fd, for the events: EVFILT_READ 
+    // (when there is data to be read on the socket), and perform the following
+    // actions on this kevent: EV_ADD and EV_ENABLE (add the event to the kqueue 
+    // and enable it).
+    EV_SET(change_event, socket_listen_fd, EVFILT_READ, EV_ADD | EV_ENABLE, 0, 0, 0);
+
+    // Register kevent with the kqueue.
+    if (kevent(kq, change_event, 1, NULL, 0, NULL) == -1)
+    {
+        perror("kevent");
+        exit(1);
+    }
+
+    // Actual event loop.
+    for (;;)
+    {
+        // Check for new events, but do not register new events with
+        // the kqueue. Hence the 2nd and 3rd arguments are NULL, 0.
+        // Only handle 1 new event per iteration in the loop; 5th
+        // argument is 1.
+        new_events = kevent(kq, NULL, 0, event, 1, NULL);
+        if (new_events == -1)
+        {
+            perror("kevent");
+            exit(1);
+        }
+
+        for (int i = 0; new_events > i; i++)
+        {
+            printf("amount of new events: %d\n", new_events);
+            int event_fd = event[i].ident;
+
+            // When the client disconnects an EOF is sent. By closing the file
+            // descriptor the event is automatically removed from the kqueue.
+            if (event[i].flags & EV_EOF)
+            {
+                printf("Client has disconnected\n");
+               close(event_fd);
+            }
+            // If the new event's file descriptor is the same as the listening
+            // socket's file descriptor, we are sure that a new client wants 
+            // to connect to our socket.
+            else if (event_fd == socket_listen_fd)
+            {
+                printf("New connection coming in...\n");    
+
+                // Incoming socket connection on the listening socket.
+                // Create a new socket for the actual connection to client.
+                socket_connection_fd = accept(event_fd, (struct sockaddr *)&client_addr, (socklen_t *)&client_len);
+                if (socket_connection_fd == -1)
+                {
+                    perror("Accept socket error");
+                }
+
+                // Put this new socket connection also as a 'filter' event
+                // to watch in kqueue, so we can now watch for events on this
+                // new socket.
+                EV_SET(change_event, socket_connection_fd, EVFILT_READ, EV_ADD, 0, 0, NULL);
+                if (kevent(kq, change_event, 1, NULL, 0, NULL) < 0)
+                {
+                    perror("kevent error");
+                }
+            }
+
+            else if (event[i].filter & EVFILT_READ)
+            {
+                // Read bytes from socket
+                char buf[1024];
+                size_t bytes_read = recv(event_fd, buf, sizeof(buf), 0);
+                printf("read %zu bytes\n", bytes_read);
+            }
+        }
+    }
+
+    return 0;
+}