Skip to content
forked from kail-cali/Filec

asyncio - non-blocking socket server implemented on Spark

Notifications You must be signed in to change notification settings

Hail-cali/cspark

 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

56 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Multiplex-Full-duplex Server on Spark Implementation

Socket Server based on spark architecture

verseion <v2.2.3>

Feature

  • MulitPlexing- Non-Blocking Server
  • Full-duplex pipe connections on Pool resources handling
  • Job Sheduleing

API

  • Find File and Transfer
  • Word Count (Dev)

Acrciteture

  • Listen Server
  • Cluster Manager
    • Job Scheduling Handler(FIFO)
    • Classifiy Jobs Handler
    • Sub Tasks Handler

How To Run

  • How to compile

  • at root dir ./FileC source MakeFile && source MakeClient

  • How to run Server

./start_server

Client

./start_client

IMPORTANT

  • SECRET NOT INCLUDED IN GIT, WRITE SECRET ON YOUR CONTROL.TXT
  • ./server/control.txt'
  • ./client/secret.txt

Exception Handling

socket worked with asyncio -non blocking, needed to exception handling

  • timeout :: close socket fd
  • Connection failure:: close socket
  • Retires :: close socket
  • slow connection :: deal wtih timeout
  • partial read :: caused by I/O error or slow network etc.. deal with terminate session

About

asyncio - non-blocking socket server implemented on Spark

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages

  • C 97.4%
  • Shell 2.6%