src/Pure/General/socket_io.ML
changeset 54342 fbcaa9f08879
parent 54340 18c621069bf8
child 62354 fdd6989cc8a0
equal deleted inserted replaced
54341:e1c275df5522 54342:fbcaa9f08879
    23     val name = NetHostDB.toString host ^ ":" ^ string_of_int port;
    23     val name = NetHostDB.toString host ^ ":" ^ string_of_int port;
    24 
    24 
    25     val rd =
    25     val rd =
    26       BinPrimIO.RD {
    26       BinPrimIO.RD {
    27         name = name,
    27         name = name,
    28         chunkSize = 4096,
    28         chunkSize = io_buffer_size,
    29         readVec = SOME (fn n => Socket.recvVec (socket, n)),
    29         readVec = SOME (fn n => Socket.recvVec (socket, n)),
    30         readArr = SOME (fn buffer => Socket.recvArr (socket, buffer)),
    30         readArr = SOME (fn buffer => Socket.recvArr (socket, buffer)),
    31         readVecNB = NONE,
    31         readVecNB = NONE,
    32         readArrNB = NONE,
    32         readArrNB = NONE,
    33         block = NONE,
    33         block = NONE,
    42       };
    42       };
    43 
    43 
    44     val wr =
    44     val wr =
    45       BinPrimIO.WR {
    45       BinPrimIO.WR {
    46         name = name,
    46         name = name,
    47         chunkSize = 4096,
    47         chunkSize = io_buffer_size,
    48         writeVec = SOME (fn buffer => Socket.sendVec (socket, buffer)),
    48         writeVec = SOME (fn buffer => Socket.sendVec (socket, buffer)),
    49         writeArr = SOME (fn buffer => Socket.sendArr (socket, buffer)),
    49         writeArr = SOME (fn buffer => Socket.sendArr (socket, buffer)),
    50         writeVecNB = NONE,
    50         writeVecNB = NONE,
    51         writeArrNB = NONE,
    51         writeArrNB = NONE,
    52         block = NONE,
    52         block = NONE,