@@ -191,7 +191,7 @@ resource context_res(ctx: context_t) {
191
191
}
192
192
}
193
193
194
-
194
+ // Create a zeromq context.
195
195
fn init ( io_threads : int ) -> result:: t < context , error > unsafe {
196
196
let zmq_ctx = libzmq:: zmq_init ( io_threads as i32 ) ;
197
197
@@ -354,10 +354,12 @@ obj new_socket(sock: @socket_res) {
354
354
if r == -1i32 { err ( errno_to_error ( ) ) } else { ok ( ( ) ) }
355
355
}
356
356
357
+ // Accept connections on a socket.
357
358
fn bind ( endpoint : str ) -> result:: t < ( ) , error > {
358
359
_bind ( sock, endpoint)
359
360
}
360
361
362
+ // Connect a socket.
361
363
fn connect ( endpoint : str ) -> result:: t < ( ) , error > {
362
364
_connect ( sock, endpoint)
363
365
}
@@ -416,7 +418,7 @@ fn _connect(sock: @socket_res, endpoint: str) -> result::t<(), error> {
416
418
if rc == -1i32 { err ( errno_to_error ( ) ) } else { ok ( ( ) ) }
417
419
}
418
420
419
-
421
+ // Convert a socket kind into the constant value.
420
422
fn socket_kind_to_i32 ( k : socket_kind ) -> c_int {
421
423
alt k {
422
424
PAIR . { constants : : ZMQ_PAIR }
@@ -433,6 +435,7 @@ fn socket_kind_to_i32(k: socket_kind) -> c_int {
433
435
}
434
436
}
435
437
438
+ // Return the error string for an error.
436
439
fn error_to_str ( error : error ) -> str unsafe {
437
440
let s = libzmq:: zmq_strerror ( error_to_errno ( error) ) ;
438
441
ret if unsafe :: reinterpret_cast ( s) == -1 {
@@ -443,6 +446,7 @@ fn error_to_str(error: error) -> str unsafe {
443
446
}
444
447
}
445
448
449
+ // Convert the errno into an error type.
446
450
fn errno_to_error ( ) -> error {
447
451
alt libzmq:: zmq_errno ( ) {
448
452
e when e == constants:: ENOTSUP { ENOTSUP }
@@ -462,6 +466,7 @@ fn errno_to_error() -> error {
462
466
}
463
467
}
464
468
469
+ // Convert an error into an error number.
465
470
fn error_to_errno ( error : error ) -> c_int {
466
471
alt error {
467
472
ENOTSUP . { constants : : ENOTSUP }
0 commit comments